σ O'—^c@@sVdZddlmZddlZddlZddlmZddlmZddl m Z ddl m Z ydd l mZWn'ek r«d efd „ƒYZnXdd lmZd efd„ƒYZyTddlmZddlmZddlmZddlmZddlmZWnZek r‚defd„ƒYZ eZee_!eZZe e_"e_#eZZnXdZ$e%edƒZ&edƒe_'dej"fd„ƒYZ"e"e_"dej#fd„ƒYZ#e#e_#dej!fd„ƒYZ!de j(fd „ƒYZ(d!ee j)fd"„ƒYZd#e j*fd$„ƒYZ*dS(%sF kombu.transport.amqplib ======================= amqplib transport. i(tabsolute_importN(titems(t str_to_bytes(t get_manageri(tbase(tSSLErrorRcB@seZRS((t__name__t __module__(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyRs(tunpacktNAcB@seZRS((RR(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyR s(t client_0_8(t transport(tChannel(tAMQPConnectionException(tAMQPChannelExceptiontNAxcB@seZRS((RR(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyR&si(tMSG_PEEKsAMQPt TCPTransportcB@s&eZd„Zed„Zd„ZRS(cC@sutd|jdtƒƒ\}}}|j|ƒ}t|jdƒƒ}|dkra|||fStd|ƒ‚dS(Ns>BHIiiiΞs3Framing Error, received 0x%02x while expecting 0xce(Rt_readtTruetordt Exception(tselft frame_typetchanneltsizetpayloadtch((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyt read_frame;s$  cC@sΐ|j}x™t|ƒ|kr€y |jj|t|ƒƒ}WnAtjk r}| r{|jtjtjfkr{q n‚nX|s—t dƒ‚n||7}q W|| }|||_|S(Ns Socket closed( t _read_buffertlentsocktrecvtsocketterrorterrnotEAGAINtEINTRtIOError(Rtntinitialt read_buffertstexctresult((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyREs  "  cC@s7z&y|jƒWntk r$nXWdd|_XdS(N(tcloseRtNoneR(R((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyt__del__Ws  (RRRtFalseRR/(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyR9s t SSLTransportcB@s/eZd„Zd„Zed„Zd„ZRS(cC@s>t|tƒr||_nd|_tjj|||ƒdS(N(t isinstancetdicttssloptsR.tsslobjR t_AbstractTransportt__init__(Rthosttconnect_timeouttssl((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyR7ds  cC@sutd|jdtƒƒ\}}}|j|ƒ}t|jdƒƒ}|dkra|||fStd|ƒ‚dS(Ns>BHIiiiΞs3Framing Error, received 0x%02x while expecting 0xce(RRRRR(RRRRRR((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyRks$  cC@s¦d}x™t|ƒ|kr‘y |jj|t|ƒƒ}WnAtjk r~}| rx|jtjtjfkrxq n‚nX|s”tdƒ‚n||7}q W|S(Nts Socket closed( RR5treadR!R"R#R$R%R&(RR'R(R,R*R+((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyRus "cC@s7z&y|jƒWntk r$nXWdd|_XdS(N(R-RR.R(R((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyR/…s  (RRR7RR0RR/(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyR1bs  t ConnectioncB@sYeZeZd„Zd„Zd„Zdd„Zdd„Z dd„Z dd„Z RS(cO@s8ytt|ƒj||ŽWntjk r3nXdS(N(tsuperR=t _do_closeR!R"(Rtargstkwargs((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyR?’sc C@s‡|jƒ}|jƒ}|jƒ}|jƒ}t||dƒ}|jdr}x1|jdD]} | ||||ƒq]Wn|‚dS(Ni2i<t basic_return(i2i<(t read_shortt read_shortstrRtevents( RRR@tmsgt reply_codet reply_texttexchanget routing_keyR+tcallback((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyt_dispatch_basic_returnšs     cO@s0tt|ƒj||Ži|jd6|_dS(Ni<i2(i<i2(R>R=R7RLt_method_override(RR@RA((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyR7§sc C@sϋ|j}|j|dd|ƒ\}}}}||}|rˆ|jrˆt|dƒrˆy|jj|jƒ|_Wqˆtk r„qˆXn|j j |ƒp¬|j j |dƒ}|dkrΞtd|ƒ‚n|dkrη|||ƒS||||ƒSdS(sWait for an event on a channel.ttimeouttcontent_encodingsUnknown AMQP method (%d, %d)N( tchannelst_wait_multipleR.t auto_decodethasattrtbodytdecodeRORRMtgett _METHOD_MAP( RRNtchanmaptchanidt method_sigR@tcontentRt amqp_method((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyt drain_events«s$       cC@sα|dkr|jjƒS|jj}|jƒ}||krM|j|ƒnzpy|jjƒSWnXtk r»}dt|ƒkr”t j ƒ‚ndt|ƒkr΅t j ƒ‚n‚nXWd||krά|j|ƒnXdS(Ns timed outsThe operation did not complete( R.t method_readert read_methodR Rt gettimeoutt settimeoutRtstrR!RN(RRNRtprevR+((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyt read_timeoutΖs"       c C@s9xŽt|ƒD]€\}}|j}xh|D]`}|d}|dks]||ks]|dkr)|j|ƒ|\}} } ||| | fSq)Wq W|j} |j} x| |ƒ\}}} } ||krΦ|dksξ||ksξ|dkrώ||| | fS||jj|| | fƒ|dkr¦| ƒq¦q¦WdS(Niii((ii((ii((Rt method_queueR.tremoveRdtwaittappend( RRPtallowed_methodsRNt channel_idRRet queued_methodRZR@R[RdRg((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyRQάs,              cC@s1y|j|SWntk r,t||ƒSXdS(N(RPtKeyErrorR (RRj((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyRs N( RRRt connectedR?RLR7R.R]RdRQR(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyR=s     $tMessagecB@seZd„ZRS(cK@s}|j}tt|ƒj|d|jd|jd|jdƒd|jdƒd|jd|jd|jdƒpri|dS( NRTt delivery_tagt content_typeROt delivery_infot propertiestheaderstapplication_headers(RrR>RnR7RTRoRVRq(RRRFRAtprops((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyR7 s     (RRR7(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyRnsR cB@sceZeZieƒd6Zd„Zdddddd„Zd„Zd„Z d„Z d„Z RS(RBcO@s)tƒ|_tt|ƒj||ŽdS(N(tsettno_ack_consumersR>R R7(RR@RA((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyR7s c C@s(tj|d|d|d|d||S(s%Encapsulate data into a AMQP message.tpriorityRpRORt(tamqpRn(RRTRxRpRORsRr((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pytprepare_messages cC@s|j||ƒS(s4Convert encoded message body back to a Python value.(Rn(Rt raw_message((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pytmessage_to_python(scC@s(ztt|ƒjƒWdd|_XdS(N(R>R R-R.t connection(R((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyR-,scO@s<tt|ƒj||Ž}|dr8|jj|ƒn|S(Ntno_ack(R>R t basic_consumeRwtadd(RR@RAt consumer_tag((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyR2s cK@s)|jj|ƒtt|ƒj||S(N(RwtdiscardR>R t basic_cancel(RRRA((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyRƒ8sN( RRRnRvRER7R.RzR|R-RRƒ(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyR s    t TransportcB@s»eZeZeZejjee j e e e fZejjefZdZdZeZd„Zd„Zd„Zd„Zd„Zd„Zd„Zd „Zed „ƒZd „ZRS( tamqplibRycK@sC||_|jdƒp|j|_ttkr?tdƒ‚ndS(Nt default_ports-Missing amqplib library (pip install amqplib)(tclientRVR†RyR t ImportError(RR‡RA((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyR7Os  cC@s |jƒS(N(R(RR}((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pytcreate_channelVscK@s |j|S(N(R](RR}RA((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyR]YscC@sΝ|j}xBt|jƒD]1\}}t||d ƒst|||ƒqqW|jdkrid|_n|jd|jd|j d|j d|j d|j d|j d |jd |jƒ}|j|_|S( s(Establish connection to the AMQP broker.t localhosts 127.0.0.1R8tuseridtpasswordt login_methodt virtual_hosttinsistR:R9N(R‡Rtdefault_connection_paramstgetattrR.tsetattrthostnameR=R8R‹RŒRRŽRR:R9(Rtconninfotnamet default_valuetconn((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pytestablish_connection\s           cC@sd|_|jƒdS(s!Close the AMQP broker connection.N(R.R‡R-(RR}((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pytclose_connectionos cC@s‰tr…|jj}|jƒ}|jdƒzFy|jdtjƒWn(tjk r[ntj k rot SXWd|j|ƒXnt S(Ng-Cλβ6?i( t HAS_MSG_PEEKR RR`RaR R!RRNR"R0R(RR}RRc((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pytis_alivets    cC@s|jdk o|j|ƒS(N(RPR.R›(RR}((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pytverify_connectionƒscC@s&|j|jjj|j||ƒdS(N(t add_readerR^tsourceRt on_readable(RR}tloop((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pytregister_with_event_loop†scC@s*idd6dd6|jd6dd6dd6S( NtguestR‹RŒtportRŠR“tAMQPLAINR(R†(R((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyRŠs cO@st|j||ŽS(N(RR‡(RR@RA((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyRs(RRR=t DEFAULT_PORTR†RR„tconnection_errorsR R!R"R&tOSErrortAttributeErrortchannel_errorsRt driver_namet driver_typeRt supports_evR7R‰R]R˜R™R›RœR‘tpropertyRR(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pyR„=s&         (+t__doc__t __future__RR#R!t kombu.fiveRtkombu.utils.encodingRtkombu.utils.amq_managerRR;RR:RRˆRtstructRtobjectR R…R Rytamqplib.client_0_8R tamqplib.client_0_8.channelR t_Channeltamqplib.client_0_8.exceptionsR RRR=RR1R₯RSRštAMQP_PROTOCOL_HEADERRnt StdChannelR„(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/amqplib.pytsJ      & * x&