
    辙h                        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%jO                               D ]  \  Z(Z)e)e% ed edge(       d   <    y)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y)r   zWarning for deprecated things.N__name__
__module____qualname____doc__     K/var/www/Befach/backend/env/lib/python3.12/site-packages/amqp/exceptions.pyr   r      s    (r'   r   c                       e Zd ZdZy)r   zMessage was nacked by broker.Nr!   r&   r'   r(   r   r      s    'r'   r   c                   6    e Zd ZdZdZ	 	 ddZd Zed        Zy)r   z#Base class for all AMQP exceptions.r   Nc                    || _         |xs | j                  | _        || _        || _        |xs d| _        |r'| j
                  st        j                  |d      | _        t        j                  | |||| j
                         y )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__"   st    !$1		$$&,"d...22:rBD4%z43C3C	Er'   c                     | j                   rdj                  |       S | j                  xs$ dj                  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__.   sF    ;;@GGMM 
"7">">J#
 	
r'   c                 6    | j                   xs | 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      s/    -D37.2
E
 3 3r'   r   c                       e Zd ZdZy)r   zAMQP Connection Error.Nr!   r&   r'   r(   r   r   :   s     r'   r   c                       e Zd ZdZy)r   zAMQP Channel Error.Nr!   r&   r'   r(   r   r   >   s    r'   r   c                       e Zd ZdZy)r
   z/Exception class for recoverable channel errors.Nr!   r&   r'   r(   r
   r
   B   s    9r'   r
   c                       e Zd ZdZy)r   z1Exception class for irrecoverable channel errors.Nr!   r&   r'   r(   r   r   F   s    ;r'   r   c                       e Zd ZdZy)r   z2Exception class for recoverable connection errors.Nr!   r&   r'   r(   r   r   J   s    <r'   r   c                       e Zd ZdZy)r	   z4Exception class for irrecoverable connection errors.Nr!   r&   r'   r(   r	   r	   N   s    >r'   r	   c                       e Zd ZdZy)Blockedz"AMQP Connection Blocked Predicate.Nr!   r&   r'   r(   rG   rG   R       ,r'   rG   c                       e Zd ZdZy)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y)r   zAMQP Content Too Large Error.7  Nr"   r#   r$   r%   r.   r&   r'   r(   r   r   Z   
    'Dr'   r   c                       e Zd ZdZdZy)r   zAMQP No Consumers Error.9  NrL   r&   r'   r(   r   r   `   
    "Dr'   r   c                       e Zd ZdZdZy)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y)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y)r   zAMQP Access Refused Error.  NrL   r&   r'   r(   r   r   r   s
    $Dr'   r   c                       e Zd ZdZdZy)r   zAMQP Not Found Error.  NrL   r&   r'   r(   r   r   x   s
    Dr'   r   c                       e Zd ZdZdZy)r   zAMQP Resource Locked Error.  NrL   r&   r'   r(   r   r   ~   
    %Dr'   r   c                       e Zd ZdZdZy)r   zAMQP Precondition Failed Error.  NrL   r&   r'   r(   r   r      s
    )Dr'   r   c                       e Zd ZdZdZy)r   zAMQP Frame Error.  NrL   r&   r'   r(   r   r      s
    Dr'   r   c                       e Zd ZdZdZy)r   zAMQP Frame Syntax Error.  NrL   r&   r'   r(   r   r      rP   r'   r   c                       e Zd ZdZdZy)r   zAMQP Invalid Command Error.  NrL   r&   r'   r(   r   r      r[   r'   r   c                       e Zd ZdZdZy)r   zAMQP Channel Not Open Error.  NrL   r&   r'   r(   r   r      s
    &Dr'   r   c                       e Zd ZdZdZy)r   zAMQP Unexpected Frame.  NrL   r&   r'   r(   r   r      s
     Dr'   r   c                       e Zd ZdZdZy)r   zAMQP Resource Error.  NrL   r&   r'   r(   r   r      
    Dr'   r   c                       e Zd ZdZdZy)r   zAMQP Not Allowed Error.  NrL   r&   r'   r(   r   r      s
    !Dr'   r   c                       e Zd ZdZdZy)r   zAMQP Not Implemented Error.  NrL   r&   r'   r(   r   r      r[   r'   r   c                       e Zd ZdZdZy)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                 Z    	 t        |    |||       S # t        $ r  ||||       cY S w xY w)N)r/   )	ERROR_MAPKeyError)r.   textr9   defaults       r(   error_for_coderv      s8    6tV== 6tV556s    **)
   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      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'   