U
    W¨+dI  ã                   @   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©Z
method_sigÚargsÚcontentNFc                 C   s   t | ||ƒS )z'Create amqp method specification tuple.)r   r   © r   ú-/tmp/pip-unpacked-wheel-xhcdc304/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_IDZStartZStartOkÚSecureZSecureOkZTuneZTuneOkÚOpenÚOpenOkÚCloseÚCloseOkZBlockedZ	Unblockedr   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	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   ZFlowZFlowOkr   r    r   r   r   r   r!       s   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#   r$   r'   r(   ZPurgeZPurgeOkr%   r&   r)   r*   r   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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   ZQosZQosOkZConsumeZ	ConsumeOkZCancelZCancelOkZPublishZReturnZDeliverZGetZGetOkZGetEmptyZAckZNackZRejectZRecoverAsyncZRecoverZ	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   )r7   r   )r7   r   N)r   r   r   r   r   ÚSelectÚSelectOkr   r   r   r   r6   f   s   r6   c                   @   s,   e Zd ZdZdZdZdZdZdZdZ	dZ
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   r8   r9   ZCommitZCommitOkZRollbackZ
RollbackOkr   r   r   r   r:   o   s   r:   )NF)r   Úcollectionsr   r   r	   r
   r!   r"   r+   r,   r6   r:   r   r   r   r   Ú<module>   s   

	