
O'^c           @@  s`  d  Z  d d l m Z d d l m Z m Z 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 g Z d e f d     YZ d e f d     YZ	 d e f d      YZ
 d	 e
 f d!     YZ d
 e
 f d"     YZ d e	 f d#     YZ d e	 f d$     YZ d% e f d&     YZ d e f d'     YZ d e f d(     YZ d e f d)     YZ d e f d*     YZ d e f d+     YZ d e f d,     YZ d e f d-     YZ d e f d.     YZ d e f d/     YZ d e f d0     YZ d e f d1     YZ d e f d2     YZ d e f d3     YZ d e f d4     YZ d e f d5     YZ d e f d6     YZ d e f d7     YZ  d e f d8     YZ! d e f d9     YZ" i e d: 6e d; 6e d< 6e d= 6e d> 6e d? 6e d@ 6e dA 6e dB 6e dC 6e dD 6e dE 6e dF 6e dG 6e  dH 6e! dI 6e" dJ 6Z# dK   Z$ dL   Z% i> dM d 6dO d 6dQ d 6dS d 6dU d 6dW d 6dY d 6d[ d 6d] d 6d_ d 6da d 6db d 6dc d 6dd d 6de d 6df d 6dg d 6dh d 6di d 6dj d 6dk d 6dl d 6dm d 6dn d 6do d 6dp d 6dq d 6dr d 6ds d 6dt d 6du d 6dv d 6dw d 6dx d 6dy d 6dz d 6d{ d 6d} d 6d~ d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6d d 6Z& x@ e' e& j(    D], \ Z) Z* e* e& e d e d e)   d <q,Wd S(   s   Exceptions used by amqpi    (   t   absolute_import(   t   packt   unpackt	   AMQPErrort   ConnectionErrort   ChannelErrort   RecoverableConnectionErrort   IrrecoverableConnectionErrort   RecoverableChannelErrort   IrrecoverableChannelErrort   ConsumerCancelledt   ContentTooLarget   NoConsumerst   ConnectionForcedt   InvalidPatht   AccessRefusedt   NotFoundt   ResourceLockedt   PreconditionFailedt
   FrameErrort   FrameSyntaxErrort   InvalidCommandt   ChannelNotOpent   UnexpectedFramet   ResourceErrort   NotConfirmedt
   NotAllowedt   AMQPNotImplementedErrort   InternalErrorc           B@  s;   e  Z d  Z d d d d d  Z d   Z e d    Z RS(   i    c         C@  s   | |  _  | p |  j |  _ | |  _ | |  _ | p6 d |  _ | rd |  j rd t j | d  |  _ n  t j	 |  | | | |  j  d  S(   Nt    (
   t   messaget   codet
   reply_codet
   reply_textt
   method_sigt   method_namet   METHOD_NAME_MAPt   gett	   Exceptiont   __init__(   t   selfR!   R"   R#   R    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR'   %   s    			c         C@  s#   |  j  r d j |   S|  j p" d S(   Ns+   {0.method}: ({0.reply_code}) {0.reply_text}s   <AMQPError: unknown error>(   t   methodt   formatR!   (   R(   (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyt   __str__1   s    	c         C@  s   |  j  p |  j S(   N(   R#   R"   (   R(   (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR)   6   s    N(   t   __name__t
   __module__R   t   NoneR'   R+   t   propertyR)   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR   "   s
   	c           B@  s   e  Z RS(    (   R,   R-   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR   ;   s   c           B@  s   e  Z RS(    (   R,   R-   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR   ?   s   c           B@  s   e  Z RS(    (   R,   R-   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR   C   s   c           B@  s   e  Z RS(    (   R,   R-   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR	   G   s   c           B@  s   e  Z RS(    (   R,   R-   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR   K   s   c           B@  s   e  Z RS(    (   R,   R-   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR   O   s   t   Blockedc           B@  s   e  Z RS(    (   R,   R-   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR0   S   s   c           B@  s   e  Z RS(    (   R,   R-   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR
   W   s   c           B@  s   e  Z d  Z RS(   i7  (   R,   R-   R   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR   [   s   c           B@  s   e  Z d  Z RS(   i9  (   R,   R-   R   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR   _   s   c           B@  s   e  Z d  Z RS(   i@  (   R,   R-   R   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR   c   s   c           B@  s   e  Z d  Z RS(   i  (   R,   R-   R   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR   g   s   c           B@  s   e  Z d  Z RS(   i  (   R,   R-   R   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR   k   s   c           B@  s   e  Z d  Z RS(   i  (   R,   R-   R   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR   o   s   c           B@  s   e  Z RS(    (   R,   R-   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR   s   s   c           B@  s   e  Z d  Z RS(   i  (   R,   R-   R   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR   w   s   c           B@  s   e  Z d  Z RS(   i  (   R,   R-   R   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR   {   s   c           B@  s   e  Z d  Z RS(   i  (   R,   R-   R   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR      s   c           B@  s   e  Z d  Z RS(   i  (   R,   R-   R   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR      s   c           B@  s   e  Z d  Z RS(   i  (   R,   R-   R   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR      s   c           B@  s   e  Z d  Z RS(   i  (   R,   R-   R   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR      s   c           B@  s   e  Z d  Z RS(   i  (   R,   R-   R   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR      s   c           B@  s   e  Z d  Z RS(   i  (   R,   R-   R   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR      s   c           B@  s   e  Z d  Z RS(   i  (   R,   R-   R   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR      s   c           B@  s   e  Z d  Z RS(   i  (   R,   R-   R   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR      s   c           B@  s   e  Z d  Z RS(   i  (   R,   R-   R   (    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyR      s   i7  i9  i@  i  i  i  i  i  i  i  i  i  i  i  i  i  i  c         C@  sC   y t  |  | | d |  SWn! t k
 r> | | | d |  SXd  S(   NR    (   t	   ERROR_MAPt   KeyError(   R   t   textR)   t   default(    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyt   error_for_code   s    c         C@  s   t  |  | | |   d  S(   N(   R5   (   R   R3   R)   R4   (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyt   raise_for_code   s    s   Connection.starti
   s   Connection.start_oki   s   Connection.securei   s   Connection.secure_oki   s   Connection.tunei   s   Connection.tune_oki   s   Connection.openi(   s   Connection.open_oki)   s   Connection.closei2   s   Connection.close_oki3   s   Channel.opens   Channel.open_oks   Channel.flows   Channel.flow_oks   Channel.closes   Channel.close_oks   Access.requests   Access.request_oks   Exchange.declares   Exchange.declare_oks   Exchange.deletes   Exchange.delete_oks   Exchange.binds   Exchange.bind_oks   Exchange.unbinds   Exchange.unbind_oks   Queue.declares   Queue.declare_oks
   Queue.binds   Queue.bind_oks   Queue.purges   Queue.purge_oks   Queue.deletes   Queue.delete_oks   Queue.unbinds   Queue.unbind_oks	   Basic.qosi<   s   Basic.qos_oks   Basic.consumes   Basic.consume_oks   Basic.cancels   Basic.cancel_oks   Basic.publishs   Basic.returns   Basic.delivers	   Basic.getiF   s   Basic.get_okiG   s   Basic.get_emptyiH   s	   Basic.ackiP   s   Basic.rejectiZ   s   Basic.recover_asyncid   s   Basic.recoverin   s   Basic.recover_okio   s
   Basic.nackix   s	   Tx.selects   Tx.select_oks	   Tx.commits   Tx.commit_oks   Tx.rollbacks   Tx.rollback_oks   Confirm.selectiU   s   Confirm.select_oks   >Is   >HHN(   i
   i
   (   i
   i   (   i
   i   (   i
   i   (   i
   i   (   i
   i   (   i
   i(   (   i
   i)   (   i
   i2   (   i
   i3   (   i   i
   (   i   i   (   i   i   (   i   i   (   i   i(   (   i   i)   (   i   i
   (   i   i   (   i(   i
   (   i(   i   (   i(   i   (   i(   i   (   i(   i   (   i(   i   (   i(   i(   (   i(   i)   (   i2   i
   (   i2   i   (   i2   i   (   i2   i   (   i2   i   (   i2   i   (   i2   i(   (   i2   i)   (   i2   i2   (   i2   i3   (   i<   i
   (   i<   i   (   i<   i   (   i<   i   (   i<   i   (   i<   i   (   i<   i(   (   i<   i2   (   i<   i<   (   i<   iF   (   i<   iG   (   i<   iH   (   i<   iP   (   i<   iZ   (   i<   id   (   i<   in   (   i<   io   (   i<   ix   (   iZ   i
   (   iZ   i   (   iZ   i   (   iZ   i   (   iZ   i   (   iZ   i   (   iU   i
   (   iU   i   (+   t   __doc__t
   __future__R    t   structR   R   t   __all__R&   R   R   R   R   R	   R   R   R0   R
   R   R   R   R   R   R   R   R   R   R   R   R   R   R   R   R   R   R   R1   R5   R6   R$   t   listt   itemst
   _method_idt   _method_name(    (    (    s1   /tmp/pip-unpacked-wheel-9igm28/amqp/exceptions.pyt   <module>   s   	
		
