ó O'—^c@@sqdZddlmZddlZddlZddlZy ddlZddlmZWnek rwdZZnXddl m Z ddl m Z ddlmZddlmZdd lmZmZd d lmZe d ƒZd ZdZd ZejejZZdefd„ƒYZdefd„ƒYZdej fd„ƒYZ dej!fd„ƒYZ!dS(s= kombu.transport.zmq =================== ZeroMQ transport. i(tabsolute_importN(tZMQError(tEmpty(t get_logger(tpickle(tcached_property(tpolltREADi(tvirtualskombu.transport.zmqi³i€tMultiChannelPollercB@sheZeZd„Zd„Zd„Zd„Zd„Zd„Z d„Z d d„Z e d„ƒZRS( cC@s%tƒ|_i|_tƒ|_dS(N(tsett _channelst _fd_to_chanRtpoller(tself((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyt__init__(s  cC@scx9|jD].}y|jj|ƒWq tk r7q Xq W|jjƒ|jjƒd|_dS(N(R R t unregistertKeyErrorR tcleartNone(Rtfd((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pytclose0s   cC@s|jj|ƒdS(N(R tadd(Rtchannel((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyR:scC@s0|jj|ƒ|jj|jjjdƒdS(N(R tdiscardR tpoptclientt connectionRR(RR((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyR=scC@s9|jj}||j|j<|jj|j|jƒdS(N(RRR RR tregistert eventflags(RRtconn((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyt _registerAs cC@s%x|jD]}|j|ƒq WdS(N(R R(RR((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyt on_poll_startFscC@s|j|}|jƒ|fS(N(R t drain_events(Rtfilenotchan((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyt on_readableJs cC@sP|jƒ|jj|ƒ}x$|p(gD]\}}|j|ƒSWtƒ‚dS(N(R R RR$R(RttimeoutteventsR"t_((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pytgetNs  cC@s|jS(N(R (R((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pytfdsWsN(t__name__t __module__RRRRRRRR R$RR(tpropertyR)(((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyR %s       tClientcB@s\eZdeededd„Zd„Zddd„Zd„Z d„Z e d„ƒZ RS(stcp://127.0.0.1c C@s¥y|jdƒ\}}Wntk r8d}|}nX|jdƒ} ||_|dkrltdƒ‚n|p~tjjƒ|_|r¾|jjtj ƒ|_ |j j dj |ƒƒn d|_ |jjtjƒ|_ttdƒr|jjtj|ƒn|jjtj|ƒ|r<|jjtj|ƒnxb| D]Z} |dkrxd| krx| dttƒ7} ndj|d| gƒ} |j| ƒqCWdS( Ns://ttcpt;sCurrently only TCP can be usedstcp://*:{0.port}tSNDHWMt:t(tsplitt ValueErrortporttNotImplementedErrortzmqtContexttinstancetcontexttsockettPULLtsinktbindtformatRtPUSHtventthasattrt setsockoptR0tHWMtSWAPtstrt DEFAULT_PORTtjointconnect( RturiR5thwmt swap_sizet enable_sinkR:tschemetpartst endpointstendpoint((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyR^s2      cC@s|jj|ƒdS(N(RARI(RRQ((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyRI†scC@sž|j}yK|dk rI|j|}|_z|jƒSWd||_Xn |jƒSWnCtk r™}|jtjkr“tj tj|j ƒ‚qš‚nXdS(N( R=RtRCVTIMEOtrecvRterrnoR7tEAGAINR;terrortstrerror(RtqueueR%R=t prev_timeouttexc((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyR(‰s   cK@s|jj|ƒS(N(RAtsend(RRXtmessagetkwargs((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pytputšscC@sF|jr&|jj r&|jjƒn|jjsB|jjƒndS(N(R=tclosedRRA(R((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyRs cC@s|jr|jS|jS(N(R=RA(R((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyR£s N( R*R+RGt DEFAULT_HWMRtTrueRRIR(R^RR,R(((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyR-\s  &   tChannelcB@s“eZeZeZd ZeZe Z e j j dZ d„Zd d„Zd„Zd„Zd d„Zd „Zd „Zd „Zed „ƒZRS(RKRLRMt port_incrcO@sRtt|ƒ}|j||Ž|jjj|jjj|ƒ|jj|_dS(N( tsuperRbRRRR_tcycleRtconnection_errors(RtargsR]tsuper_((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyR·s  cC@sgyt|jj||ƒƒSWnCtjk rb}|jtjkr\|dkr\tƒ‚qc‚nXdS(Ni(tloadsRR(R;RVRTRUR(RRXR%RZ((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyt_getÁs  cK@s#|jj|t|dƒ|dS(Niÿÿÿÿ(RR^tdumps(RRXR\R]((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyt_putÊscC@sdS(Ni((RRX((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyt_purgeÍscC@s|jd|ƒS(NR%(R((RReR%((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyt_pollÐscC@s_|jsH|jjj|ƒy|jdjƒWqHtk rDqHXntt|ƒjƒdS(NR( R_RReRt__dict__RRRdRb(R((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyRÓs  cC@s||jd|jS(Ni(t channel_idRc(RR5((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyt _prepare_portÜsc C@sj|jj}|j|jptƒ}|jd|jp9dd|d|jd|jd|j d|jj ƒS(NRJstcp://127.0.0.1R5RKRLRMR:( RRRqR5RGR-thostnameRKRLRMR:(RtconninfoR5((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyt_create_clientßs    cC@s |jƒS(N(Rt(R((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyRésN(RKRLRMRc(R*R+R-R`RKRRLRaRMt DEFAULT_INCRRcRRbtfrom_transport_optionsRRjRlRmRnRRqRtRR(((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyRbªs       t TransportcB@sŸeZeZeZeZdZdZe j j e fZ eZ d Zd„Zd„Zd„Zd„Zd d„Zd„Zd„Zd „Zed „ƒZRS( tzeromqR7cO@sDtdkrtdƒ‚ntt|ƒj||Žtƒ|_dS(Ns The zmq library is not installed(R7Rt ImportErrorRdRwRR Re(RRgR]((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyRûs cC@stjS(N(R7t __version__(R((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pytdriver_versionsc@s\|j‰|jˆ_|j‰|j‰ˆj‰‡‡‡‡fd†}|jj|ƒdS(Nc@s1ˆƒgˆjD]}ˆ|ˆ|ƒ^qdS(N(R)(R(t add_readerRetcycle_poll_startR$(s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyR s(ReR R|R$R ton_tickR(RRtloopR ((R|ReR}R$s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pytregister_with_event_loops     cC@s|j|jj|ƒƒdS(N(t _handle_eventReR$(RR"((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyR$scC@s®t}xw|jD]l}y|jjd|ƒ}Wn1tjk rb}|jtjkr\qn‚qX|j||fƒt }qW|sªtjtjt j tjƒƒ‚ndS(NR%( tFalsetchannelsReR(R;RVRTRURRatosRW(RRR%t more_to_readRtevtRZ((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyR!s cC@s^|\}}|\}}| s.||jkrItdj||ƒƒ‚n|j||ƒdS(Ns.Message for queue {0!r} without consumers: {1}(t _callbacksRR?(RR†titemRR\RX((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyR$s  cC@s|jjtt|ƒjƒS(N(R:R_RdRwtestablish_connection(R((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyR‰-s cC@sCtt|ƒj|ƒy|jdjƒWntk r>nXdS(NR:(RdRwtclose_connectionRottermR(RR((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyRŠ1s  cC@s tjdƒS(Ni(R7R8(R((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyR:8sN(R*R+RbRat can_parse_urlRGt default_portt driver_typet driver_nameRRwRfRt supports_evRtpolling_intervalRR{R€R$R!RR‰RŠRR:(((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyRwîs"       ("t__doc__t __future__RRTR„R;R7RRyRt kombu.fiveRt kombu.logRtkombu.serializationRt kombu.utilsRtkombu.utils.eventioRRR2RtloggerRGR`RuRkRitobjectR R-RbRw(((s5/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/zmq.pyts0      7ND