
    YfI                         d Z ddlmZ  edd          ZddZ G d d	          Z G d
 d          Z G d d          Z G d d          Z G d d          Z	 G d d          Z
 G d d          ZdS )z
AMQP Spec.    )
namedtuplemethod_t
method_sigargscontentNFc                 $    t          | ||          S )z'Create amqp method specification tuple.)r   r   s      ;/var/www/html/env/lib/python3.11/site-packages/amqp/spec.pymethodr      s    Jg...    c                   F    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	Unblocked r   r
   r   r      sU        HEGFHDFDFEGGIIIr   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.       s7        HDFDFEGGGr   r.   c                   6    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
   r2   r2   -   sA        HGIFHDFFHHHr   r2   c                   >    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   r3   r4   r7   r8   PurgePurgeOkr5   r6   r9   r:   r,   r   r
   r<   r<   <   sK        HGIDFEGFHFHHHr   r<   c                   ^    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   ss        H
CEGIFHGFG
CEH
CDFLGIIIr   r@   c                       e Zd ZdZdZdZdZdS )ConfirmzAMQ Confirm class.U   )r^   r   )r^   r   N)r   r   r   r   r   SelectSelectOkr,   r   r
   r]   r]   f   s#        HFHHHr   r]   c                   .    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.rF   )rF   r   )rF   r   )rF   r   )rF   r   )rF   r   )rF   r   N)r   r   r   r   r   r_   r`   CommitCommitOkRollback
RollbackOkr,   r   r
   rb   rb   o   s7        HFHFHHJJJr   rb   )NF)r   collectionsr   r   r   r   r.   r2   r<   r@   r]   rb   r,   r   r
   <module>rh      se     " " " " " ":j"CDD/ / / /
       &
 
 
 
 
 
 
 
              "       2       
 
 
 
 
 
 
 
 
 
r   