)Jf'dZGddeZGddeZGddeZGddeZGd d eZGd d eZGd deZGddeZ GddeZ GddeZ GddeZ Gdde Z Gdde ZGddeZGddeZGdd eZGd!d"eZGd#d$eZGd%d&eZGd'd(eZGd)d*eZGd+d,eZGd-d.eZGd/d0eZGd1d2eZGd3d4eZGd5d6eZGd7d8eZGd9d:eZGd;deZ Gd?d@eZ!GdAdBeZ"GdCdDeZ#GdEdFeZ$GdGdHeZ%GdIdJe#Z&dKS)LzPika specific exceptionsceZdZdZdS) AMQPErrorc.|jjd|jS)Nz*: An unspecified AMQP error has occurred;  __class____name__argsselfs R/home/alex/cs2snipeproduction/venv/lib/python3.11/site-packages/pika/exceptions.py__repr__zAMQPError.__repr__s N # # #TYY0 0Nr __module__ __qualname__r r r rrs#00000r rceZdZdZdS)AMQPConnectionErrorct|jdkr7d|jj|jd|jdSd|jj|jS)Nz {}: ({}) {}z{}: {})lenrformatrrr s r r zAMQPConnectionError.__repr__sb ty>>Q   ''(?1(, ! 66 6??4>#:DIFF Fr Nrrr r rr s(GGGGGr rceZdZdZdS)ConnectionOpenAbortedz'Client closed connection while opening.Nrrr__doc__rr r rrs1111r rceZdZdZdS)StreamLostErrorzStream (TCP) connection lost.Nrrr r rr''''r rceZdZdZdS)IncompatibleProtocolErrorc.|jjd|jS)Nz8: The protocol returned by the server is not supported: rr s r r z"IncompatibleProtocolError.__repr__ s#'''   r Nrrr r r"r"s#r r"ceZdZdZdS)AuthenticationErrorc<|jjd|jddS)Nz3: Server and client could not negotiate use of the rz authentication mechanismrr s r r zAuthenticationError.__repr__*s'.2n.E.E.E.2illl< =r Nrrr r r%r%(s#=====r r%ceZdZdZdS)ProbableAuthenticationErrorc.|jjd|jS)Nz\: Client was disconnected at a connection stage indicating a probable authentication error: rr s r r z$ProbableAuthenticationError.__repr__2#'''   r Nrrr r r(r(0#r r(ceZdZdZdS)ProbableAccessDeniedErrorc.|jjd|jS)Nzv: Client was disconnected at a connection stage indicating a probable denial of access to the specified virtual host: rr s r r z"ProbableAccessDeniedError.__repr__=r*r Nrrr r r-r-;r+r r-ceZdZdZdS)NoFreeChannelsc d|jjzS)Nz/%s: The connection has run out of free channelsrrr s r r zNoFreeChannels.__repr__Hs@ N #% %r Nrrr r r0r0F#%%%%%r r0c"eZdZdZfdZxZS)ConnectionWrongStateErrorz9Connection is in wrong state for the requested operation.c~|jr'tt|Sd|jjzS)NzA%s: The connection is in wrong state for the requested operation.)rsuperr5r rr)r rs r r z"ConnectionWrongStateError.__repr__PsA 9 <2D99BBDD D!#'>#:; CC<<<<<<<<RabbitMQ-specific: timed out waiting for connection.unblocked.Nrrr r rSrSsHHHHr rSceZdZdZdS)AMQPHeartbeatTimeoutz6Connection was dropped as result of heartbeat timeout.Nrrr r rUrU@@@@r rUceZdZdZdS)AMQPChannelErrorcLd|jj|jS)Nz{}: {!r})rrrrr s r r zAMQPChannelError.__repr__s  !8$)DDDr Nrrr r rXrXs(EEEEEr rXceZdZdZdS)ChannelWrongStateErrorz6Channel is in wrong state for the requested operation.Nrrr r r[r[rVr r[cTeZdZdZfdZdZedZedZxZ S) ChannelClosedz/The channel closed by client or by broker ctt|t|t |dS)a :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)r7r]r=r>r?r@s r r=zChannelClosed.__init__s7 mT""++C OOS__MMMMMr cXd|jj|j|jSrDrEr s r r zChannelClosed.__repr__rFr c|jdSrHrIr s r rAzChannelClosed.reply_coderJr c|jdSrLrIr s r rBzChannelClosed.reply_textrJr ) rrrrr=r rMrArBr8r9s@r r]r]s N N N N N777XXr r]ceZdZdZdS)ChannelClosedByBrokerz`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 Nrrr r rcrcr rcceZdZdZdS)ChannelClosedByClientzChannel 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 Nrrr r rfrfrdr rfceZdZdZdS)DuplicateConsumerTagc:|jjd|jdS)Nz>: The consumer tag specified already exists for this channel: rrr s r r zDuplicateConsumerTag.__repr__s&!%!8!8!8$)A,,H Ir Nrrr r rhrhs(IIIIIr rhceZdZdZdS)ConsumerCancelledc d|jjzS)Nz%s: Server cancelled consumerr2r s r r zConsumerCancelled.__repr__s.1HHHr Nrrr r rkrks(IIIIIr rkc(eZdZdZfdZdZxZS)UnroutableErrora-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 ctt|dt|z||_dS) :param sequence(blocking_connection.ReturnedMessage) messages: Sequence of returned unroutable messages z!%s unroutable message(s) returnedN)r7rnr=rmessagesr rqrs r r=zUnroutableError.__init__sE ot$$-- /3x== A C C C! r cHd|jjt|jfzSNz-%s: %i unroutable messages returned by brokerrrrrqr s r r zUnroutableError.__repr__)> N #S%7%7B99 9r rrrrr=r r8r9s@r rnrnsQ!!!!!9999999r rnc(eZdZdZfdZdZxZS) NackErrorzThis exception is raised when a message published in publisher-acknowledgements mode is Nack'ed by the broker. Used by BlockingChannel. ctt|dt|z||_dS)rpz%s message(s) NACKedN)r7ryr=rrqrrs r r=zNackError.__init__s> i  H3s8}}EFFF  r cHd|jjt|jfzSrtrur s r r zNackError.__repr__rvr rwr9s@r ryrysQ !!!!!9999999r ryceZdZdZdS)InvalidChannelNumberc:|jjd|jdS)Nz0: An invalid channel number has been specified: rrr s r r zInvalidChannelNumber.__repr__ $ N # # #TYq\\3 3r Nrrr r r}r} #33333r r}ceZdZdZdS)ProtocolSyntaxErrorc d|jjzS)Nz1%s: An unspecified protocol syntax error occurredr2r s r r zProtocolSyntaxError.__repr__sB N #% %r Nrrr r rrr3r rceZdZdZdS)UnexpectedFrameErrorc:|jjd|jdS)Nz$: Received a frame out of sequence: rrr s r r zUnexpectedFrameError.__repr__rr Nrrr r rrrr rceZdZdZdS)ProtocolVersionMismatchcV|jjd|jdd|jdS)Nz#: Protocol versions did not match: rz vs rrr s r r z ProtocolVersionMismatch.__repr__"s2 N # # #TYq\\\49Q<<A Ar Nrrr r rr (AAAAAr rceZdZdZdS)BodyTooLongErrorcRd|jj|jd|jdfzS)NzL%s: Received too many bytes for a message delivery: Received %i, expected %irrrr s r r zBodyTooLongError.__repr__)s2+.2n.E.2ilDIaL.JJ Kr Nrrr r rr's(KKKKKr rceZdZdZdS)InvalidFrameErrorc:|jjd|jdS)Nz: Invalid frame received: rrr s r r zInvalidFrameError.__repr__1s'37>3J3J3J379Q<<A Ar Nrrr r rr/rr rceZdZdZdS)InvalidFieldTypeExceptionc:|jjd|jdS)N: Unsupported field kind rrr s r r z"InvalidFieldTypeException.__repr__8s'26.2I2I2I26)A,,@ @r Nrrr r rr6s(@@@@@r rceZdZdZdS)UnsupportedAMQPFieldExceptioncT|jjdt|jdS)Nrr)rrtyperr s r r z&UnsupportedAMQPFieldException.__repr__?s026.2I2I2I26ty|2D2D2DF Fr Nrrr r rr=s(FFFFFr rceZdZdS)MethodNotImplementedN)rrrrr r rrDsDr rceZdZdZdS) ChannelErrorc d|jjzS)Nz2%s: An unspecified error occurred with the Channelr2r s r r zChannelError.__repr__JsC N #% %r Nrrr r rrHr3r rceZdZdZdS)ReentrancyErrorzThe requested operation would result in unsupported recursion or reentrancy. Used by BlockingConnection/BlockingChannel Nrrr r rrOrdr rceZdZdZdS)ShortStringTooLongc:d|jj|jdfzS)Nz9%s: AMQP Short String can contain up to 255 bytes: %.300srrr s r r zShortStringTooLong.__repr__Zs& N3TYq\BC Dr Nrrr r rrXs(DDDDDr rceZdZdZdS)DuplicateGetOkCallbackc d|jjzS)Nz`%s: basic_get can only be called again after the callback for the previous basic_get is executedr2r s r r zDuplicateGetOkCallback.__repr__as57;~7NO Pr Nrrr r rr_s(PPPPPr rN)'r Exceptionrrrrr"r%r(r-r0r5r;rOrQrSrUrXr[r]rcrfrhrkrnryr}rrrrrrrrrrrrrr r rs00000 000GGGGG)GGG22222/222((((()((( 3=====-==="5 3%%%%%(%%%<<<<< 3<<<*D(((((/(((;;;;;/;;;IIIII2IIIAAAAA.AAAEEEEEyEEE AAAAA-AAA%%%%%$%%%PMMIIIII+IIIIIIII(III 99999&999499999 999,333339333%%%%%)%%%33333.333AAAAA1AAAKKKKK*KKKAAAAA+AAA@@@@@ 3@@@FFFFF$7FFF     9   %%%%%9%%%iDDDDDDDDPPPPP\PPPPPr