
    Yf                     v   d Z ddlmZmZ dZ G d de          Z G d de          Z G d d	e          Z	 G d
 de	          Z
 G d de	          Z G d de          Z G d de          Z G d de
          Z G d de
          Z G d de          Z G d de          Z G d de          Z G d de          Z G d de          Z G d  d!e          Z G d" d#e          Z G d$ d%e          Z G d& d'e          Z G d( d)e          Z G d* d+e          Z G d, d-e          Z G d. d/e          Z G d0 d1e          Z G d2 d3e          Z G d4 d5e          Z G d6 d7e          Z  G d8 d9e          Z! G d: d;e          Z"i d<ed=ed>ed?ed@edAedBedCedDedEedFedGedHedIedJe dKe!dLe"Z#dM Z$i dNdOdPdQdRdSdTdUdVdWdXdYdZd[d\d]d^d_d`dadbdcdddedfdgdhdidjdkdldmdndoi dpdqdrdsdtdudvdwdxdydzd{d|d}d~dddddddddddddddddddi ddddddddddddddddddddddddddddddddddddddddddddddZ% e&e%'                                          D ]!\  Z(Z)e)e% ed edge(R            d         <   "dS )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                       e Zd ZdZdS )r   zWarning for deprecated things.N__name__
__module____qualname____doc__     A/var/www/html/env/lib/python3.11/site-packages/amqp/exceptions.pyr   r      s        ((((r'   r   c                       e Zd ZdZdS )r   zMessage was nacked by broker.Nr!   r&   r'   r(   r   r      s        ''''r'   r   c                   >    e Zd ZdZdZ	 	 ddZd Zed             ZdS )r   z#Base class for all AMQP exceptions.r   Nc                     || _         |p| j        | _        || _        || _        |pd| _        |r'| j        s t                              |d          | _        t          	                    | |||| j                   d S )N )
messagecode
reply_code
reply_text
method_sigmethod_nameMETHOD_NAME_MAPget	Exception__init__)selfr0   r1   r2   r/   s        r(   r6   zAMQPError.__init__"   s    !$1	$$&," 	Cd. 	C.22:rBBD4%z43C	E 	E 	E 	E 	Er'   c                     | j         rd                    |           S | j        p&d                    t          |           j                  S )Nz+{0.method}: ({0.reply_code}) {0.reply_text}z<{}: unknown error>)methodformatr0   typer"   r7   s    r(   __str__zAMQPError.__str__.   sO    ; 	N@GGMMM 
"7">">JJ#
 #
 	
r'   c                     | j         p| j        S )N)r2   r1   r<   s    r(   r9   zAMQPError.method5   s    24?2r'   )NNNN)	r"   r#   r$   r%   r.   r6   r=   propertyr9   r&   r'   r(   r   r      sg        --D37.2
E 
E 
E 
E
 
 
 3 3 X3 3 3r'   r   c                       e Zd ZdZdS )r   zAMQP Connection Error.Nr!   r&   r'   r(   r   r   :   s            r'   r   c                       e Zd ZdZdS )r   zAMQP Channel Error.Nr!   r&   r'   r(   r   r   >   s        r'   r   c                       e Zd ZdZdS )r
   z/Exception class for recoverable channel errors.Nr!   r&   r'   r(   r
   r
   B   s        9999r'   r
   c                       e Zd ZdZdS )r   z1Exception class for irrecoverable channel errors.Nr!   r&   r'   r(   r   r   F   s        ;;;;r'   r   c                       e Zd ZdZdS )r   z2Exception class for recoverable connection errors.Nr!   r&   r'   r(   r   r   J   s        <<<<r'   r   c                       e Zd ZdZdS )r	   z4Exception class for irrecoverable connection errors.Nr!   r&   r'   r(   r	   r	   N   s        >>>>r'   r	   c                       e Zd ZdZdS )Blockedz"AMQP Connection Blocked Predicate.Nr!   r&   r'   r(   rG   rG   R           ,,,,r'   rG   c                       e Zd ZdZdS )r   z"AMQP Consumer Cancelled Predicate.Nr!   r&   r'   r(   r   r   V   rH   r'   r   c                       e Zd ZdZdZdS )r   zAMQP Content Too Large Error.7  Nr"   r#   r$   r%   r.   r&   r'   r(   r   r   Z           ''DDDr'   r   c                       e Zd ZdZdZdS )r   zAMQP No Consumers Error.9  NrL   r&   r'   r(   r   r   `           ""DDDr'   r   c                       e Zd ZdZdZdS )r   zAMQP Connection Forced Error.@  NrL   r&   r'   r(   r   r   f   rM   r'   r   c                       e Zd ZdZdZdS )r   zAMQP Invalid Path Error.  NrL   r&   r'   r(   r   r   l   rP   r'   r   c                       e Zd ZdZdZdS )r   zAMQP Access Refused Error.  NrL   r&   r'   r(   r   r   r   s        $$DDDr'   r   c                       e Zd ZdZdZdS )r   zAMQP Not Found Error.  NrL   r&   r'   r(   r   r   x   s        DDDr'   r   c                       e Zd ZdZdZdS )r   zAMQP Resource Locked Error.  NrL   r&   r'   r(   r   r   ~           %%DDDr'   r   c                       e Zd ZdZdZdS )r   zAMQP Precondition Failed Error.  NrL   r&   r'   r(   r   r      s        ))DDDr'   r   c                       e Zd ZdZdZdS )r   zAMQP Frame Error.  NrL   r&   r'   r(   r   r      s        DDDr'   r   c                       e Zd ZdZdZdS )r   zAMQP Frame Syntax Error.  NrL   r&   r'   r(   r   r      rP   r'   r   c                       e Zd ZdZdZdS )r   zAMQP Invalid Command Error.  NrL   r&   r'   r(   r   r      r[   r'   r   c                       e Zd ZdZdZdS )r   zAMQP Channel Not Open Error.  NrL   r&   r'   r(   r   r      s        &&DDDr'   r   c                       e Zd ZdZdZdS )r   zAMQP Unexpected Frame.  NrL   r&   r'   r(   r   r      s          DDDr'   r   c                       e Zd ZdZdZdS )r   zAMQP Resource Error.  NrL   r&   r'   r(   r   r              DDDr'   r   c                       e Zd ZdZdZdS )r   zAMQP Not Allowed Error.  NrL   r&   r'   r(   r   r      s        !!DDDr'   r   c                       e Zd ZdZdZdS )r   zAMQP Not Implemented Error.  NrL   r&   r'   r(   r   r      r[   r'   r   c                       e Zd ZdZdZdS )r   zAMQP Internal Error.  NrL   r&   r'   r(   r   r      rj   r'   r   rK   rO   rR   rT   rV   rX   rZ   r]   r_   ra   rc   re   rg   ri   rl   rn   rp   c                 p    	 t          |          |||           S # t          $ r  ||||           cY S w xY w)N)r/   )	ERROR_MAPKeyError)r.   textr9   defaults       r(   error_for_coderv      sX    6tV==== 6 6 6wtV5555556s    55)
   rw   zConnection.start)rw      zConnection.start_ok)rw      zConnection.secure)rw      zConnection.secure_ok)rw      zConnection.tune)rw      zConnection.tune_ok)rw   (   zConnection.open)rw   )   zConnection.open_ok)rw   2   zConnection.close)rw   3   zConnection.close_ok)ry   rw   zChannel.open)ry   rx   zChannel.open_ok)ry   ry   zChannel.flow)ry   rz   zChannel.flow_ok)ry   r}   zChannel.close)ry   r~   zChannel.close_ok)r{   rw   zAccess.request)r{   rx   zAccess.request_ok)r}   rw   zExchange.declare)r}   rx   zExchange.declare_ok)r}   ry   zExchange.delete)r}   rz   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   rw   zQueue.declare)r   rx   zQueue.declare_ok)r   ry   z
Queue.bind)r   rz   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)<   rw   z	Basic.qos)r   rx   zBasic.qos_ok)r   ry   zBasic.consume)r   rz   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   F   z	Basic.get)r   G   zBasic.get_ok)r   H   zBasic.get_empty)r   P   z	Basic.ack)r   Z   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   x   )r   rw   )r   rx   )r   ry   )r   rz   )r   r{   )r   r|   )U   rw   )r   rx   z>Iz>HHN)*r%   structr   r   __all__UserWarningr   r5   r   r   r   r   r
   r   r   r	   rG   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   rr   rv   r3   listitems
_method_id_method_namer&   r'   r(   <module>r      s	             ) ) ) ) )[ ) ) )( ( ( ( (I ( ( (3 3 3 3 3	 3 3 3:! ! ! ! !i ! ! !    9   : : : : :l : : :< < < < < < < <= = = = = = = =? ? ? ? ?? ? ? ?- - - - -( - - -- - - - -2 - - -    -       )       1       .       -       (       ,       2       -       3       1       1       2       .       -       :       0    	 	
    	  	       	 !" #	*6 6 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 FF4e!9j!9!9!9::1=>> r'   