
    h                        S r SSKJrJr  S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 " 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 " 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 " S. S/\5      r " S0 S1\5      r " S2 S3\5      r " S4 S5\5      r " S6 S7\5      r  " S8 S9\5      r! " S: S;\5      r"0 S<\_S=\_S>\_S?\_S@\_SA\_SB\_SC\_SD\_SE\_SF\_SG\_SH\_SI\_SJ\ _SK\!_SL\"_r#SM r$0 SNSO_SPSQ_SRSS_STSU_SVSW_SXSY_SZS[_S\S]_S^S__S`Sa_SbSc_SdSe_SfSg_ShSi_SjSk_SlSm_SnSo_0 SpSq_SrSs_StSu_SvSw_SxSy_SzS{_S|S}_S~S_SS_SS_SS_SS_SS_SS_SS_SS_SS_E0 SS_SS_SS_SS_SS_SS_SS_SS_SS_SS_SS_SS_SS_SS_SS_SS_SS_ESSSSSSSSSSSS.Er%\&" \%RO                  5       5       H  u  r(r)\)\%\" S\" S/\(Q76 5      S   '   M     g)zExceptions used by amqp.    )packunpack)	AMQPErrorConnectionErrorChannelErrorRecoverableConnectionErrorIrrecoverableConnectionErrorRecoverableChannelErrorIrrecoverableChannelErrorConsumerCancelledContentTooLargeNoConsumersConnectionForcedInvalidPathAccessRefusedNotFoundResourceLockedPreconditionFailed
FrameErrorFrameSyntaxErrorInvalidCommandChannelNotOpenUnexpectedFrameResourceError
NotAllowedAMQPNotImplementedErrorInternalErrorMessageNackedAMQPDeprecationWarningc                       \ rS rSrSrSrg)r      zWarning for deprecated things. N__name__
__module____qualname____firstlineno____doc____static_attributes__r"       7D:\TimeStamps\venv\Lib\site-packages\amqp/exceptions.pyr   r      s    (r*   r   c                       \ rS rSrSrSrg)r      zMessage was nacked by broker.r"   Nr#   r"   r*   r+   r   r      s    'r*   r   c                   @    \ rS rSrSrSr  S	S jrS r\S 5       r	Sr
g)
r      z#Base class for all AMQP exceptions.r   Nc                 $   Xl         U=(       d    U R                  U l        Xl        X l        U=(       d    SU l        U(       a,  U R
                  (       d  [        R                  US5      U l        [        R                  XXU R
                  5        g )N )
messagecode
reply_code
reply_text
method_sigmethod_nameMETHOD_NAME_MAPget	Exception__init__)selfr5   r6   r7   r4   s        r+   r;   AMQPError.__init__"   sj    !$1		$$&,"d...22:rBD4%43C3C	Er*   c                     U R                   (       a  SR                  U 5      $ U R                  =(       d$    SR                  [        U 5      R                  5      $ )Nz+{0.method}: ({0.reply_code}) {0.reply_text}z<{}: unknown error>)methodformatr5   typer$   r<   s    r+   __str__AMQPError.__str__.   sF    ;;@GGMM 
"7">">J#
 	
r*   c                 @    U R                   =(       d    U R                  $ )N)r7   r6   rB   s    r+   r?   AMQPError.method5   s    24??2r*   )r2   r7   r6   r4   r5   )NNNN)r$   r%   r&   r'   r(   r3   r;   rC   propertyr?   r)   r"   r*   r+   r   r      s/    -D37.2
E
 3 3r*   r   c                       \ rS rSrSrSrg)r   :   zAMQP Connection Error.r"   Nr#   r"   r*   r+   r   r   :   s     r*   r   c                       \ rS rSrSrSrg)r   >   zAMQP Channel Error.r"   Nr#   r"   r*   r+   r   r   >   s    r*   r   c                       \ rS rSrSrSrg)r
   B   z/Exception class for recoverable channel errors.r"   Nr#   r"   r*   r+   r
   r
   B   s    9r*   r
   c                       \ rS rSrSrSrg)r   F   z1Exception class for irrecoverable channel errors.r"   Nr#   r"   r*   r+   r   r   F   s    ;r*   r   c                       \ rS rSrSrSrg)r   J   z2Exception class for recoverable connection errors.r"   Nr#   r"   r*   r+   r   r   J   s    <r*   r   c                       \ rS rSrSrSrg)r	   N   z4Exception class for irrecoverable connection errors.r"   Nr#   r"   r*   r+   r	   r	   N   s    >r*   r	   c                       \ rS rSrSrSrg)BlockedR   z"AMQP Connection Blocked Predicate.r"   Nr#   r"   r*   r+   rU   rU   R       ,r*   rU   c                       \ rS rSrSrSrg)r   V   z"AMQP Consumer Cancelled Predicate.r"   Nr#   r"   r*   r+   r   r   V   rW   r*   r   c                       \ rS rSrSrSrSrg)r   Z   zAMQP Content Too Large Error.7  r"   Nr$   r%   r&   r'   r(   r3   r)   r"   r*   r+   r   r   Z   
    'Dr*   r   c                       \ rS rSrSrSrSrg)r   `   zAMQP No Consumers Error.9  r"   Nr]   r"   r*   r+   r   r   `   
    "Dr*   r   c                       \ rS rSrSrSrSrg)r   f   zAMQP Connection Forced Error.@  r"   Nr]   r"   r*   r+   r   r   f   r^   r*   r   c                       \ rS rSrSrSrSrg)r   l   zAMQP Invalid Path Error.  r"   Nr]   r"   r*   r+   r   r   l   rb   r*   r   c                       \ rS rSrSrSrSrg)r   r   zAMQP Access Refused Error.  r"   Nr]   r"   r*   r+   r   r   r   s
    $Dr*   r   c                       \ rS rSrSrSrSrg)r   x   zAMQP Not Found Error.  r"   Nr]   r"   r*   r+   r   r   x   s
    Dr*   r   c                       \ rS rSrSrSrSrg)r   ~   zAMQP Resource Locked Error.  r"   Nr]   r"   r*   r+   r   r   ~   
    %Dr*   r   c                       \ rS rSrSrSrSrg)r      zAMQP Precondition Failed Error.  r"   Nr]   r"   r*   r+   r   r      s
    )Dr*   r   c                       \ rS rSrSrSrSrg)r      zAMQP Frame Error.  r"   Nr]   r"   r*   r+   r   r      s
    Dr*   r   c                       \ rS rSrSrSrSrg)r      zAMQP Frame Syntax Error.  r"   Nr]   r"   r*   r+   r   r      rb   r*   r   c                       \ rS rSrSrSrSrg)r      zAMQP Invalid Command Error.  r"   Nr]   r"   r*   r+   r   r      rr   r*   r   c                       \ rS rSrSrSrSrg)r      zAMQP Channel Not Open Error.  r"   Nr]   r"   r*   r+   r   r      s
    &Dr*   r   c                       \ rS rSrSrSrSrg)r      zAMQP Unexpected Frame.  r"   Nr]   r"   r*   r+   r   r      s
     Dr*   r   c                       \ rS rSrSrSrSrg)r      zAMQP Resource Error.  r"   Nr]   r"   r*   r+   r   r      
    Dr*   r   c                       \ rS rSrSrSrSrg)r      zAMQP Not Allowed Error.  r"   Nr]   r"   r*   r+   r   r      s
    !Dr*   r   c                       \ rS rSrSrSrSrg)r      zAMQP Not Implemented Error.  r"   Nr]   r"   r*   r+   r   r      rr   r*   r   c                       \ rS rSrSrSrSrg)r      zAMQP Internal Error.  r"   Nr]   r"   r*   r+   r   r      r   r*   r   r\   ra   re   rh   rk   rn   rq   ru   rx   r{   r~   r   r   r   r   r   r   c                 N     [         U    " XU S9$ ! [         a
    U" XU S9s $ f = f)N)r4   )	ERROR_MAPKeyError)r3   textr?   defaults       r+   error_for_coder      s4    6t== 6t556s    $$)
   r   zConnection.start)r      zConnection.start_ok)r      zConnection.secure)r   r!   zConnection.secure_ok)r      zConnection.tune)r      zConnection.tune_ok)r   (   zConnection.open)r   )   zConnection.open_ok)r   2   zConnection.close)r   3   zConnection.close_ok)r   r   zChannel.open)r   r   zChannel.open_ok)r   r   zChannel.flow)r   r!   zChannel.flow_ok)r   r   zChannel.close)r   r   zChannel.close_ok)r   r   zAccess.request)r   r   zAccess.request_ok)r   r   zExchange.declare)r   r   zExchange.declare_ok)r   r   zExchange.delete)r   r!   zExchange.delete_ok)r   r   zExchange.bind)r   r   zExchange.bind_ok)r   r   zExchange.unbind)r   r   zExchange.unbind_ok)r   r   zQueue.declare)r   r   zQueue.declare_ok)r   r   z
Queue.bind)r   r!   zQueue.bind_ok)r   r   zQueue.purge)r   r   zQueue.purge_ok)r   r   zQueue.delete)r   r   zQueue.delete_ok)r   r   zQueue.unbind)r   r   zQueue.unbind_ok)<   r   z	Basic.qos)r   r   zBasic.qos_ok)r   r   zBasic.consume)r   r!   zBasic.consume_ok)r   r   zBasic.cancel)r   r   zBasic.cancel_ok)r   r   zBasic.publish)r   r   zBasic.return)r   r   zBasic.deliver)r   rO   z	Basic.get)r   G   zBasic.get_ok)r   H   zBasic.get_empty)r   P   z	Basic.ack)r   r[   zBasic.reject)r   d   zBasic.recover_asynczBasic.recoverzBasic.recover_okz
Basic.nackz	Tx.selectzTx.select_okz	Tx.commitzTx.commit_okzTx.rollbackzTx.rollback_okzConfirm.selectzConfirm.select_ok))r   n   )r   o   )r   rm   )r[   r   )r[   r   )r[   r   )r[   r!   )r[   r   )r[   r   )U   r   )r   r   z>Iz>HHN)*r(   structr   r   __all__UserWarningr   r:   r   r   r   r   r
   r   r   r	   rU   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r8   listitems
_method_id_method_namer"   r*   r+   <module>r      si     )[ )(I (3	 3:!i !9 :l :< <= =?? ?-( --2 -- ) 1 . - ( , 2 - 3 1 1 2 . - : 0  	 	
    	  	       	 !" #	*6? ?#? !? $	?
 ? "? ? "?  ? #? n? ? n? ? o?   !?" #?$ !%?&  '?( #)?* +?, "-?. o/?0  1?2 3?4 "5?6 o7?8  9?: l;?< o=?> m??@ A?B nC?D E?F nG?H I?J kK?L nM?N oO?P  Q?R nS?T U?V oW?X nY?Z o[?\ k]?^ n_?` a?b kc?d ne?f $g?h !!}?D !%_%:%:%< =J F4e!9j!9:1=> !>r*   