ó Ģ g]c@s8dZdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZd efd „ƒYZd efd „ƒYZd efd„ƒYZdefd„ƒYZ defd„ƒYZ defd„ƒYZ defd„ƒYZ de fd„ƒYZ de fd„ƒYZdefd„ƒYZdefd„ƒYZdefd „ƒYZd!efd"„ƒYZd#efd$„ƒYZd%efd&„ƒYZd'efd(„ƒYZd)efd*„ƒYZd+efd,„ƒYZd-efd.„ƒYZd/efd0„ƒYZd1efd2„ƒYZd3efd4„ƒYZd5efd6„ƒYZd7efd8„ƒYZd9efd:„ƒYZd;efd<„ƒYZd=efd>„ƒYZ d?efd@„ƒYZ!dAefdB„ƒYZ"dCefdD„ƒYZ#dEefdF„ƒYZ$dGefdH„ƒYZ%dIe#fdJ„ƒYZ&dKS(LsPika specific exceptionst AMQPErrorcBseZd„ZRS(cCsd|jj|jfS(Ns.%s: An unspecified AMQP error has occurred; %s(t __class__t__name__targs(tself((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyt__repr__s(Rt __module__R(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyRstAMQPConnectionErrorcBseZd„ZRS(cCsYt|jƒdkr<dj|jj|jd|jdƒSdj|jj|jƒSdS(Nis {}: ({}) {}iis{}: {}(tlenRtformatRR(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyRs(RRR(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR stConnectionOpenAbortedcBseZdZRS(s'Client closed connection while opening.(RRt__doc__(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR stStreamLostErrorcBseZdZRS(sStream (TCP) connection lost.(RRR (((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR stIncompatibleProtocolErrorcBseZd„ZRS(cCsd|jj|jfS(Ns<%s: The protocol returned by the server is not supported: %s(RRR(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR s (RRR(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR stAuthenticationErrorcBseZd„ZRS(cCsd|jj|jdfS(NsP%s: Server and client could not negotiate use of the %s authentication mechanismi(RRR(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR*s (RRR(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR(stProbableAuthenticationErrorcBseZd„ZRS(cCsd|jj|jfS(Ns`%s: Client was disconnected at a connection stage indicating a probable authentication error: %s(RRR(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR2s (RRR(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR0stProbableAccessDeniedErrorcBseZd„ZRS(cCsd|jj|jfS(Nsz%s: Client was disconnected at a connection stage indicating a probable denial of access to the specified virtual host: %s(RRR(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR=s (RRR(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR;stNoFreeChannelscBseZd„ZRS(cCsd|jjS(Ns/%s: The connection has run out of free channels(RR(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyRHs(RRR(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyRFstConnectionWrongStateErrorcBseZdZd„ZRS(s9Connection is in wrong state for the requested operation.cCs.|jrtt|ƒjƒSd|jjSdS(NsA%s: The connection is in wrong state for the requested operation.(RtsuperRRRR(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyRPs (RRR R(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyRMstConnectionClosedcBs8eZd„Zd„Zed„ƒZed„ƒZRS(cCs)tt|ƒjt|ƒt|ƒƒdS(sQ :param int reply_code: reply-code that was used in user's or broker's `Connection.Close` method. NEW in v1.0.0 :param str reply_text: reply-text that was used in user's or broker's `Connection.Close` method. Human-readable string corresponding to `reply_code`. NEW in v1.0.0 N(RRt__init__tinttstr(Rt reply_codet reply_text((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyRZs cCsdj|jj|j|jƒS(Ns {}: ({}) {!r}(R RRRR(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyRescCs |jdS(s, NEW in v1.0.0 :rtype: int i(R(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyRiscCs |jdS(s, NEW in v1.0.0 :rtype: str i(R(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyRqs(RRRRtpropertyRR(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyRXs tConnectionClosedByBrokercBseZdZRS(sConnection.Close from broker.(RRR (((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyRzstConnectionClosedByClientcBseZdZRS(s0Connection was closed at request of Pika client.(RRR (((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR~stConnectionBlockedTimeoutcBseZdZRS(s>RabbitMQ-specific: timed out waiting for connection.unblocked.(RRR (((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR‚stAMQPHeartbeatTimeoutcBseZdZRS(s6Connection was dropped as result of heartbeat timeout.(RRR (((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR†stAMQPChannelErrorcBseZd„ZRS(cCsdj|jj|jƒS(Ns{}: {!r}(R RRR(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyRŒs(RRR(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyRŠstChannelWrongStateErrorcBseZdZRS(s6Channel is in wrong state for the requested operation.(RRR (((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR st ChannelClosedcBs>eZdZd„Zd„Zed„ƒZed„ƒZRS(s/The channel closed by client or by broker cCs)tt|ƒjt|ƒt|ƒƒdS(sŒ :param int reply_code: reply-code that was used in user's or broker's `Channel.Close` method. One of the AMQP-defined Channel Errors. NEW in v1.0.0 :param str reply_text: reply-text that was used in user's or broker's `Channel.Close` method. Human-readable string corresponding to `reply_code`; NEW in v1.0.0 N(RR!RRR(RRR((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR™s cCsdj|jj|j|jƒS(Ns {}: ({}) {!r}(R RRRR(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR§scCs |jdS(s, NEW in v1.0.0 :rtype: int i(R(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR«scCs |jdS(s, NEW in v1.0.0 :rtype: str i(R(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR³s(RRR RRRRR(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR!”s   tChannelClosedByBrokercBseZdZRS(s»`Channel.Close` from broker; may be passed as reason to channel's on-closed callback of non-blocking connection adapters or raised by `BlockingConnection`. NEW in v1.0.0 (RRR (((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR"¼stChannelClosedByClientcBseZdZRS(sąChannel closed by client upon receipt of `Channel.CloseOk`; may be passed as reason to channel's on-closed callback of non-blocking connection adapters, but not raised by `BlockingConnection`. NEW in v1.0.0 (RRR (((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR#ÅstDuplicateConsumerTagcBseZd„ZRS(cCsd|jj|jdfS(NsB%s: The consumer tag specified already exists for this channel: %si(RRR(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyRŠs(RRR(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR$ĪstConsumerCancelledcBseZd„ZRS(cCsd|jjS(Ns%s: Server cancelled consumer(RR(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR×s(RRR(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR%ÕstUnroutableErrorcBs eZdZd„Zd„ZRS(s-Exception containing one or more unroutable messages returned by broker via Basic.Return. Used by BlockingChannel. In publisher-acknowledgements mode, this is raised upon receipt of Basic.Ack from broker; in the event of Basic.Nack from broker, `NackError` is raised instead cCs-tt|ƒjdt|ƒƒ||_dS(s… :param sequence(blocking_connection.ReturnedMessage) messages: Sequence of returned unroutable messages s!%s unroutable message(s) returnedN(RR&RRtmessages(RR'((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyRęscCsd|jjt|jƒfS(Ns-%s: %i unroutable messages returned by broker(RRRR'(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyRšs(RRR RR(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR&Ūs  t NackErrorcBs eZdZd„Zd„ZRS(s•This exception is raised when a message published in publisher-acknowledgements mode is Nack'ed by the broker. Used by BlockingChannel. cCs-tt|ƒjdt|ƒƒ||_dS(s… :param sequence(blocking_connection.ReturnedMessage) messages: Sequence of returned unroutable messages s%s message(s) NACKedN(RR(RRR'(RR'((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyRüscCsd|jjt|jƒfS(Ns-%s: %i unroutable messages returned by broker(RRRR'(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyRs(RRR RR(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR(õs tInvalidChannelNumbercBseZd„ZRS(cCsd|jj|jdfS(Ns4%s: An invalid channel number has been specified: %si(RRR(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR s(RRR(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR) stProtocolSyntaxErrorcBseZd„ZRS(cCsd|jjS(Ns1%s: An unspecified protocol syntax error occurred(RR(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyRs(RRR(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR*stUnexpectedFrameErrorcBseZd„ZRS(cCsd|jj|jdfS(Ns(%s: Received a frame out of sequence: %ri(RRR(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyRs(RRR(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR+stProtocolVersionMismatchcBseZd„ZRS(cCs%d|jj|jd|jdfS(Ns-%s: Protocol versions did not match: %r vs %rii(RRR(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR"s(RRR(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR, stBodyTooLongErrorcBseZd„ZRS(cCs%d|jj|jd|jdfS(NsL%s: Received too many bytes for a message delivery: Received %i, expected %iii(RRR(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR)s (RRR(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR-'stInvalidFrameErrorcBseZd„ZRS(cCsd|jj|jdfS(Ns%s: Invalid frame received: %ri(RRR(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR1s (RRR(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR./stInvalidFieldTypeExceptioncBseZd„ZRS(cCsd|jj|jdfS(Ns%s: Unsupported field kind %si(RRR(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR8s (RRR(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR/6stUnsupportedAMQPFieldExceptioncBseZd„ZRS(cCs!d|jjt|jdƒfS(Ns%s: Unsupported field kind %si(RRttypeR(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR?s (RRR(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR0=stMethodNotImplementedcBseZRS((RR(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR2Dst ChannelErrorcBseZd„ZRS(cCsd|jjS(Ns2%s: An unspecified error occurred with the Channel(RR(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyRJs(RRR(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR3HstReentrancyErrorcBseZdZRS(s†The requested operation would result in unsupported recursion or reentrancy. Used by BlockingConnection/BlockingChannel (RRR (((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR4OstShortStringTooLongcBseZd„ZRS(cCsd|jj|jdfS(Ns9%s: AMQP Short String can contain up to 255 bytes: %.300si(RRR(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyRZs(RRR(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR5XstDuplicateGetOkCallbackcBseZd„ZRS(cCsd|jjS(Ns`%s: basic_get can only be called again after the callback for the previous basic_get is executed(RR(R((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyRas(RRR(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyR6_sN('R t ExceptionRRR R R RRRRRRRRRRRR R!R"R#R$R%R&R(R)R*R+R,R-R.R/R0R2R3R4R5R6(((s4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pytsJ     "(