o 1li'@sXdZGdddeZGdddeZGdddeZGdddeZGd d d eZGd d d eZGd ddeZGdddeZ GdddeZ GdddeZ GdddeZ Gddde Z Gddde ZGdddeZGdddeZGdd d eZGd!d"d"eZGd#d$d$eZGd%d&d&eZGd'd(d(eZGd)d*d*eZGd+d,d,eZGd-d.d.eZGd/d0d0eZGd1d2d2eZGd3d4d4eZGd5d6d6eZGd7d8d8eZGd9d:d:eZGd;d<dd>eZ Gd?d@d@eZ!GdAdBdBeZ"GdCdDdDeZ#GdEdFdFeZ$GdGdHdHeZ%GdIdJdJe#Z&dKS)LzPika specific exceptionsc@eZdZddZdS) AMQPErrorcCd|jj|jfS)Nz.%s: An unspecified AMQP error has occurred; %s __class____name__argsselfr _/var/www/html/tatsat2dev/dashboard-backend/venv/lib/python3.10/site-packages/pika/exceptions.py__repr__s zAMQPError.__repr__Nr __module__ __qualname__r r r r r r rc@r)AMQPConnectionErrorcCs>t|jdkrd|jj|jd|jdSd|jj|jS)Nz {}: ({}) {}z{}: {})lenrformatrrrr r r r s zAMQPConnectionError.__repr__Nr r r r r r rrc@eZdZdZdS)ConnectionOpenAbortedz'Client closed connection while opening.Nrrr__doc__r r r r rrc@r)StreamLostErrorzStream (TCP) connection lost.Nrr r r r rrrc@r)IncompatibleProtocolErrorcCr)Nz<%s: The protocol returned by the server is not supported: %srrr r r r s z"IncompatibleProtocolError.__repr__Nr r r r r rrrc@r)AuthenticationErrorcCd|jj|jdfS)NzP%s: Server and client could not negotiate use of the %s authentication mechanismrrrr r r r *s zAuthenticationError.__repr__Nr r r r r r(rrc@r)ProbableAuthenticationErrorcCr)Nz`%s: Client was disconnected at a connection stage indicating a probable authentication error: %srrr r r r 2 z$ProbableAuthenticationError.__repr__Nr r r r r r 0rr c@r)ProbableAccessDeniedErrorcCr)Nzz%s: Client was disconnected at a connection stage indicating a probable denial of access to the specified virtual host: %srrr r r r =r!z"ProbableAccessDeniedError.__repr__Nr r r r r r";rr"c@r)NoFreeChannelscC d|jjS)Nz/%s: The connection has run out of free channelsrrrr r r r HzNoFreeChannels.__repr__Nr r r r r r#Frr#cs eZdZdZfddZZS)ConnectionWrongStateErrorz9Connection is in wrong state for the requested operation.cs |jr tt|Sd|jjS)NzA%s: The connection is in wrong state for the requested operation.)rsuperr'r rrrrr r r Ps z"ConnectionWrongStateError.__repr__)rrrrr __classcell__r r r)r r'Msr'cs<eZdZfddZddZeddZeddZZS) ConnectionClosedctt|t|t|dS)aQ :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)r(r+__init__intstrr reply_code reply_textr)r r r-Zs zConnectionClosed.__init__cCd|jj|j|jSNz {}: ({}) {!r}rrrr1r2rr r r r ezConnectionClosed.__repr__cC |jdSz, NEW in v1.0.0 :rtype: int rrrr r r r1i zConnectionClosed.reply_codecCr7z, NEW in v1.0.0 :rtype: str rr9rr r r r2qr:zConnectionClosed.reply_text) rrrr-r propertyr1r2r*r r r)r r+Xs   r+c@r)ConnectionClosedByBrokerzConnection.Close from broker.Nrr r r r r=zrr=c@r)ConnectionClosedByClientz0Connection was closed at request of Pika client.Nrr r r r r>~rr>c@r)ConnectionBlockedTimeoutz>RabbitMQ-specific: timed out waiting for connection.unblocked.Nrr r r r r?rr?c@r)AMQPHeartbeatTimeoutz6Connection was dropped as result of heartbeat timeout.Nrr r r r r@rr@c@r)AMQPChannelErrorcCsd|jj|jS)Nz{}: {!r})rrrrrr r r r szAMQPChannelError.__repr__Nr r r r r rArrAc@r)ChannelWrongStateErrorz6Channel is in wrong state for the requested operation.Nrr r r r rBrrBcs@eZdZdZfddZddZeddZedd ZZ S) ChannelClosedz/The channel closed by client or by broker cr,)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)r(rCr-r.r/r0r)r r r-s zChannelClosed.__init__cCr3r4r5rr r r r r6zChannelClosed.__repr__cCr7r8r9rr r r r1r:zChannelClosed.reply_codecCr7r;r9rr r r r2r:zChannelClosed.reply_text) rrrrr-r r<r1r2r*r r r)r rCs  rCc@r)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 Nrr r r r rDrrDc@r)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 Nrr r r r rErrEc@r)DuplicateConsumerTagcCr)NzB%s: The consumer tag specified already exists for this channel: %srrrr r r r zDuplicateConsumerTag.__repr__Nr r r r r rFrrFc@r)ConsumerCancelledcCr$)Nz%s: Server cancelled consumerr%rr r r r s zConsumerCancelled.__repr__Nr r r r r rHrrHc(eZdZdZfddZddZZS)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 c"tt|dt|||_dS) :param sequence(blocking_connection.ReturnedMessage) messages: Sequence of returned unroutable messages z!%s unroutable message(s) returnedN)r(rJr-rmessagesr rMr)r r r-s   zUnroutableError.__init__cCd|jjt|jfSNz-%s: %i unroutable messages returned by brokerrrrrMrr r r r zUnroutableError.__repr__rrrrr-r r*r r r)r rJs  rJcrI) NackErrorzThis exception is raised when a message published in publisher-acknowledgements mode is Nack'ed by the broker. Used by BlockingChannel. crK)rLz%s message(s) NACKedN)r(rTr-rrMrNr)r r r-s  zNackError.__init__cCrOrPrQrr r r r rRzNackError.__repr__rSr r r)r rTs  rTc@r)InvalidChannelNumbercCr)Nz4%s: An invalid channel number has been specified: %srrrr r r r rRzInvalidChannelNumber.__repr__Nr r r r r rU rrUc@r)ProtocolSyntaxErrorcCr$)Nz1%s: An unspecified protocol syntax error occurredr%rr r r r r&zProtocolSyntaxError.__repr__Nr r r r r rVrrVc@r)UnexpectedFrameErrorcCr)Nz(%s: Received a frame out of sequence: %rrrrr r r r rRzUnexpectedFrameError.__repr__Nr r r r r rWrrWc@r)ProtocolVersionMismatchcCd|jj|jd|jdfS)Nz-%s: Protocol versions did not match: %r vs %rrrrrr r r r "sz ProtocolVersionMismatch.__repr__Nr r r r r rX rrXc@r)BodyTooLongErrorcCrY)NzL%s: Received too many bytes for a message delivery: Received %i, expected %irrrrr r r r )s zBodyTooLongError.__repr__Nr r r r r rZ'rrZc@r)InvalidFrameErrorcCr)Nz%s: Invalid frame received: %rrrrr r r r 1zInvalidFrameError.__repr__Nr r r r r r[/rr[c@r)InvalidFieldTypeExceptioncCr)N%s: Unsupported field kind %srrrr r r r 8r\z"InvalidFieldTypeException.__repr__Nr r r r r r]6rr]c@r)UnsupportedAMQPFieldExceptioncCsd|jjt|jdfS)Nr^r)rrtyperrr r r r ?s z&UnsupportedAMQPFieldException.__repr__Nr r r r r r_=rr_c@s eZdZdS)MethodNotImplementedN)rrrr r r r raDsrac@r) ChannelErrorcCr$)Nz2%s: An unspecified error occurred with the Channelr%rr r r r Jr&zChannelError.__repr__Nr r r r r rbHrrbc@r)ReentrancyErrorzThe requested operation would result in unsupported recursion or reentrancy. Used by BlockingConnection/BlockingChannel Nrr r r r rcOrrcc@r)ShortStringTooLongcCr)Nz9%s: AMQP Short String can contain up to 255 bytes: %.300srrrr r r r ZrGzShortStringTooLong.__repr__Nr r r r r rdXrrdc@r)DuplicateGetOkCallbackcCr$)Nz`%s: basic_get can only be called again after the callback for the previous basic_get is executedr%rr r r r ar&zDuplicateGetOkCallback.__repr__Nr r r r r re_rreN)'r Exceptionrrrrrrr r"r#r'r+r=r>r?r@rArBrCrDrErFrHrJrTrUrVrWrXrZr[r]r_rarbrcrdrer r r r sL     "(