ó O'—^c@@shddlmZddlZddlmZddlmZddlmZm Z m Z m Z m Z m Z mZmZddlmZmZmZmZmZdefd „ƒYZd efd „ƒYZd efd „ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdS(i(tabsolute_importN(tRecoverableConnectionError(tcommon(t Broadcastt maybe_declaret send_replytcollect_repliestdeclaration_cachedt ignore_errorstQoStPREFETCH_COUNT_MAXi(tCaset ContextMocktMocktMockPooltpatchttest_ignore_errorscB@seZd„ZRS(c C@s™tƒ}tf|_tf|_t|ƒtƒ‚WdQXd„}t||ƒd|_|_|jtƒ!t|ƒtƒ‚WdQXWdQXdS(NcS@s tƒ‚dS(N(tKeyError(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pytraisings((R Rtchannel_errorstconnection_errorsRt assertRaises(tselft connectionR((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyt test_ignoreds       (t__name__t __module__R(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyRsttest_declaration_cachedcB@seZd„Zd„ZRS(cC@s5tƒ}dg|jj_|jtd|ƒƒdS(Ntfoo(R Rtclienttdeclared_entitiest assertTrueR(Rtchan((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyttest_when_cached+s cC@s5tƒ}dg|jj_|jtd|ƒƒdS(NtbarR(R RRRt assertFalseR(RR ((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyttest_when_not_cached0s (RRR!R$(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyR)s ttest_BroadcastcB@seZd„ZRS(cC@sØtddƒ}|j|jjdƒƒ|j|jdƒ|j|jƒ|j|jjdƒ|j|jjdƒtddƒ}|j|jdƒ|j|jjdƒ|t ƒƒ}|j|j|jƒdS(NtnameR%sbcast.tfanouttexplicit_queue_name( RRR&t startswitht assertEqualtaliast auto_deletetexchangettypeR (Rtqtq2((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyttest_arguments8s(RRR1(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyR%6sttest_maybe_declarecB@s#eZd„Zd„Zd„ZRS(cC@sêtƒ}tƒ}|j_tƒ|_tƒ}t|_t|_t|_ ||_ t ||ƒ|j |j jdƒ|jt|ƒ|jjjƒt ||ƒ|j |j jdƒd|j _|jtƒt |ƒWdQXdS(Ni(R RRtsetRtTruetcan_cache_declarationtFalseR,tis_boundtchannelRR*tdeclaret call_counttassertInthashtNoneRR(RR8Rtentity((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyttest_cacheableJs"          cC@srtƒ}tƒ|jj_tƒ}t|_t|_||j _ ||j j _ t ||ƒ|j j |ƒdS(N(R R3RRRR4R5R6R7tbindt return_valueR8Rtassert_called_with(RR8R>((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyttest_binds_entitiesas      cC@s|tƒ}tƒ}|j_tƒ|_tƒ}t|_t|_||_t ||dtƒ|j |jjj j ƒdS(Ntretry( R RRR3RR4R5R7R8RRtensureR:(RR8RR>((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyttest_with_retryms      (RRR?RCRF(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyR2Hs  t test_repliescB@sPeZd„Zedƒd„ƒZedƒd„ƒZedƒd„ƒZRS(cC@stƒ}d|_d|_idd6dd6|_tƒ}tƒ}t|_||_tƒ}||_tƒ|jjj _ t ||idd6|ƒ|j |j jƒ|j j}|j|ddidd6ƒ|j|di|d 6dd 6dd6d d 6td 6dd6dd6ƒdS(Nsapplication/jsontbinarythellotreply_totworldtcorrelation_idiiR-t routing_keytjsont serializerRDt retry_policytcontent_encoding(R t content_typeRQt propertiesR4R7R8R3RRRRRtpublishR:t call_argstassertDictEqualR6R=(RtreqR8R-tproducertargs((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyttest_send_reply|s.            skombu.common.itermessagesc C@sÓtƒtƒtƒ}}}tƒtƒ}}||fg|_t|||dtƒ}t|ƒ}|j||ƒ|j|||dtƒ|jjƒ|jt ƒt|ƒWdQX|j j|j ƒdS(Ntno_ack( R RARR6tnexttassertIsRBtackRt StopIterationtafter_reply_message_receivedR&( Rt itermessagestconnR8tqueuetbodytmessagetittm((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyttest_collect_replies_with_ack–s  c C@s tƒtƒtƒ}}}tƒtƒ}}||fg|_t|||ƒ}t|ƒ}|j||ƒ|j|||dtƒ|j|jj ƒdS(NR[( R RARR\R]RBR4R#R^tcalled( RRaRbR8RcRdReRfRg((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyttest_collect_replies_no_ack¦s cC@sotƒtƒtƒ}}}g|_t|||ƒ}|jtƒt|ƒWdQX|j|jjƒdS(N( R RARRR_R\R#R`Ri(RRaRbR8RcRf((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyttest_collect_replies_no_replies±s  (RRRZRRhRjRk(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyRGzs  t test_insuredcB@sDeZedƒd„ƒZd„Zdd„Zd„Zd„ZRS( skombu.common.loggercC@s'tjddƒ|j|jjƒdS(NRi(Rt_ensure_errbackRterrorRi(Rtlogger((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyttest_ensure_errback¾scC@sOtƒ}tƒ}tjtƒ||ƒ|j|ƒtjtƒ|dƒdS(N(R Rtrevive_connectionRBR=(Rt on_reviveR8((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyttest_revive_connectionÃs    tworkstignoredcC@sJtƒ}t|ƒ}tƒ}tƒ}|j_||_||||fS(N(R RR t autoretryRA(Rtinsured_returnsRbtpooltfuntinsured((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pytget_insured_mocksËs     c C@s|jƒ\}}}}tj||didd6ƒ}|j|dƒ|jjdtjƒ|j|jƒ|j \}}|j |d ƒ|j |idd6|d6ƒ|j|j jƒ|j j \}} |j |||j fƒ|j| jdƒƒ|j| jdƒƒdS( NiR"RRtterrbackRRr(ii(ii(R{RRzR*tensure_connectionRBRmRRiRUtassertTupleEqualRVRvtdefault_channeltget( RRbRxRyRztretti_argsti_kwargstar_argst ar_kwargs((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyRlÓs   cC@s[|jƒ\}}}}tƒ}tj||didd6d|ƒ|jjd|ƒdS(NiR"RR|(ii(R{R RRzR}RB(RRbRxRyRztcustom_errback((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyttest_insured_custom_errbackès  (RtRu(RRRRpRsR{RlR‡(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyRl¼s    t MockConsumercB@s2eZeƒZddd„Zd„Zd„ZRS(cK@s||_||_||_dS(N(R8tqueuest callbacks(RR8R‰RŠtkwargs((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyt__init__ôs  cC@s|jj|ƒ|S(N(t consumerstadd(R((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyt __enter__ùscG@s|jj|ƒdS(N(Rtdiscard(Rtexc_info((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyt__exit__ýsN(RRR3RR=RŒRR’(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyRˆñs  ttest_itermessagescB@sEeZdefd„ƒYZd„Zd„Zedƒd„ƒZRS(tMockConnectioncB@seZeZd„ZRS(cK@sQ|jrtjƒ‚nx2tjD]'}x|jD]}|ddƒq2Wq"WdS(NRdRe(tshould_raise_timeouttsocketttimeoutRˆRRŠ(RR‹tconsumertcallback((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyt drain_eventss  (RRR6R•Rš(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyR”scC@s…|jƒ}tƒ}||j_t|_tj||dddƒ}t|ƒ}|j |dƒ|j t ƒt|ƒWdQXdS(NR/tlimitiRdRe(RdRe( R”R RRRˆtConsumerRRaR\R~RR_(RRbR8RfR((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyt test_default s     cC@sr|jƒ}t|_tƒ}||j_t|_tj ||dddƒ}|j t ƒt |ƒWdQXdS(NR/R›i( R”R4R•R RRRˆRœRRaRR_R\(RRbR8Rf((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyttest_when_raises_socket_timeouts     skombu.common.dequecC@s|tƒ}|_tƒ|j_|jƒ}tƒ}t|_tj ||dddƒ}|j t ƒt |ƒWdQXdS(NR/R›i( R RAt IndexErrortpopleftt side_effectR”RˆRœRRaRR_R\(Rtdequetdeque_instanceRbR8Rf((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyttest_when_raises_IndexError%s   (RRtobjectR”RRžRR¤(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyR“s ttest_QoScB@sfeZdefd„ƒYZd„Zd„Zd„Zd„Zd„Zd„Z d„Z d „Z RS( t_QoScB@seZd„Zd„ZRS(cC@s ||_tj|d|ƒdS(N(tvalueR RŒR=(RR¨((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyRŒ5s cC@s|S(N((RR¨((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyR39s(RRRŒR3(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyR§4s cC@sjtdƒX}tƒ}t|dƒ}d|_|jdƒ|j|jjƒ|jddƒWdQXdS(Nskombu.common.loggeri idItprefetch_counti( RR R tprevR3RtwarnRiRB(RRoR™tqos((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyttest_qos_exceeds_16bit<s   cC@sŠ|jdƒ}|j|jƒdƒ|j|jdƒdƒ|j|jdƒdƒ|j|jdƒdƒ|j|jƒdƒdS(Ni i iiiâÿÿÿii(R§R*tincrement_eventuallytdecrement_eventually(RR¬((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyttest_qos_increment_decrementGs cC@s£|jdƒ}|j|jƒdƒ|j|jdƒdƒ|j|jdƒdƒ|j|jdƒdƒ|j|jƒdƒ|j|jdƒdƒdS(Niiiâÿÿÿii (R§R*R®R¯(RR¬((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyt%test_qos_disabled_increment_decrementOsc@s‰|jdƒ‰‡fd†}‡fd†}d„}|||gƒ|jˆjdƒdˆ_|||gƒ|jˆjdƒdS(Ni c@s%xtdƒD]}ˆjƒq WdS(Niè(trangeR®(ti(R¬(s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyRŽ[sc@s%xtdƒD]}ˆjƒq WdS(Niè(R²R¯(R³(R¬(s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pytsub_scS@slddlm}g|D]}|d|ƒ^q}x|D]}|jƒq9Wx|D]}|jƒqTWdS(Ni(tThreadttarget(t threadingRµtstarttjoin(tfunsRµRytthreadstthread((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pytthreadedcs "  iÚiè(R§R*R¨(RRŽR´R½((R¬s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyttest_qos_thread_safeXs  cC@s·ttƒtdƒ}|jƒ|j|jtdƒ|jƒ|j|jtƒ|jƒ|j|jtdƒ|jƒ|j|jtƒ|jƒ|j|jtdƒdS(Ni(R R R tupdateR*R¨R®R¯(RR¬((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyttest_exceeds_shortrs     cC@stƒ}t|jdƒ}|jƒ|j|jdƒ|jjddƒ|jƒ|jƒ|j|jdƒ|jjddƒ|jƒ|j|jdƒ|jjddƒ|jidd6|jj ƒd|_|jƒ|j|jdƒ|j ƒ|j|jdƒdS(Ni R©i ii( R R R¬R¿R*R¨RBR¯R;RUR®(Rt mconsumerR¬((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyt!test_consumer_increment_decrements$        cC@sbtƒ}t|jdƒ}|jƒ|j|jdƒd|_|jƒ|j|jdƒdS(Ni i i(R R R¬R¯R*R¨(RRÁR¬((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyt"test_consumer_decrement_eventually•s    cC@sOtƒ}t|jdƒ}|jdƒ|j|jdƒ|j|jƒdS(Ni i (R R R¬R3R*Rª(RRÁR¬((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyttest_setžs   ( RRR R§R­R°R±R¾RÀRÂRÃRÄ(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyR¦2s    ( t __future__RR–tamqpRtkombuRt kombu.commonRRRRRRR R tcaseR R R RRRRR%R2RGRlR¥RˆR“R¦(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_common.pyts :( 2B51