๓ O'—^c@@sฯdZddlmZddlmZddlmZddlmZm Z ddl m Z dd gZ e j Zedd „Zdejfd „ƒYZd ejfd „ƒYZd ejfd„ƒYZdS(sฆ kombu.compat ============ Carrot compatible interface for :class:`Publisher` and :class:`Producer`. See http://packages.python.org/pypi/carrot for documentation. i(tabsolute_import(tcounti(t messaging(tExchangetQueue(titemst PublishertConsumercc@sQ|jd|ƒx:tdƒD],}|r>||kr>t‚n|jƒVqWdS(Ntno_acki(tconsumeRt StopIterationt drain_events(t connectiontconsumerRtlimitt iteration((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pyt _iterconsumes  cB@szeZdZdZdZeZeZeZ ddddddd„Z d„Z d„Z d„Zd„Zed„ƒZRS( ttdirectc K@sๆ|r|}n|p|j|_|p-|j|_|p?|j|_|dk r]||_n|dk ru||_nt|jtƒsรtd|jd|jd|jd|jd|jƒ|_ntt |ƒj ||j|dS(Ntnamettypet routing_keyt auto_deletetdurable( texchanget exchange_typeRtNoneRRt isinstanceRtsuperRt__init__( tselfR RRRRRtchanneltkwargs((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pyR(s         cO@s|j||ŽS(N(tpublish(RtargsR ((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pytsend?scC@s tt|ƒjƒt|_dS(N(RRtclosetTruet_closed(R((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pyR$BscC@s|S(N((R((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pyt __enter__FscG@s|jƒdS(N(R$(Rtexc_info((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pyt__exit__IscC@s|jS(N(R(R((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pytbackendLsN(t__name__t __module__RRRR%RtFalseRR&RRR#R$R'R)tpropertyR*(((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pyR s      cB@sืeZdZdZdZdZeZeZ eZ dZeZ dddddddd„Z d„Zd„Zd„Zd„Zd„Zded„Zd „Zdd „Zddd „Zdd „Zded „ZRS(RRc K@s.|jƒ|_|dk r'||_n|dk r?||_n|dk rW||_n|pc|j|_|pu|j|_|p‡|j|_|p™|j |_ t |jd|jd|j d|jd|jƒ}t |jd|d|j d|jd|jd|jƒ}t t |ƒj|j|| dS(NRRRRRt exclusive(RR*RRR/RtqueueRRRRRRRR( RR R0RRRRR/RR ((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pyR\s.                cC@s#||_tt|ƒj|ƒdS(N(R*RRtrevive(RR((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pyR1zs cC@s$|jƒ|jjƒt|_dS(N(tcancelR*R$R%R&(R((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pyR$~s  cC@s|S(N((R((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pyR'ƒscG@s|jƒdS(N(R$(RR(((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pyR)†scC@s|jdtƒS(Ntinfinite(t iterqueueR%(R((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pyt__iter__‰scC@sW|dkr|j}n|jdj|ƒ}|rS|rS|j|j|ƒqSn|S(Ni(RRtqueuestgettreceivetpayload(RRtenable_callbackstmessage((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pytfetchŒs  cC@stdƒ‚dS(Ns Use fetch(enable_callbacks=True)(tNotImplementedError(R((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pyt process_next•scC@s%|dk rtdƒ‚n|jƒS(Ns&discard_all does not implement filters(RR=tpurge(Rt filterfunc((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pyt discard_all˜s  cC@st|j|||ƒS(N(RR (RRR((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pyt iterconsumežscC@s|j|ƒ}t|ƒS(N(RBtlist(RRtit((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pytwaitกscc@sWxPtƒD]E}|jƒ}| r/|dksA|rJ||krJt‚n|Vq WdS(N(RR<RR (RRR3titems_since_starttitem((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pyR4ฅs   N(R+R,R0RRRR%RR-R/RR&RRR1R$R'R)R5R<R>RARBRER4(((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pyRQs.         t ConsumerSetcB@sVeZdddd„Zded„Zd„Zd„Zd„Zd„Z d„Z RS(c K@sล|rt|_||_nt|_|jƒ|_g}|rcx!|D]}|j|jƒqFWn|rขx6t|ƒD]%\}} |jt j || ƒqvWnt t |ƒj |j||dS(N(R%t_provided_channelR*R-RtextendR6RtappendRt from_dictRRHR( RR RLt consumersRR R6R t queue_namet queue_options((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pyRฐs     cC@st|j|||ƒS(N(RR (RRR((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pyRBรscC@s |jƒS(N(R?(R((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pyRAฦscK@s|j||S(N(tadd_queue_from_dict(RR0toptions((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pytadd_consumer_from_dictษscC@s%x|jD]}|j|ƒq WdS(N(R6t add_queue(RR R0((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pyt add_consumerฬscC@s#||_tt|ƒj|ƒdS(N(R*RRHR1(RR((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pyR1ะs cC@s'|jƒ|js#|jjƒndS(N(R2RIRR$(R((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pyR$ิs  N( R+R,RRR-RBRARRRTR1R$(((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pyRHฎs     N(t__doc__t __future__Rt itertoolsRRRtentityRRtfiveRt__all__RLtentry_to_queueR-RRtProducerRRRH(((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/compat.pyt s  1]