o
    Df                     @   s  d Z ddlmZmZ dZG dd deZG dd deZG dd	 d	eZ	G d
d de	Z
G dd de	ZG dd deZG dd deZG dd de
ZG dd de
ZG dd deZG dd deZG dd deZG dd deZG dd deZG d d! d!eZG d"d# d#eZG d$d% d%eZG d&d' d'eZG d(d) d)eZG d*d+ d+eZG d,d- d-eZG d.d/ d/eZG d0d1 d1eZG d2d3 d3eZG d4d5 d5eZG d6d7 d7eZ G d8d9 d9eZ!G d: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#dMdN Z$i dOdPdQdRdSdTdUdVdWdXdYdZd[d\d]d^d_d`dadbdcdddedfdgdhdidjdkdldmdndodpi dqdrdsdtdudvdwdxdydzd{d|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dedge(R  d < qdS )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__ r%   r%   H/home/ubuntu/webapp/venv/lib/python3.10/site-packages/amqp/exceptions.pyr          r   c                   @   r   )r   zMessage was nacked by broker.Nr    r%   r%   r%   r&   r      r'   r   c                   @   s6   e Zd ZdZdZ		d
ddZdd Zedd	 ZdS )r   z#Base class for all AMQP exceptions.r   Nc                 C   sX   || _ |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__)selfr,   r-   r.   r+   r%   r%   r&   r2   "   s   

zAMQPError.__init__c                 C   s&   | j rd| S | jpdt| jS )Nz+{0.method}: ({0.reply_code}) {0.reply_text}z<{}: unknown error>)methodformatr,   typer!   r3   r%   r%   r&   __str__.   s
   

zAMQPError.__str__c                 C   s   | j p| jS )N)r.   r-   r7   r%   r%   r&   r4   5   s   zAMQPError.method)NNNN)	r!   r"   r#   r$   r*   r2   r8   propertyr4   r%   r%   r%   r&   r      s    
r   c                   @   r   )r   zAMQP Connection Error.Nr    r%   r%   r%   r&   r   :   r'   r   c                   @   r   )r   zAMQP Channel Error.Nr    r%   r%   r%   r&   r   >   r'   r   c                   @   r   )r	   z/Exception class for recoverable channel errors.Nr    r%   r%   r%   r&   r	   B   r'   r	   c                   @   r   )r
   z1Exception class for irrecoverable channel errors.Nr    r%   r%   r%   r&   r
   F   r'   r
   c                   @   r   )r   z2Exception class for recoverable connection errors.Nr    r%   r%   r%   r&   r   J   r'   r   c                   @   r   )r   z4Exception class for irrecoverable connection errors.Nr    r%   r%   r%   r&   r   N   r'   r   c                   @   r   )Blockedz"AMQP Connection Blocked Predicate.Nr    r%   r%   r%   r&   r:   R   r'   r:   c                   @   r   )r   z"AMQP Consumer Cancelled Predicate.Nr    r%   r%   r%   r&   r   V   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       r   c                   @   r;   )r   zAMQP No Consumers Error.9  Nr=   r%   r%   r%   r&   r   `   r>   r   c                   @   r;   )r   zAMQP Connection Forced Error.@  Nr=   r%   r%   r%   r&   r   f   r>   r   c                   @   r;   )r   zAMQP Invalid Path Error.  Nr=   r%   r%   r%   r&   r   l   r>   r   c                   @   r;   )r   zAMQP Access Refused Error.  Nr=   r%   r%   r%   r&   r   r   r>   r   c                   @   r;   )r   zAMQP Not Found Error.  Nr=   r%   r%   r%   r&   r   x   r>   r   c                   @   r;   )r   zAMQP Resource Locked Error.  Nr=   r%   r%   r%   r&   r   ~   r>   r   c                   @   r;   )r   zAMQP Precondition Failed Error.  Nr=   r%   r%   r%   r&   r      r>   r   c                   @   r;   )r   zAMQP Frame Error.  Nr=   r%   r%   r%   r&   r      r>   r   c                   @   r;   )r   zAMQP Frame Syntax Error.  Nr=   r%   r%   r%   r&   r      r>   r   c                   @   r;   )r   zAMQP Invalid Command Error.  Nr=   r%   r%   r%   r&   r      r>   r   c                   @   r;   )r   zAMQP Channel Not Open Error.  Nr=   r%   r%   r%   r&   r      r>   r   c                   @   r;   )r   zAMQP Unexpected Frame.  Nr=   r%   r%   r%   r&   r      r>   r   c                   @   r;   )r   zAMQP Resource Error.  Nr=   r%   r%   r%   r&   r      r>   r   c                   @   r;   )r   zAMQP Not Allowed Error.  Nr=   r%   r%   r%   r&   r      r>   r   c                   @   r;   )r   zAMQP Not Implemented Error.  Nr=   r%   r%   r%   r&   r      r>   r   c                   @   r;   )r   zAMQP Internal Error.  Nr=   r%   r%   r%   r&   r      r>   r   r<   r?   r@   rA   rB   rC   rD   rE   rF   rG   rH   rI   rJ   rK   rL   rM   rN   c                 C   s6   z
t |  ||| dW S  ty   |||| d Y S w )N)r+   )	ERROR_MAPKeyError)r*   textr4   defaultr%   r%   r&   error_for_code   s
   rS   )
   rT   zConnection.start)rT      zConnection.start_ok)rT      zConnection.secure)rT      zConnection.secure_ok)rT      zConnection.tune)rT      zConnection.tune_ok)rT   (   zConnection.open)rT   )   zConnection.open_ok)rT   2   zConnection.close)rT   3   zConnection.close_ok)rV   rT   zChannel.open)rV   rU   zChannel.open_ok)rV   rV   zChannel.flow)rV   rW   zChannel.flow_ok)rV   rZ   zChannel.close)rV   r[   zChannel.close_ok)rX   rT   zAccess.request)rX   rU   zAccess.request_ok)rZ   rT   zExchange.declare)rZ   rU   zExchange.declare_ok)rZ   rV   zExchange.delete)rZ   rW   zExchange.delete_ok)rZ   rX   zExchange.bind)rZ   rY   zExchange.bind_ok)rZ   rZ   zExchange.unbind)rZ   r[   zExchange.unbind_ok)r\   rT   zQueue.declare)r\   rU   zQueue.declare_ok)r\   rV   z
Queue.bind)r\   rW   zQueue.bind_ok)r\   rX   zQueue.purge)r\   rY   zQueue.purge_ok)r\   rZ   zQueue.delete)r\   r[   zQueue.delete_ok)r\   r\   zQueue.unbind)r\   r]   zQueue.unbind_ok)<   rT   z	Basic.qos)r^   rU   zBasic.qos_ok)r^   rV   zBasic.consume)r^   rW   zBasic.consume_ok)r^   rX   zBasic.cancel)r^   rY   zBasic.cancel_ok)r^   rZ   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   )rc   rT   )rc   rU   )rc   rV   )rc   rW   )rc   rX   )rc   rY   )U   rT   )rh   rU   z>Iz>HHN)*r$   structr   r   __all__UserWarningr   r1   r   r   r   r   r	   r
   r   r   r:   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   rO   rS   r/   listitems
_method_id_method_namer%   r%   r%   r&   <module>   st   	
	
 !"#$%&'()*+,-./01234B 