l g]c@sdZGddeZGddeZGddeZGddeZGd 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;d<eZGd=d>eZ Gd?d@eZ!GdAdBeZ"GdCdDeZ#GdEdFeZ$GdGdHeZ%GdIdJe#Z&dKS(LuPika specific exceptionscBs|EeZdZdS(cCsd|jj|jfS(Nu.%s: An unspecified AMQP error has occurred; %s(u __class__u__name__uargs(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__repr__sN(u__name__u __module__u__repr__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu AMQPErrors u AMQPErrorcBs|EeZdZdS(cCsYt|jdkr<dj|jj|jd|jdSdj|jj|jSdS(Niu {}: ({}) {}iiu{}: {}(ulenuargsuformatu __class__u__name__(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__repr__sN(u__name__u __module__u__repr__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuAMQPConnectionError s uAMQPConnectionErrorcBs|EeZdZdS(u'Client closed connection while opening.N(u__name__u __module__u__doc__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuConnectionOpenAborteds uConnectionOpenAbortedcBs|EeZdZdS(uStream (TCP) connection lost.N(u__name__u __module__u__doc__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuStreamLostErrors uStreamLostErrorcBs|EeZdZdS(cCsd|jj|jfS(Nu<%s: The protocol returned by the server is not supported: %s(u __class__u__name__uargs(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__repr__ s N(u__name__u __module__u__repr__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuIncompatibleProtocolErrors uIncompatibleProtocolErrorcBs|EeZdZdS(cCsd|jj|jdfS(NuP%s: Server and client could not negotiate use of the %s authentication mechanismi(u __class__u__name__uargs(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__repr__*s N(u__name__u __module__u__repr__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuAuthenticationError(s uAuthenticationErrorcBs|EeZdZdS(cCsd|jj|jfS(Nu`%s: Client was disconnected at a connection stage indicating a probable authentication error: %s(u __class__u__name__uargs(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__repr__2s N(u__name__u __module__u__repr__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuProbableAuthenticationError0s uProbableAuthenticationErrorcBs|EeZdZdS(cCsd|jj|jfS(Nuz%s: Client was disconnected at a connection stage indicating a probable denial of access to the specified virtual host: %s(u __class__u__name__uargs(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__repr__=s N(u__name__u __module__u__repr__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuProbableAccessDeniedError;s uProbableAccessDeniedErrorcBs|EeZdZdS(cCsd|jjS(Nu/%s: The connection has run out of free channels(u __class__u__name__(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__repr__HsN(u__name__u __module__u__repr__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuNoFreeChannelsFs uNoFreeChannelscs#|EeZdZfdZS(u9Connection is in wrong state for the requested operation.cs.|jrtt|jSd|jjSdS(NuA%s: The connection is in wrong state for the requested operation.(uargsusuperuConnectionWrongStateErroru__repr__u __class__u__name__(uself(u __class__(u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__repr__Ps (u__name__u __module__u__doc__u__repr__(u __locals__((u __class__u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuConnectionWrongStateErrorMs uConnectionWrongStateErrorcsD|EeZfdZdZedZedZS(cs)tt|jt|t|dS(uQ :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(usuperuConnectionClosedu__init__uintustr(uselfu reply_codeu reply_text(u __class__(u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__init__Zs cCsdj|jj|j|jS(Nu {}: ({}) {!r}(uformatu __class__u__name__u reply_codeu reply_text(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__repr__escCs |jdS(u, NEW in v1.0.0 :rtype: int i(uargs(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu reply_codeiscCs |jdS(u, NEW in v1.0.0 :rtype: str i(uargs(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu reply_textqs(u__name__u __module__u__init__u__repr__upropertyu reply_codeu reply_text(u __locals__((u __class__u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuConnectionClosedXs  uConnectionClosedcBs|EeZdZdS(uConnection.Close from broker.N(u__name__u __module__u__doc__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuConnectionClosedByBrokerzs uConnectionClosedByBrokercBs|EeZdZdS(u0Connection was closed at request of Pika client.N(u__name__u __module__u__doc__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuConnectionClosedByClient~s uConnectionClosedByClientcBs|EeZdZdS(u>RabbitMQ-specific: timed out waiting for connection.unblocked.N(u__name__u __module__u__doc__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuConnectionBlockedTimeouts uConnectionBlockedTimeoutcBs|EeZdZdS(u6Connection was dropped as result of heartbeat timeout.N(u__name__u __module__u__doc__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuAMQPHeartbeatTimeouts uAMQPHeartbeatTimeoutcBs|EeZdZdS(cCsdj|jj|jS(Nu{}: {!r}(uformatu __class__u__name__uargs(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__repr__sN(u__name__u __module__u__repr__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuAMQPChannelErrors uAMQPChannelErrorcBs|EeZdZdS(u6Channel is in wrong state for the requested operation.N(u__name__u __module__u__doc__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuChannelWrongStateErrors uChannelWrongStateErrorcsJ|EeZdZfdZdZedZedZS(u/The channel closed by client or by broker cs)tt|jt|t|dS(u :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(usuperu ChannelClosedu__init__uintustr(uselfu reply_codeu reply_text(u __class__(u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__init__s cCsdj|jj|j|jS(Nu {}: ({}) {!r}(uformatu __class__u__name__u reply_codeu reply_text(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__repr__scCs |jdS(u, NEW in v1.0.0 :rtype: int i(uargs(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu reply_codescCs |jdS(u, NEW in v1.0.0 :rtype: str i(uargs(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu reply_texts(u__name__u __module__u__doc__u__init__u__repr__upropertyu reply_codeu reply_text(u __locals__((u __class__u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu ChannelCloseds  u ChannelClosedcBs|EeZdZdS(u`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 N(u__name__u __module__u__doc__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuChannelClosedByBrokers uChannelClosedByBrokercBs|EeZdZdS(uChannel 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 N(u__name__u __module__u__doc__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuChannelClosedByClients uChannelClosedByClientcBs|EeZdZdS(cCsd|jj|jdfS(NuB%s: The consumer tag specified already exists for this channel: %si(u __class__u__name__uargs(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__repr__sN(u__name__u __module__u__repr__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuDuplicateConsumerTags uDuplicateConsumerTagcBs|EeZdZdS(cCsd|jjS(Nu%s: Server cancelled consumer(u __class__u__name__(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__repr__sN(u__name__u __module__u__repr__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuConsumerCancelleds uConsumerCancelledcs,|EeZdZfdZdZS(u-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 cs-tt|jdt|||_dS(u :param sequence(blocking_connection.ReturnedMessage) messages: Sequence of returned unroutable messages u!%s unroutable message(s) returnedN(usuperuUnroutableErroru__init__ulenumessages(uselfumessages(u __class__(u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__init__scCsd|jjt|jfS(Nu-%s: %i unroutable messages returned by broker(u __class__u__name__ulenumessages(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__repr__s(u__name__u __module__u__doc__u__init__u__repr__(u __locals__((u __class__u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuUnroutableErrors  uUnroutableErrorcs,|EeZdZfdZdZS(uThis exception is raised when a message published in publisher-acknowledgements mode is Nack'ed by the broker. Used by BlockingChannel. cs-tt|jdt|||_dS(u :param sequence(blocking_connection.ReturnedMessage) messages: Sequence of returned unroutable messages u%s message(s) NACKedN(usuperu NackErroru__init__ulenumessages(uselfumessages(u __class__(u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__init__scCsd|jjt|jfS(Nu-%s: %i unroutable messages returned by broker(u __class__u__name__ulenumessages(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__repr__s(u__name__u __module__u__doc__u__init__u__repr__(u __locals__((u __class__u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu NackErrors  u NackErrorcBs|EeZdZdS(cCsd|jj|jdfS(Nu4%s: An invalid channel number has been specified: %si(u __class__u__name__uargs(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__repr__ sN(u__name__u __module__u__repr__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuInvalidChannelNumber s uInvalidChannelNumbercBs|EeZdZdS(cCsd|jjS(Nu1%s: An unspecified protocol syntax error occurred(u __class__u__name__(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__repr__sN(u__name__u __module__u__repr__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuProtocolSyntaxErrors uProtocolSyntaxErrorcBs|EeZdZdS(cCsd|jj|jdfS(Nu(%s: Received a frame out of sequence: %ri(u __class__u__name__uargs(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__repr__sN(u__name__u __module__u__repr__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuUnexpectedFrameErrors uUnexpectedFrameErrorcBs|EeZdZdS(cCs%d|jj|jd|jdfS(Nu-%s: Protocol versions did not match: %r vs %rii(u __class__u__name__uargs(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__repr__"sN(u__name__u __module__u__repr__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuProtocolVersionMismatch s uProtocolVersionMismatchcBs|EeZdZdS(cCs%d|jj|jd|jdfS(NuL%s: Received too many bytes for a message delivery: Received %i, expected %iii(u __class__u__name__uargs(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__repr__)s N(u__name__u __module__u__repr__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuBodyTooLongError's uBodyTooLongErrorcBs|EeZdZdS(cCsd|jj|jdfS(Nu%s: Invalid frame received: %ri(u __class__u__name__uargs(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__repr__1s N(u__name__u __module__u__repr__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuInvalidFrameError/s uInvalidFrameErrorcBs|EeZdZdS(cCsd|jj|jdfS(Nu%s: Unsupported field kind %si(u __class__u__name__uargs(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__repr__8s N(u__name__u __module__u__repr__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuInvalidFieldTypeException6s uInvalidFieldTypeExceptioncBs|EeZdZdS(cCs!d|jjt|jdfS(Nu%s: Unsupported field kind %si(u __class__u__name__utypeuargs(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__repr__?s N(u__name__u __module__u__repr__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuUnsupportedAMQPFieldException=s uUnsupportedAMQPFieldExceptioncBs|EeZdS(N(u__name__u __module__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuMethodNotImplementedDs uMethodNotImplementedcBs|EeZdZdS(cCsd|jjS(Nu2%s: An unspecified error occurred with the Channel(u __class__u__name__(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__repr__JsN(u__name__u __module__u__repr__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu ChannelErrorHs u ChannelErrorcBs|EeZdZdS(uThe requested operation would result in unsupported recursion or reentrancy. Used by BlockingConnection/BlockingChannel N(u__name__u __module__u__doc__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuReentrancyErrorOs uReentrancyErrorcBs|EeZdZdS(cCsd|jj|jdfS(Nu9%s: AMQP Short String can contain up to 255 bytes: %.300si(u __class__u__name__uargs(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__repr__ZsN(u__name__u __module__u__repr__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuShortStringTooLongXs uShortStringTooLongcBs|EeZdZdS(cCsd|jjS(Nu`%s: basic_get can only be called again after the callback for the previous basic_get is executed(u __class__u__name__(uself((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyu__repr__asN(u__name__u __module__u__repr__(u __locals__((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyuDuplicateGetOkCallback_s uDuplicateGetOkCallbackN('u__doc__u Exceptionu AMQPErroruAMQPConnectionErroruConnectionOpenAborteduStreamLostErroruIncompatibleProtocolErroruAuthenticationErroruProbableAuthenticationErroruProbableAccessDeniedErroruNoFreeChannelsuConnectionWrongStateErroruConnectionCloseduConnectionClosedByBrokeruConnectionClosedByClientuConnectionBlockedTimeoutuAMQPHeartbeatTimeoutuAMQPChannelErroruChannelWrongStateErroru ChannelCloseduChannelClosedByBrokeruChannelClosedByClientuDuplicateConsumerTaguConsumerCancelleduUnroutableErroru NackErroruInvalidChannelNumberuProtocolSyntaxErroruUnexpectedFrameErroruProtocolVersionMismatchuBodyTooLongErroruInvalidFrameErroruInvalidFieldTypeExceptionuUnsupportedAMQPFieldExceptionuMethodNotImplementedu ChannelErroruReentrancyErroruShortStringTooLonguDuplicateGetOkCallback(((u4/srv/kernel/kteam-tools/dashboard/pika/exceptions.pyusJ     "(