o
    vvXj…  ã                   @   s  d Z ddlmZmZ ddlmZ ddlmZmZ g d¢Z	G dd„ de
ƒZG d	d
„ d
eƒZe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/d0„ d0eƒZ G d1d2„ d2eƒZ!G d3d4„ d4eƒZ"G d5d6„ d6eƒZ#G d7d8„ d8eƒZ$G d9d:„ d:eƒZ%G d;d<„ d<eƒZ&G d=d>„ d>eƒZ'i d?e“d@e“dAe“dBe“dCe“dDe“dEe“dFe“dGe“dHe “dIe!“dJe"“dKe#“dLe$“dMe%“dNe&“dOe'“Z(dPdQ„ Z)i dRdS“dTdU“dVdW“dXdY“dZd[“d\d]“d^d_“d`da“dbdc“ddde“dfdg“dhdi“djdk“dldm“dndo“dpdq“drds“i dtdu“dvdw“dxdy“dzd{“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•“¥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.é    )Úabsolute_importÚunicode_literalsé   )Úpython_2_unicode_compatible)Ú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)   úL/var/www/html/myproject/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__)Úselfr0   r1   r2   r/   r)   r)   r*   r6   %   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Úformatr0   Útyper%   ©r7   r)   r)   r*   Ú__str__1   s
   

ÿzAMQPError.__str__c                 C   s   | j p| jS )N)r2   r1   r;   r)   r)   r*   r8   8   s   zAMQPError.method)NNNN)	r%   r&   r'   r(   r.   r6   r<   Úpropertyr8   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
   A   r+   r
   c                   @   r#   )r   z/Exception class for recoverable channel errors.Nr$   r)   r)   r)   r*   r   E   r+   r   c                   @   r#   )r   z1Exception class for irrecoverable channel errors.Nr$   r)   r)   r)   r*   r   I   r+   r   c                   @   r#   )r   z2Exception class for recoverable connection errors.Nr$   r)   r)   r)   r*   r   M   r+   r   c                   @   r#   )r   z4Exception class for irrecoverable connection errors.Nr$   r)   r)   r)   r*   r   Q   r+   r   c                   @   r#   )ÚBlockedz"AMQP Connection Blocked Predicate.Nr$   r)   r)   r)   r*   r>   U   r+   r>   c                   @   r#   )r   z"AMQP Consumer Cancelled Predicate.Nr$   r)   r)   r)   r*   r   Y   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   ]   ó    r   c                   @   r?   )r   zAMQP No Consumers Error.é9  NrA   r)   r)   r)   r*   r   c   rB   r   c                   @   r?   )r   zAMQP Connection Forced Error.é@  NrA   r)   r)   r)   r*   r   i   rB   r   c                   @   r?   )r   zAMQP Invalid Path Error.é’  NrA   r)   r)   r)   r*   r   o   rB   r   c                   @   r?   )r   zAMQP Access Refused Error.é“  NrA   r)   r)   r)   r*   r   u   rB   r   c                   @   r?   )r   zAMQP Not Found Error.é”  NrA   r)   r)   r)   r*   r   {   rB   r   c                   @   r?   )r   zAMQP Resource Locked Error.é•  NrA   r)   r)   r)   r*   r   �   rB   r   c                   @   r?   )r   zAMQP Precondition Failed Error.é–  NrA   r)   r)   r)   r*   r   ‡   rB   r   c                   @   r?   )r   zAMQP Frame Error.éõ  NrA   r)   r)   r)   r*   r   �   rB   r   c                   @   r?   )r   zAMQP Frame Syntax Error.éö  NrA   r)   r)   r)   r*   r   “   rB   r   c                   @   r?   )r   zAMQP Invalid Command Error.é÷  NrA   r)   r)   r)   r*   r   ™   rB   r   c                   @   r?   )r   zAMQP Channel Not Open Error.éø  NrA   r)   r)   r)   r*   r   Ÿ   rB   r   c                   @   r?   )r   zAMQP Unexpected Frame.éù  NrA   r)   r)   r)   r*   r   ¥   rB   r   c                   @   r?   )r   zAMQP Resource Error.éú  NrA   r)   r)   r)   r*   r   «   rB   r   c                   @   r?   )r   zAMQP Not Allowed Error.é  NrA   r)   r)   r)   r*   r   ±   rB   r   c                   @   r?   )r   zAMQP Not Implemented Error.é  NrA   r)   r)   r)   r*   r   ·   rB   r   c                   @   r?   )r    zAMQP Internal Error.é  NrA   r)   r)   r)   r*   r    ½   rB   r    r@   rC   rD   rE   rF   rG   rH   rI   rJ   rK   rL   rM   rN   rO   rP   rQ   rR   c                 C   s6   z
t |  ||| d�W S  ty   |||| d� Y S w )N)r/   )Ú	ERROR_MAPÚKeyError)r.   Útextr8   Údefaultr)   r)   r*   Úerror_for_codeØ   s
   ÿrW   )é
   rX   zConnection.start)rX   é   zConnection.start_ok)rX   é   zConnection.secure)rX   é   zConnection.secure_ok)rX   é   zConnection.tune)rX   é   zConnection.tune_ok)rX   é(   zConnection.open)rX   é)   zConnection.open_ok)rX   é2   zConnection.close)rX   é3   zConnection.close_ok)rZ   rX   zChannel.open)rZ   rY   zChannel.open_ok)rZ   rZ   zChannel.flow)rZ   r[   zChannel.flow_ok)rZ   r^   zChannel.close)rZ   r_   zChannel.close_ok)r\   rX   zAccess.request)r\   rY   zAccess.request_ok)r^   rX   zExchange.declare)r^   rY   zExchange.declare_ok)r^   rZ   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`   rX   zQueue.declare)r`   rY   zQueue.declare_ok)r`   rZ   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`   ra   zQueue.unbind_ok)é<   rX   z	Basic.qos)rb   rY   zBasic.qos_ok)rb   rZ   zBasic.consume)rb   r[   zBasic.consume_ok)rb   r\   zBasic.cancel)rb   r]   zBasic.cancel_ok)rb   r^   zBasic.publish)rb   r`   zBasic.return)rb   rb   zBasic.deliver)rb   éF   z	Basic.get)rb   éG   zBasic.get_ok)rb   éH   zBasic.get_empty)rb   éP   z	Basic.ack)rb   éZ   zBasic.reject)rb   é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))rb   én   )rb   éo   )rb   éx   )rg   rX   )rg   rY   )rg   rZ   )rg   r[   )rg   r\   )rg   r]   )éU   rX   )rl   rY   z>Iz>HHN)/r(   Ú
__future__r   r   Úfiver   Úplatformr   r   Ú__all__ÚUserWarningr"   r5   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    rS   rW   r3   ÚlistÚitemsÚ
_method_idÚ_method_namer)   r)   r)   r*   Ú<module>   sz   ÿþýüûúùø	÷
öõôóòñðïÿþýüûúùø	÷
öõôóòñðïîíìëêéèçæåäãâá à!ß"Þ#Ý$Ü%Û&Ú'Ù(Ø)×*Ö+Õ,Ô-Ó.Ò/Ñ0Ð1Ï2Î3Í4ÂB ÿÿ