o
    vvXj‚  ã                   @   sš   d Z ddlmZmZ ddlmZ eddƒZddd	„ZG d
d„ dƒZG dd„ dƒZ	G dd„ dƒZ
G dd„ dƒZG dd„ dƒZG dd„ dƒZG dd„ dƒZdS )z
AMQP Spec.é    )Úabsolute_importÚunicode_literals)Ú
namedtupleÚmethod_t©Ú
method_sigÚargsÚcontentNFc                 C   s   t | ||ƒS )z'Create amqp method specification tuple.)r   r   © r
   úF/var/www/html/myproject/venv/lib/python3.10/site-packages/amqp/spec.pyÚmethod	   s   r   c                   @   sD   e Zd ZdZdZdZdZdZdZdZ	dZ
d	Zd
ZdZdZdZdZdS )Ú
ConnectionzAMQ Connection class.é
   )r   r   )r   é   )r   é   )r   é   )r   é   )r   é   )r   é(   )r   é)   )r   é2   )r   é3   )r   é<   )r   é=   N)Ú__name__Ú
__module__Ú__qualname__Ú__doc__ÚCLASS_IDÚStartÚStartOkÚSecureÚSecureOkÚTuneÚTuneOkÚOpenÚOpenOkÚCloseÚCloseOkÚBlockedÚ	Unblockedr
   r
   r
   r   r      s    r   c                   @   ó,   e Zd ZdZdZdZdZdZdZdZ	dZ
d	S )
ÚChannelzAMQ Channel class.r   )r   r   )r   r   )r   r   )r   r   )r   r   )r   r   N)r   r   r   r   r   r%   r&   ÚFlowÚFlowOkr'   r(   r
   r
   r
   r   r,   !   ó    r,   c                   @   s4   e Zd ZdZdZdZdZdZdZdZ	dZ
d	Zd
ZdS )ÚExchangezAMQ 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   r0   .   s    r0   c                   @   s<   e Zd ZdZdZdZdZdZdZdZ	dZ
d	Zd
ZdZdZdS )ÚQueuezAMQ 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   r1   r2   r5   r6   ÚPurgeÚPurgeOkr3   r4   r7   r8   r
   r
   r
   r   r9   =   s    r9   c                   @   s\   e Zd ZdZdZdZdZdZdZdZ	dZ
d	Zd
ZdZdZdZdZdZdZdZdZdZdZdS )ÚBasiczAMQ 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   ÚQosÚQosOkÚConsumeÚ	ConsumeOkÚCancelÚCancelOkÚPublishÚReturnÚDeliverÚGetÚGetOkÚGetEmptyÚAckÚNackÚRejectÚRecoverAsyncÚRecoverÚ	RecoverOkr
   r
   r
   r   r<   N   s*    r<   c                   @   s   e Zd ZdZdZdZdZdS )ÚConfirmzAMQ Confirm class.éU   )rY   r   )rY   r   N)r   r   r   r   r   ÚSelectÚSelectOkr
   r
   r
   r   rX   g   s
    rX   c                   @   r+   )
ÚTxzAMQ Tx class.rB   )rB   r   )rB   r   )rB   r   )rB   r   )rB   r   )rB   r   N)r   r   r   r   r   rZ   r[   ÚCommitÚCommitOkÚRollbackÚ
RollbackOkr
   r
   r
   r   r\   p   r/   r\   )NF)r   Ú
__future__r   r   Úcollectionsr   r   r   r   r,   r0   r9   r<   rX   r\   r
   r
   r
   r   Ú<module>   s    

	