ó O'—^c@@sĘdZddlmZddlZddlmZddlmZddlmZddl m Z dd l m Z m Z d d gZd efd „ƒYZd efd„ƒYZd efd„ƒYZdS(s/ kombu.simple ============ Simple interface. i(tabsolute_importN(tdequei(tentity(t messaging(t maybe_channel(tEmptyt monotonict SimpleQueuet SimpleBuffert SimpleBasecB@sĪeZeZeZd„Zd„Zed„Zed d„Z d„Z d d d d d„Z d„Z d„Zd„Zd „Zd „Zd „Zd „ZeZRS(cC@s|S(N((tself((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/simple.pyt __enter__scG@s|jƒdS(N(tclose(R texc_info((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/simple.pyt__exit__scC@s`t|ƒ|_||_||_||_|jjd|_tƒ|_|jj |j ƒdS(Ni( Rtchanneltproducertconsumertno_acktqueuestqueueRtbuffertregister_callbackt_receive(R RRRR((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/simple.pyt__init__ s    cC@sÃ|s|jƒS|jƒd}|}x–trūtƒ}|jrN|jjƒSy#|jjjj d|ol|ƒWn t j k r“|j ƒ‚nX|tƒ|7}|rĩ||pļd}q)WdS(Ngttimeout(t get_nowaitt_consumetTrueRRtpopleftRt connectiontclientt drain_eventstsocketRRtNone(R tblockRtelapsedt remainingt time_start((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/simple.pytget)s       cC@s1|jjd|jƒ}|s-|jƒ‚n|S(NR(RR'RR(R tm((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/simple.pyR;sc K@s/|jj|d|d|d|d||dS(Nt serializert routing_keytheaderst compression(Rtpublish(R tmessageR)R+R,R*tkwargs((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/simple.pytputAs cC@s |jjƒS(N(Rtpurge(R ((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/simple.pytclearJscC@s"|jjdtƒ\}}}|S(Ntpassive(Rt queue_declareR(R t_tsize((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/simple.pytqsizeMscC@s|jjƒdS(N(Rtcancel(R ((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/simple.pyR QscC@s|jj|ƒdS(N(Rtappend(R t message_dataR.((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/simple.pyRTscC@s/|js+|jjd|jƒt|_ndS(NR(t _consumingRtconsumeRR(R ((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/simple.pyRWs cC@s |jƒS(s`len(self) -> self.qsize()`(R7(R ((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/simple.pyt__len__\scC@stS(N(R(R ((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/simple.pyt__bool__`sN(t__name__t __module__RtFalseR;R RRRR"R'RR0R2R7R RRR=R>t __nonzero__(((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/simple.pyR s"             cB@s9eZeZiZidd6Zdddddd„ZRS(tdirectttypec K@s |} t|j|pi}t|j|p0i}|dkrN|j}nt| tjƒs“tj||} tj|| ||} |} n| j }| j } | j } t j || d|d| d|ƒ} t j|| ƒ} tt|ƒj|| | ||dS(NR)R*R,(tdictt queue_optst exchange_optsR"Rt isinstanceRtQueuetExchangetnametexchangeR*RtProducertConsumertsuperRR(R RRKRRFRGR)R,R/RRLR*RR((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/simple.pyRjs&       N(R?R@RARRFRGR"R(((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/simple.pyRes  cB@s>eZeZededeƒZededddeƒZRS(tdurablet auto_deletet delivery_modet transient(R?R@RRRERARFRG(((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/simple.pyRƒs    (t__doc__t __future__RR!t collectionsRtRRRRtfiveRRt__all__tobjectR RR(((s./tmp/pip-unpacked-wheel-UAnTfW/kombu/simple.pyts  O