>i'6dZGddeZGddeZGddeZGddeZGd 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&yK)LzPika specific exceptionsceZdZdZy) AMQPErrorcL|jjd|jS)Nz*: An unspecified AMQP error has occurred;  __class____name__argsselfs I/var/www/html/aiagents/fe/lib/python3.12/site-packages/pika/exceptions.py__repr__zAMQPError.__repr__s NN # #TYY0 0Nr __module__ __qualname__r r r rrs0r rceZdZdZy)AMQPConnectionErrorct|jdk(rAdj|jj|jd|jdSdj|jj|jS)Nz {}: ({}) {}z{}: {})lenrformatrrr s r r zAMQPConnectionError.__repr__sg tyy>Q  ''(?(?1(, ! 6 6??4>>#:#:DIIF Fr Nrrr r rr sGr rceZdZdZy)ConnectionOpenAbortedz'Client closed connection while opening.Nrrr__doc__rr r rrs1r rceZdZdZy)StreamLostErrorzStream (TCP) connection lost.Nrrr r rr'r rceZdZdZy)IncompatibleProtocolErrorcL|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"sr r"ceZdZdZy)AuthenticationErrorcT|jjd|jddS)Nz3: Server and client could not negotiate use of the rz authentication mechanismrr s r r zAuthenticationError.__repr__*s$.2nn.E.E.2iil< =r Nrrr r r%r%(s=r r%ceZdZdZy)ProbableAuthenticationErrorcL|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(0r r(ceZdZdZy)ProbableAccessDeniedErrorcL|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-ceZdZdZy)NoFreeChannelsc4d|jjzS)Nz/%s: The connection has run out of free channelsrrr s r r zNoFreeChannels.__repr__Hs@ NN # #% %r Nrrr r r0r0F%r r0c"eZdZdZfdZxZS)ConnectionWrongStateErrorz9Connection is in wrong state for the requested operation.cr|jrtt|Sd|jj zS)NzA%s: The connection is in wrong state for the requested operation.)rsuperr5r rr)r rs r r z"ConnectionWrongStateError.__repr__Ps7 992DBD D!#'>>#:#:; RabbitMQ-specific: timed out waiting for connection.unblocked.Nrrr r rSrSsHr rSceZdZdZy)AMQPHeartbeatTimeoutz6Connection was dropped as result of heartbeat timeout.Nrrr r rUrU@r rUceZdZdZy)AMQPChannelErrorcbdj|jj|jS)Nz{}: {!r})rrrrr s r r zAMQPChannelError.__repr__s#  !8!8$))DDr Nrrr r rXrXsEr rXceZdZdZy)ChannelWrongStateErrorz6Channel is in wrong state for the requested operation.Nrrr r r[r[rVr r[cHeZdZdZfdZdZedZedZxZ S) ChannelClosedz/The channel closed by client or by broker cRtt| t|t |y)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__s mT+C OS_Mr cxdj|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; N7r r]ceZdZdZy)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 rcceZdZdZy)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 rfceZdZdZy)DuplicateConsumerTagcR|jjd|jdS)Nz>: The consumer tag specified already exists for this channel: rrr s r r zDuplicateConsumerTag.__repr__s%!%!8!8$))A,H Ir Nrrr r rhrhsIr rhceZdZdZy)ConsumerCancelledc4d|jjzS)Nz%s: Server cancelled consumerr2r s r r zConsumerCancelled.__repr__s.1H1HHHr Nrrr r rkrksIr 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 cRtt| dt|z||_y) :param sequence(blocking_connection.ReturnedMessage) messages: Sequence of returned unroutable messages z!%s unroutable message(s) returnedN)r7rnr=rmessagesr rqrs r r=zUnroutableError.__init__s* ot- /3x= A C! r c^d|jjt|jfzSNz-%s: %i unroutable messages returned by brokerrrrrqr s r r zUnroutableError.__repr__-> NN # #S%7B99 9r rrrrr=r r8r9s@r rnrns!9r rnc(eZdZdZfdZdZxZS) NackErrorzThis exception is raised when a message published in publisher-acknowledgements mode is Nack'ed by the broker. Used by BlockingChannel. cRtt| dt|z||_y)rpz%s message(s) NACKedN)r7ryr=rrqrrs r r=zNackError.__init__s( i 3s8}EF  r c^d|jjt|jfzSrtrur s r r zNackError.__repr__rvr rwr9s@r ryrys !9r ryceZdZdZy)InvalidChannelNumbercR|jjd|jdS)Nz0: An invalid channel number has been specified: rrr s r r zInvalidChannelNumber.__repr__ # NN # #TYYq\3 3r Nrrr r r}r} 3r r}ceZdZdZy)ProtocolSyntaxErrorc4d|jjzS)Nz1%s: An unspecified protocol syntax error occurredr2r s r r zProtocolSyntaxError.__repr__sB NN # #% %r Nrrr r rrr3r rceZdZdZy)UnexpectedFrameErrorcR|jjd|jdS)Nz$: Received a frame out of sequence: rrr s r r zUnexpectedFrameError.__repr__rr Nrrr r rrrr rceZdZdZy)ProtocolVersionMismatchcr|jjd|jdd|jdS)Nz#: Protocol versions did not match: rz vs rrr s r r z ProtocolVersionMismatch.__repr__"s/ NN # #TYYq\499Q<A Ar Nrrr r rr Ar rceZdZdZy)BodyTooLongErrorcnd|jj|jd|jdfzS)NzL%s: Received too many bytes for a message delivery: Received %i, expected %irrrr s r r zBodyTooLongError.__repr__)s;+.2nn.E.E.2iilDIIaL.JJ Kr Nrrr r rr'sKr rceZdZdZy)InvalidFrameErrorcR|jjd|jdS)Nz: Invalid frame received: rrr s r r zInvalidFrameError.__repr__1s&37>>3J3J3799Q<A Ar Nrrr r rr/rr rceZdZdZy)InvalidFieldTypeExceptioncR|jjd|jdS)N: Unsupported field kind rrr s r r z"InvalidFieldTypeException.__repr__8s&26..2I2I26))A,@ @r Nrrr r rr6s@r rceZdZdZy)UnsupportedAMQPFieldExceptioncd|jjdt|jdS)Nrr)rrtyperr s r r z&UnsupportedAMQPFieldException.__repr__?s+26..2I2I26tyy|2DF Fr Nrrr r rr=sFr rc eZdZy)MethodNotImplementedN)rrrrr r rrDsr rceZdZdZy) ChannelErrorc4d|jjzS)Nz2%s: An unspecified error occurred with the Channelr2r s r r zChannelError.__repr__JsC NN # #% %r Nrrr r rrHr3r rceZdZdZy)ReentrancyErrorzThe requested operation would result in unsupported recursion or reentrancy. Used by BlockingConnection/BlockingChannel Nrrr r rrOrdr rceZdZdZy)ShortStringTooLongcRd|jj|jdfzS)Nz9%s: AMQP Short String can contain up to 255 bytes: %.300srrr s r r zShortStringTooLong.__repr__Zs- NN33TYYq\BC Dr Nrrr r rrXsDr rceZdZdZy)DuplicateGetOkCallbackc4d|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__as 57;~~7N7NO Pr Nrrr r rr_sPr rN)'r Exceptionrrrrr"r%r(r-r0r5r;rOrQrSrUrXr[r]rcrfrhrkrnryr}rrrrrrrrrrrrrr r rs0 0G)G2/2()( 3=-="5 3%(%< 3<*D(/(;/;I2IA.AEyE A-A%$%PMMI+II(I 9&949 9,393%)%3.3A1AK*KA+A@ 3@F$7F 9 %9%iDDP\Pr