
    hI                         S r SSKJr  \" SS5      rSS jr " S S5      r " S	 S
5      r " S S5      r " S S5      r " S S5      r	 " S S5      r
 " S S5      rg)z
AMQP Spec.    )
namedtuplemethod_t
method_sigargscontentNc                     [        XU5      $ )z'Create amqp method specification tuple.)r   r   s      1D:\TimeStamps\venv\Lib\site-packages\amqp/spec.pymethodr      s    Jg..    c                   L    \ rS rSrSrSrSrSrSrSr	Sr
S	rS
rSrSrSrSrSrSrg)
Connection   zAMQ Connection class.
   )r   r   )r      )r      )r      )r      )r      )r   (   )r   )   )r   2   )r   3   )r   <   )r   =    N)__name__
__module____qualname____firstlineno____doc__CLASS_IDStartStartOkSecureSecureOkTuneTuneOkOpenOpenOkCloseCloseOkBlocked	Unblocked__static_attributes__r   r   r
   r   r      sF    HEGFHDFDFEGGIr   r   c                   4    \ rS rSrSrSrSrSrSrSr	Sr
S	rS
rg)Channel    zAMQ Channel class.r   )r   r   )r   r   )r   r   )r   r   )r   r   )r   r   r   N)r   r   r   r    r!   r"   r)   r*   FlowFlowOkr+   r,   r/   r   r   r
   r1   r1       s(    HDFDFEGr   r1   c                   <    \ rS rSrSrSrSrSrSrSr	Sr
S	rS
rSrSrg)Exchange-   zAMQ Exchange class.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"   Declare	DeclareOkDeleteDeleteOkBindBindOkUnbindUnbindOkr/   r   r   r
   r6   r6   -   s2    HGIFHDFFHr   r6   c                   D    \ rS rSrSrSrSrSrSrSr	Sr
S	rS
rSrSrSrSrg)Queuer   zAMQ Queue class.r   )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"   r8   r9   r<   r=   PurgePurgeOkr:   r;   r>   r?   r/   r   r   r
   rA   rA   <   s<    HGIDFEGFHFHr   rA   c                   d    \ rS rSrSrSrSrSrSrSr	Sr
S	rS
rSrSrSrSrSrSrSrSrSrSrSrSrg)BasicM   z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   r   N)r   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
   rE   rE   M   sd    H
CEGIFHGFG
CEH
CDFLGIr   rE   c                   $    \ rS rSrSrSrSrSrSrg)Confirmf   zAMQ Confirm class.U   )re   r   )re   r   r   N)	r   r   r   r    r!   r"   SelectSelectOkr/   r   r   r
   rc   rc   f   s    HFHr   rc   c                   4    \ rS rSrSrSrSrSrSrSr	Sr
S	rS
rg)TxrO   zAMQ Tx class.rL   )rL   r   )rL   r   )rL   r   )rL   r   )rL   r   )rL   r   r   N)r   r   r   r    r!   r"   rf   rg   CommitCommitOkRollback
RollbackOkr/   r   r   r
   ri   ri   o   s(    HFHFHHJr   ri   )NF)r!   collectionsr   r   r   r   r1   r6   rA   rE   rc   ri   r   r   r
   <module>ro      sc     "j"CD/
 &
 
  " 2 
 
r   