File: //usr/local/lib/python3.9/site-packages/amqp/__pycache__/exceptions.cpython-39.pyc
a
X>h� � ? @ s� d Z ddlmZmZ dZG dd� de�ZG dd� de�ZG dd � d e�Z G d
d � d e �Z
G d d
� d
e �Z G dd� de �Z G dd� de �Z
G dd� de
�ZG dd� de
�ZG dd� de�ZG dd� de�ZG dd� de �ZG d d � d e �ZG d d � d e�ZG d d!� d!e�ZG d"d#� d#e
�ZG d$d%� d%e
�ZG d&d'� d'e �ZG d(d)� d)e
�ZG d*d+� d+e�ZG d,d-� d-e�ZG d.d/� d/e�Z G d0d1� d1e�Z G d2d3� d3e�Z G d4d5� d5e�Z G d6d7� d7e�Z G d8d9� d9e�Z!G d:d;� d;e�Z"eeeeeeeeeee e e e e e!e"d<�Z#d=d>� Z$d?d@dAdBdCdDdEdFdGdHdIdJdKdLdMdNdOdPdQdRdSdTdUdVdWdXdYdZd[d\d]d^d_d`dadbdcdddedfdgdhdidjdkdldmdndodpdqdrdsdtdudvdwdxdydzd{d|d}�>Z%e&e%�'� �D ](\Z(Z)e)e%ed~edge(�R � �d < �q�d�S )�zExceptions used by amqp.� )�pack�unpack)� AMQPError�ConnectionError� ChannelError�RecoverableConnectionError� IrrecoverableConnectionError�RecoverableChannelError�IrrecoverableChannelError�ConsumerCancelled�ContentTooLarge� NoConsumers�ConnectionForced� InvalidPath�
AccessRefused�NotFound�ResourceLocked�PreconditionFailed�
FrameError�FrameSyntaxError�InvalidCommand�ChannelNotOpen�UnexpectedFrame�
ResourceError�
NotAllowed�AMQPNotImplementedError�
InternalError�
MessageNacked�AMQPDeprecationWarningc @ s e Zd ZdZdS )r z Warning for deprecated things.N��__name__�
__module__� __qualname__�__doc__� r$ r$ �9/usr/local/lib/python3.9/site-packages/amqp/exceptions.pyr s r c @ s e Zd ZdZdS )r z Message was nacked by broker.Nr r$ r$ r$ r% r s r c @ s2 e Zd ZdZdZd
dd�Zdd� Zedd � �ZdS ) r z#Base class for all AMQP exceptions.r Nc C sX || _ |p| j| _|| _|| _|p$d| _|r@| js@t�|d�| _t� | |||| j� d S )N� )
�message�code�
reply_code�
reply_text�
method_sig� method_name�METHOD_NAME_MAP�get� Exception�__init__)�selfr* r+ r, r) r$ r$ r% r0 " s
�zAMQPError.__init__c C s& | j rd�| �S | jp$d�t| �j�S )Nz+{0.method}: ({0.reply_code}) {0.reply_text}z<{}: unknown error>)�method�formatr* �typer �r1 r$ r$ r% �__str__. s
�zAMQPError.__str__c C s | j p
| jS )N)r, r+ r5 r$ r$ r% r2 5 s zAMQPError.method)NNNN) r r! r" r# r( r0 r6 �propertyr2 r$ r$ r$ r% r s �
r c @ s e Zd ZdZdS )r zAMQP Connection Error.Nr r$ r$ r$ r% r : s r c @ s e Zd ZdZdS )r zAMQP Channel Error.Nr r$ r$ r$ r% r > s r c @ s e Zd ZdZdS )r z/Exception class for recoverable channel errors.Nr r$ r$ r$ r% r B s r c @ s e Zd ZdZdS )r
z1Exception class for irrecoverable channel errors.Nr r$ r$ r$ r% r
F s r
c @ s e Zd ZdZdS )r z2Exception class for recoverable connection errors.Nr r$ r$ r$ r% r J s r c @ s e Zd ZdZdS )r z4Exception class for irrecoverable connection errors.Nr r$ r$ r$ r% r N s r c @ s e Zd ZdZdS )�Blockedz"AMQP Connection Blocked Predicate.Nr r$ r$ r$ r% r8 R s r8 c @ s e Zd ZdZdS )r z"AMQP Consumer Cancelled Predicate.Nr r$ r$ r$ r% r V s r c @ s e Zd ZdZdZdS )r z AMQP Content Too Large Error.�7 N�r r! r" r# r( r$ r$ r$ r% r Z s r c @ s e Zd ZdZdZdS )r
zAMQP No Consumers Error.�9 Nr: r$ r$ r$ r% r
` s r
c @ s e Zd ZdZdZdS )r z AMQP Connection Forced Error.�@ Nr: r$ r$ r$ r% r f s r c @ s e Zd ZdZdZdS )r zAMQP Invalid Path Error.� Nr: r$ r$ r$ r% r l s r c @ s e Zd ZdZdZdS )r zAMQP Access Refused Error.� Nr: r$ r$ r$ r% r r s r c @ s e Zd ZdZdZdS )r zAMQP Not Found Error.� Nr: r$ r$ r$ r% r x s r c @ s e Zd ZdZdZdS )r zAMQP Resource Locked Error.� Nr: r$ r$ r$ r% r ~ s r c @ s e Zd ZdZdZdS )r z AMQP Precondition Failed Error.� Nr: r$ r$ r$ r% r � s r c @ s e Zd ZdZdZdS )r zAMQP Frame Error.� Nr: r$ r$ r$ r% r � s r c @ s e Zd ZdZdZdS )r zAMQP Frame Syntax Error.� Nr: r$ r$ r$ r% r � s r c @ s e Zd ZdZdZdS )r zAMQP Invalid Command Error.� Nr: r$ r$ r$ r% r � s r c @ s e Zd ZdZdZdS )r z AMQP Channel Not Open Error.� Nr: r$ r$ r$ r% r � s r c @ s e Zd ZdZdZdS )r zAMQP Unexpected Frame.� Nr: r$ r$ r$ r% r � s r c @ s e Zd ZdZdZdS )r zAMQP Resource Error.� Nr: r$ r$ r$ r% r � s r c @ s e Zd ZdZdZdS )r zAMQP Not Allowed Error.� Nr: r$ r$ r$ r% r � s r c @ s e Zd ZdZdZdS )r zAMQP Not Implemented Error.� Nr: r$ r$ r$ r% r � s r c @ s e Zd ZdZdZdS )r zAMQP Internal Error.� Nr: r$ r$ r$ r% r � s r )r9 r; r< r= r> r? r@ rA rB rC rD rE rF rG rH rI rJ c C s: zt | ||| d�W S ty4 |||| d� Y S 0 d S )N)r) )� ERROR_MAP�KeyError)r( �textr2 �defaultr$ r$ r% �error_for_code� s rO zConnection.startzConnection.start_okzConnection.securezConnection.secure_okzConnection.tunezConnection.tune_okzConnection.openzConnection.open_okzConnection.closezConnection.close_okz Channel.openzChannel.open_okz Channel.flowzChannel.flow_okz
Channel.closezChannel.close_okzAccess.requestzAccess.request_okzExchange.declarezExchange.declare_okzExchange.deletezExchange.delete_okz
Exchange.bindzExchange.bind_okzExchange.unbindzExchange.unbind_okz
Queue.declarezQueue.declare_okz
Queue.bindz
Queue.bind_okz Queue.purgezQueue.purge_okz Queue.deletezQueue.delete_okz Queue.unbindzQueue.unbind_okz Basic.qosz Basic.qos_okz
Basic.consumezBasic.consume_okz Basic.cancelzBasic.cancel_okz
Basic.publishz Basic.returnz
Basic.deliverz Basic.getz Basic.get_okzBasic.get_emptyz Basic.ackz Basic.rejectzBasic.recover_asyncz
Basic.recoverzBasic.recover_okz
Basic.nackz Tx.selectz Tx.select_okz Tx.commitz Tx.commit_okz Tx.rollbackzTx.rollback_okzConfirm.selectzConfirm.select_ok)>)�
rP )rP � )rP � )rP � )rP � )rP � )rP �( )rP �) )rP �2 )rP �3 )rR rP )rR rQ )rR rR )rR rS )rR rV )rR rW )rT rP )rT rQ )rV rP )rV rQ )rV rR )rV rS )rV rT )rV rU )rV rV )rV rW )rX rP )rX rQ )rX rR )rX rS )rX rT )rX rU )rX rV )rX rW )rX rX )rX rY )�< rP )rZ rQ )rZ rR )rZ rS )rZ rT )rZ rU )rZ rV )rZ rX )rZ rZ )rZ �F )rZ �G )rZ �H )rZ �P )rZ �Z )rZ �d )rZ �n )rZ �o )rZ �x )r_ rP )r_ rQ )r_ rR )r_ rS )r_ rT )r_ rU )�U rP )rd rQ z>Iz>HHN)*r# �structr r �__all__� UserWarningr r/ r r r r r r
r r r8 r r r
r r r r r r r r r r r r r r r rK rO r- �list�itemsZ
_method_idZ _method_namer$ r$ r$ r% �<module> s� ��B�