o
    Œ¨Êhþ  ã                   @   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€“d�d‚“dƒd„“d…d†“d‡dˆ“d‰dŠ“d‹dŒ“d�dŽ“d�d�“d‘d’“¥i d“d”“d•d–“d—d˜“d™dš“d›dœ“d�dž“dŸd “d¡d¢“d£d¤“d¥d¦“d§d¨“d©dª“d«d¬“d­d®“d¯d°“d±d²“d³d´“¥dµd¶d·d¸d¹dºd»d¼d½d¾d¿dÀœ¥Z%e&e% '¡ ƒD ]\Z(Z)e)e%edÁedÂge(¢R Ž ƒd < �qØdÃS )Ä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%   úA/var/www/html/env/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 ÿÿ