File: //usr/local/lib/python3.9/site-packages/amqp/__pycache__/spec.cpython-39.pyc
a
X>hI � @ s� d Z ddlmZ edd�Zddd�ZG d d
� d
�ZG d d � d �ZG d
d� d�ZG dd� d�ZG dd� d�Z G dd� d�Z
G dd� d�Z dS )z
AMQP Spec.� )�
namedtuple�method_t�Z
method_sig�args�contentNFc C s t | ||�S )z'Create amqp method specification tuple.)r r � r �3/usr/local/lib/python3.9/site-packages/amqp/spec.py�method s r c @ sD e Zd ZdZdZdZdZdZdZdZ dZ
d Z d
Z d Z
d Zd
ZdZdS )�
ConnectionzAMQ Connection class.�
)r r )r � )r � )r � )r � )r � )r �( )r �) )r �2 )r �3 )r �< )r �= N)�__name__�
__module__� __qualname__�__doc__�CLASS_IDZStartZStartOk�SecureZSecureOkZTuneZTuneOk�Open�OpenOk�Close�CloseOkZBlockedZ Unblockedr r r r r
s r
c @ s, e Zd ZdZdZdZdZdZdZdZ dZ
d S )
�ChannelzAMQ Channel class.r
)r
r )r
r )r
r
)r
r )r
r )r
r N) r r r r r r r ZFlowZFlowOkr r r r r r r! s r! c @ s4 e Zd ZdZdZdZdZdZdZdZ dZ
d Z d
Z d S ) �ExchangezAMQ Exchange class.r )r r )r r )r r
)r r )r r )r r )r r )r r N)
r r r r r �Declare� DeclareOk�Delete�DeleteOk�Bind�BindOk�Unbind�UnbindOkr r r r r" - s r" c @ s< e Zd ZdZdZdZdZdZdZdZ dZ
d Z d
Z d Z
d Zd
S )�QueuezAMQ Queue class.r )r r )r r )r r
)r r )r r )r r )r r )r r )r r )r r N)r r r r r r# r$ r' r( ZPurgeZPurgeOkr% r& r) r* r r r r r+ < s r+ c @ s\ e Zd ZdZdZdZdZdZdZdZ dZ
d Z d
Z d Z
d Zd
ZdZdZdZdZdZdZdZdS )�BasiczAMQ Basic class.r )r r )r r )r r
)r r )r r )r r )r r )r r )r r )r �F )r �G )r �H )r �P )r �x )r �Z )r �d )r �n )r �o N)r r r r r ZQosZQosOkZConsumeZ ConsumeOkZCancelZCancelOkZPublish�ReturnZDeliverZGetZGetOkZGetEmptyZAckZNackZRejectZ RecoverAsyncZRecoverZ RecoverOkr r r r r, M s( r, c @ s e Zd ZdZdZdZdZdS )�ConfirmzAMQ Confirm class.�U )r8 r )r8 r N)r r r r r �Select�SelectOkr r r r r7 f s r7 c @ s, e Zd ZdZdZdZdZdZdZdZ dZ
d S )
�Txz
AMQ Tx class.r2 )r2 r )r2 r )r2 r
)r2 r )r2 r )r2 r N) r r r r r r9 r: ZCommitZCommitOkZRollbackZ
RollbackOkr r r r r; o s r; )NF) r � collectionsr r r r
r! r" r+ r, r7 r; r r r r �<module> s