File: //home/arjun/projects/env/lib/python3.10/site-packages/amqp/__pycache__/exceptions.cpython-310.pyc
o
%we� �
@ 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"i d<e�d=e�d>e�d?e�d@e�dAe�dBe�dCe�dDe�dEe�dFe �dGe �dHe �dIe �dJe �dKe!�dLe"�Z#dMdN� Z$i dOdP�dQdR�dSdT�dUdV�dWdX�dYdZ�d[d\�d]d^�d_d`�dadb�dcdd�dedf�dgdh�didj�dkdl�dmdn�dodp�i dqdr�dsdt�dudv�dwdx�dydz�d{d|�d}d~�dd��d�d��d�d��d�d��d�d��d�d��d�d��d�d��d�d��d�d���i d�d��d�d��d�d��d�d��d�d��d�d��d�d��d�d��d�d��d�d��d�d��d�d��d�d��d�d��d�d��d�d��d�d���d�d�d�d�d�d�d�d�d�d�d�d�� �Z%e&e%�'� �D ]\Z(Z)e)e%ed�ed�ge(�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 @ � e Zd ZdZdS )r z Warning for deprecated things.N��__name__�
__module__� __qualname__�__doc__� r% r% �H/home/arjun/projects/env/lib/python3.10/site-packages/amqp/exceptions.pyr � r c @ r )r z Message was nacked by broker.Nr r% r% r% r& r r' r c @ s6 e Zd ZdZdZ d
dd�Zdd� Zedd � �ZdS ) r z#Base class for all AMQP exceptions.r Nc C sX || _ |p| j| _|| _|| _|pd| _|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& r2 " s
�zAMQPError.__init__c C s& | j rd�| �S | jpd�t| �j�S )Nz+{0.method}: ({0.reply_code}) {0.reply_text}z<{}: unknown error>)�method�formatr, �typer! �r3 r% r% r& �__str__. s
�zAMQPError.__str__c C s | j p| jS )N)r. r- r7 r% r% r& r4 5 s zAMQPError.method)NNNN) r! r" r# r$ r* r2 r8 �propertyr4 r% r% r% r& r s
� r c @ r )r zAMQP Connection Error.Nr r% r% r% r& r : r' r c @ r )r zAMQP Channel Error.Nr r% r% r% r& r > r' r c @ r )r z/Exception class for recoverable channel errors.Nr r% r% r% r& r B r' r c @ r )r
z1Exception class for irrecoverable channel errors.Nr r% r% r% r& r
F r' r
c @ r )r z2Exception class for recoverable connection errors.Nr r% r% r% r& r J r' r c @ r )r z4Exception class for irrecoverable connection errors.Nr r% r% r% r& r N r' r c @ r )�Blockedz"AMQP Connection Blocked Predicate.Nr r% r% r% r& r: R r' r: c @ r )r z"AMQP Consumer Cancelled Predicate.Nr r% r% r% r& r V r' r c @ � e Zd ZdZdZdS )r z AMQP Content Too Large Error.�7 N�r! r" r# r$ r* r% r% r% r& r Z � r c @ r; )r
zAMQP No Consumers Error.�9 Nr= r% r% r% r& r
` r> r
c @ r; )r z AMQP Connection Forced Error.�@ Nr= r% r% r% r& r f r> r c @ r; )r zAMQP Invalid Path Error.� Nr= r% r% r% r& r l r> r c @ r; )r zAMQP Access Refused Error.� Nr= r% r% r% r& r r r> r c @ r; )r zAMQP Not Found Error.� Nr= r% r% r% r& r x r> r c @ r; )r zAMQP Resource Locked Error.� Nr= r% r% r% r& r ~ r> r c @ r; )r z AMQP Precondition Failed Error.� Nr= r% r% r% r& r � r> r c @ r; )r zAMQP Frame Error.� Nr= r% r% r% r& r � r> r c @ r; )r zAMQP Frame Syntax Error.� Nr= r% r% r% r& r � r> r c @ r; )r zAMQP Invalid Command Error.� Nr= r% r% r% r& r � r> r c @ r; )r z AMQP Channel Not Open Error.� Nr= r% r% r% r& r � r> r c @ r; )r zAMQP Unexpected Frame.� Nr= r% r% r% r& r � r> r c @ r; )r zAMQP Resource Error.� Nr= r% r% r% r& r � r> r c @ r; )r zAMQP Not Allowed Error.� Nr= r% r% r% r& r � r> r c @ r; )r zAMQP Not Implemented Error.� Nr= r% r% r% r& r � r> r c @ r; )r zAMQP Internal Error.� Nr= r% r% r% r& r � r> r r< r? r@ rA rB rC rD rE rF rG rH rI rJ rK rL rM rN c C s6 z
t | ||| d�W S ty |||| d� Y S w )N)r+ )� ERROR_MAP�KeyError)r* �textr4 �defaultr% r% r& �error_for_code� s
�rS )�
rT zConnection.start)rT � zConnection.start_ok)rT � zConnection.secure)rT � zConnection.secure_ok)rT � zConnection.tune)rT � zConnection.tune_ok)rT �( zConnection.open)rT �) zConnection.open_ok)rT �2 zConnection.close)rT �3 zConnection.close_ok)rV rT z Channel.open)rV rU zChannel.open_ok)rV rV z Channel.flow)rV rW zChannel.flow_ok)rV rZ z
Channel.close)rV r[ zChannel.close_ok)rX rT zAccess.request)rX rU zAccess.request_ok)rZ rT zExchange.declare)rZ rU zExchange.declare_ok)rZ rV zExchange.delete)rZ rW zExchange.delete_ok)rZ rX z
Exchange.bind)rZ rY zExchange.bind_ok)rZ rZ zExchange.unbind)rZ r[ zExchange.unbind_ok)r\ rT z
Queue.declare)r\ rU zQueue.declare_ok)r\ rV z
Queue.bind)r\ rW z
Queue.bind_ok)r\ rX z Queue.purge)r\ rY zQueue.purge_ok)r\ rZ z Queue.delete)r\ r[ zQueue.delete_ok)r\ r\ z Queue.unbind)r\ r] zQueue.unbind_ok)�< rT z Basic.qos)r^ rU z Basic.qos_ok)r^ rV z
Basic.consume)r^ rW zBasic.consume_ok)r^ rX z Basic.cancel)r^ rY zBasic.cancel_ok)r^ rZ z
Basic.publish)r^ r\ z Basic.return)r^ r^ z
Basic.deliver)r^ �F z Basic.get)r^ �G z Basic.get_ok)r^ �H zBasic.get_empty)r^ �P z Basic.ack)r^ �Z z Basic.reject)r^ �d zBasic.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) )r^ �n )r^ �o )r^ �x )rc rT )rc rU )rc rV )rc rW )rc rX )rc rY )�U rT )rh rU z>Iz>HHN)*r$ �structr r �__all__� UserWarningr r1 r r r r r r
r r r: r r r
r r r r r r r r r r r r r r r rO rS r/ �list�items�
_method_id� _method_namer% r% r% r& �<module> st �������� �
� � �
������������� �
� � �
��������������� � � � � �!�"�#�$�%�&�'�(�)�*�+�,�-�.�/�0�1�2�3�4�B ��