o
    hI                     @   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   K/var/www/html/optinet_system/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    

	