
    辙hI                         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y)z
AMQP Spec.    )
namedtuplemethod_t
method_sigargscontentNc                     t        | ||      S )z'Create amqp method specification tuple.)r   r   s      E/var/www/Befach/backend/env/lib/python3.12/site-packages/amqp/spec.pymethodr      s    Jg..    c                   D    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y)
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      sF    HEGFHDFDFEGGIr   r   c                   ,    e Zd ZdZdZdZdZdZdZdZ	dZ
y	)
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.       s(    HDFDFEGr   r.   c                   4    e Zd ZdZdZdZdZdZdZdZ	dZ
d	Zd
Zy)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   -   s2    HGIFHDFFHr   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y)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<   <   s<    HGIDFEGFHFHr   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y)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   sd    H
CEGIFHGFG
CEH
CDFLGIr   r@   c                       e Zd ZdZdZdZdZy)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Hr   r]   c                   ,    e Zd ZdZdZdZdZdZdZdZ	dZ
y	)
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   s(    HFHFHHJr   rb   )NF)r   collectionsr   r   r   r   r.   r2   r<   r@   r]   rb   r,   r   r
   <module>rh      sc     "j"CD/
 &
 
  " 2 
 
r   