o
    £D®fI  ã                   @   sŠ   d 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.é    )Ú
namedtupleÚmethod_t©Ú
method_sigÚargsÚcontentNFc                 C   s   t | ||ƒS )z'Create amqp method specification tuple.)r   r   © r   úB/home/ubuntu/webapp/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	   r.   -   s    r.   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   r/   r0   r3   r4   ÚPurgeÚPurgeOkr1   r2   r5   r6   r   r   r   r	   r7   <   s    r7   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:   M   s*    r:   c                   @   s   e Zd ZdZdZdZdZdS )ÚConfirmzAMQ Confirm class.éU   )rW   r   )rW   r   N)r   r   r   r   r   ÚSelectÚSelectOkr   r   r   r	   rV   f   s
    rV   c                   @   r)   )
ÚTxzAMQ Tx class.r@   )r@   r   )r@   r   )r@   r   )r@   r   )r@   r   )r@   r   N)r   r   r   r   r   rX   rY   ÚCommitÚCommitOkÚRollbackÚ
RollbackOkr   r   r   r	   rZ   o   r-   rZ   )NF)r   Úcollectionsr   r   r
   r   r*   r.   r7   r:   rV   rZ   r   r   r   r	   Ú<module>   s    

	