Ë
    šQjþ  ã                   ó¶  — 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“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%jO                  «       «      D ]  \  Z(Z)e)e% edÀ edÁg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/html/truck-me/venv/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ÓBˆDÔÜ×Ñ˜4 Ø% z°4×3CÑ3Cõ	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   € à×ÑÒ2 4§?¡?Ð2r'   )NNNN)	r"   r#   r$   r%   r.   r6   r=   Úpropertyr9   r&   r'   r(   r   r      s/   „ Ù-à€Dà37Ø.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Ü˜‰˜t V¸Ô=Ð=øÜò 6Ù�t˜V°Ô5Ò5ð6ús   ‚ “*©*)é
   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“      sn  ðÙ ÷  ð€ô)˜[ô )ô(�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 ˆoð7?ð8 Ð ð9?ð: ˆlð;?ð< ˆoð=?ð> ˆmð??ð@ ÐðA?ðB ˆnðC?ðD ÐòE?ðF ˆnðG?ðH ÐðI?ðJ ˆkðK?ðL ˆnðM?ðN ˆoðO?ðP Ð ðQ?ðR ˆnðS?ðT ÐðU?ðV ˆoðW?ðX ˆnðY?ðZ ˆoð[?ð\ ˆkð]?ð^ ˆnð_?ð` Ðða?ðb ˆkðc?ðd ˆnðe?ðf Ð$ñg?ðh Ø!ØØØØØØØØØ!ò}?€ñD !% _×%:Ñ%:Ó%<Ó =ò Ñ€J�àð ‘F˜4¡ eÐ!9¨jÒ!9Ó:¸1Ñ=Ò>ñr'   