σ O'—^c@@sΚddlmZddlmZmZmZddlmZddlmZm Z m Z ddl m Z m Z defd„ƒYZd efd „ƒYZd efd „ƒYZd efd„ƒYZdS(i(tabsolute_import(t ConnectiontExchangetQueue(tcompati(tCasetMocktpatch(t TransporttChannelt test_misccB@seZd„Zd„ZRS(c C@sΖdtfd„ƒY}dtfd„ƒY}|ƒ}|ƒ}tj||ƒ}|jt|ƒdƒ|j|jƒtj||ddƒ}|jt|ƒdd d d d d ddddg ƒdS(Nt MyConnectioncB@seZdZd„ZRS(ic_@s|jd7_|jS(Ni(tdrained(tselftargstkwargs((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyt drain_eventss(t__name__t __module__R R(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyR stConsumercB@seZeZd„ZRS(c_@s t|_dS(N(tTruetactive(R RR((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pytconsumes(RRtFalseRR(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyRsitlimiti iiiiiiii i (tobjectRt _iterconsumet assertEqualtnextt assertTrueRtlist(R R Rtconntconsumertittit2((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyttest_iterconsume s  cC@sidd6dd6dd6td6td6}tjd t|ƒ}|j|jd ƒ|j|jdƒ|j|jjdƒ|j|jj dƒ|j |j ƒ|j |jj ƒ|j |j ƒ|j |jj ƒtjd t|d tƒ}|j |j ƒ|j |jj ƒtjd t|d tƒ}|j |j ƒ|j |jj ƒtjd t|d tƒ}|j |j ƒ|j |jj ƒtjd t|d tƒ}|j |j ƒ|j |jj ƒ|jtjd t|ƒtjd t|ƒƒdS(Nsfoo.#t binding_keytfooextexchangettopict exchange_typetdurablet auto_deletetfootexchange_durabletexchange_auto_deletet queue_durabletqueue_auto_delete(RRRt from_dicttdictRtnamet routing_keyR&ttypeRR)t assertFalseR*(R tdefstq1tq2tq3tq4tq5((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyttest_Queue_from_dict$s@      (RRR#R<(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyR s ttest_PublishercB@s,eZd„Zd„Zd„Zd„ZRS(cC@stdtƒ|_dS(Nt transport(RRt connection(R ((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pytsetUpOsc C@s6tj|jddddƒ}|j|jtƒ|j|jjdƒ|j |jj ƒ|j |jj ƒ|j|jj dƒtj|jdddddtdtƒ}|j |jj ƒ|j |jj ƒtd d d ƒ}tj|jd|ƒ}|j|j|ƒtj|jdd d |jjƒdS(NR&ttest_Publisher_constructorR3trkeytdirectttest_Publisher_constructor2R*R)t#test_Publisher_constructor_explicitR4R'ttest_Publisher_constructor3tchannel(Rt PublisherR?tassertIsInstancetbackendR RR&R2RR)R5R*R4RRRtdefault_channel(R tpubtpub2texplicittpub3((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyttest_constructorRs.     cC@sStj|jddddƒ}|jidd6ƒ|jd|jƒ|jƒdS(NR&ttest_Publisher_sendR3RBtbarR+t basic_publish(RRHR?tsendtassertInRJtclose(R RL((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyt test_sendns  cC@sXtj|jddddƒ}|jƒ}|j||ƒ|jƒ|j|jƒdS(NR&RQR3RB(RRHR?t __enter__tassertIst__exit__Rt_closed(R RLtx((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyttest__enter__exit__vs   (RRR@RPRWR](((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyR=Ms   t test_ConsumercB@sΉeZd„Zedƒdd„ƒZdd„Zdd„Zdd „Zd d „Zd d „Z dd„Z dd„Z dd„Z dd„Z dd„Zdd„Zd d„ZRS(cC@stdtƒ|_dS(NR>(RRR?(R ((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyR@‚sskombu.compat._iterconsumeR#cC@sQtj|jd|d|ƒ}|jdddtƒ|j|j|tdƒdS(NtqueueR&Ri tno_ack(RRR?t iterconsumeRtassert_called_with(R R!tntc((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyt#test_iterconsume_calls__iterconsume…sttest_Consumer_constructorcC@sHtj|jd|d|ddƒ}|j|jtƒ|jd}|j|jƒ|j|j jƒ|j |j ƒ|j |j j ƒ|j |j |ƒ|j |j j |ƒtj|jd|dd|ddddtdtd tƒ}|jd}|j |jƒ|j |j jƒ|j|j ƒ|j|j j ƒdS( NR_R&R3RBit2R)R*t exclusive(RRR?RIRJR tqueuesRR)R&R5R*RR2RR(R RcRdtqtc2R8((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyRP‹s&     R]cC@s^tj|jd|d|ddƒ}|jƒ}|j||ƒ|jƒ|j|jƒdS(NR_R&R3RB(RRR?RXRYRZRR[(R RcRdR\((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyR]‘s    t test_revivecC@sZtj|jd|d|ƒ}|jjƒ'}|j|ƒ|j|j|ƒWdQXdS(NR_R&(RRR?RGtreviveRYRJ(R RcRdRk((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyRl©s t test__iter__cC@sKtj|jd|d|ƒ}tƒ|_|jƒ|jjdtƒdS(NR_R&tinfinite(RRR?Rt iterqueuet__iter__RbR(R RcRd((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyRn°s  ttest_iterqueuecC@s2tj|jd|d|ddƒ}|jƒdS(NR_R&R3RB(RRR?RV(R RcRd((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyt test_iter·s ttest_process_nextcC@sRtj|jd|d|ddƒ}|jtƒ|jƒWdQX|jƒdS(NR_R&R3RB(RRR?t assertRaisestNotImplementedErrort process_nextRV(R RcRd((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyRtΌs  cC@s2tj|jd|d|ddƒ}|jƒdS(NR_R&R3RB(RRR?RV(R RcRd((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyR#Γs ttest_discard_allcC@sEtj|jd|d|ddƒ}|jƒ|jd|jƒdS(NR_R&R3RBt queue_purge(RRR?t discard_allRURJ(R RcRd((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyRxΘs  t test_fetchc@stj|jd|d|ddƒ}|j|jƒƒ|j|jdtƒƒ|jd|jƒtg‰‡fd†}|jj j dƒ|jƒj }|j |dƒ|jj j d ƒ|j |ƒ|j |jd tƒj d ƒ|jˆd ƒdS( NR_R&R3RBR`t basic_getc@stˆdζt(RRR?RuRvRzRV(R RcRd((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyt)test_discard_all_filterfunc_not_supportedβs  t test_waitcC@smdtjfd„ƒY}||jd|d|ddƒ}|j|jdƒttdƒƒƒ|jƒdS(NtCcB@seZdd„ZRS(cs@s xt|ƒD] }|Vq WdS(N(trange(R Rti((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyRaνsN(RRtNoneRa(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyRλsR_R&R3RBi (RRR?RtwaitRRRV(R RcRRd((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyRŽιs  %c@s…dg‰dtjf‡fd†ƒY}||jd|d|ddƒ}|jt|jdd ƒƒttd ƒƒƒ|jƒdS( NiRc@seZd‡fd†ZRS(c@sˆd}ˆdcd7<|S(Nii((R Rtz(R‘(s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyR…ϋs N(RRR’R…((R‘(s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyRωsR_R&R3RBRi (RRR?RRRpRRV(R RcRRd((R‘s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyRrφs   .(RRR@RReRPR]RlRnRsRtR#RxR{RRŽRr(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyR^€s             ttest_ConsumerSetcB@sJeZd„Zd„Zedƒdd„ƒZdd„Zdd„ZRS( cC@stdtƒ|_dS(NR>(RRR?(R ((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyR@scC@s}tddƒ}tj|jd|ƒ}|j|jƒ|j|j|ƒtddƒ|_|j ƒ|j |j j ƒdS(NR2RGtcancel( RRt ConsumerSetR?Rt_provided_channelRYRJR–RVR5tcalled(R tchantcs((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyttest_providing_channel s skombu.compat._iterconsumeR#cC@sltj|jd|d|ƒ}tj|jd|gƒ}|jdddtƒ|j|j|tdƒdS(NR_R&t consumersRi R`(RRR?R—RaRRb(R RRcRdR›((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyR#sRlcC@sutj|jd|d|ƒ}tj|jd|gƒ}|jjƒ'}|j|ƒ|j|j|ƒWdQXdS(NR_R&R(RRR?R—RGRmRYRJ(R RcRdR›Rk((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyRls  t0daf8h21c C@sNiid|d6dd6d|6id|d6dd6d|6}gtdƒD]8}tj|jd|t|ƒd|t|ƒƒ^qM}tj|jd |ƒ}tj|jd |ƒ}|jt|jƒdƒ|jt|jƒd ƒ|j tj|jd|d d|d ƒƒ|jt|jƒd ƒx'|jD]}|j |j |j ƒq=W|j iid|d6dd6d|6ƒ|jt|jƒdƒx'|jD]}|j |j |j ƒqͺW|j ƒ|j|j jjdƒd ƒ|jƒ|jƒ|jƒ|jd|j ƒ|jd|j ƒ|jd|j ƒdS(Ns%s.xyxR&txyxR3s%s.xyztxyziR_RR0itxaxxxais%s.xxxtxxxRyt basic_cancelRV(RRRR?tstrR—RtlenRit add_consumerRYRGtadd_consumer_from_dictRzR™tcountRRVRU( R tprefixtdconR‘RRdRktcqtc2q((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyRP$s>H       (RRR@RœRR#RlRP(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pyR•s    N(t __future__RtkombuRRRRtcaseRRRtmocksRR R R=R^R•(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_compat.pytsC3†