ó O'—^c@@s.ddlmZddlZddlmZddlmZmZddlm Z ddl m Z ddl m Z ddlmZmZmZmZd „Zd „Zd efd „ƒYZd efd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdS(i(tabsolute_importN(t Connection(t ResourceErrort ChannelError(tvirtual(tuuid(tcompress(tCasetMocktpatchtredirect_stdoutscK@stdd|S(Nt transports!kombu.transport.virtual:Transport(R(tkwargs((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pytclientscC@s tddƒS(NR tmemory(R(((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyt memory_clientsttest_BrokerStatecB@seZd„ZRS(cC@sztjƒ}|jt|dƒƒ|jt|dƒƒtjddddƒ}|j|jdƒ|j|jdƒdS(Nt exchangestbindingsii (Rt BrokerStatet assertTruethasattrt assertEqualRR(tselftstt((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyttest_constructors  (t__name__t __module__R(((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyRsttest_QoScB@s;eZd„Zd„Zd„Zed„ƒZd„ZRS(cC@s%tjtƒjƒddƒ|_dS(Ntprefetch_counti (RtQoSR tchanneltq(R((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pytsetUp$scC@s|jjjƒdS(N(R!t _on_collecttcancel(R((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyttearDown'scC@sS|j|jjƒ|j|jjƒ|j|jjjƒ|j|jjƒdS(N(RR!R Rt assertFalset _deliveredtrestoredR#(R((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyR*sc @s€g‰dtjf‡fd†ƒY}|j|jjƒƒxJt|jjdƒD]2}|jj|tƒƒ|j|jjƒƒqRW|jj|dtƒƒ|j |jjƒƒt t |jj ƒƒ}|jj |ƒ|j|jjƒƒtƒ}|jj|d|ƒ|j |jjƒƒ|jj|ƒ|j|jjƒƒ||jjjƒ|j_tƒ}|jj|d|ƒ|jj|dtƒ|jjƒ|jjƒ|jˆddd d d d d dddg ƒ|j|jj jƒ|j |jj ƒ|jjƒt|jj _|jjƒ|j|jƒƒ|j |jƒƒt|j_|jjƒdS(NtRestoreChannelc@seZeZ‡fd†ZRS(c@sˆj|ƒdS(N(tappend(Rtmessage(t _restored(sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyt_restore7s(RRtTruet do_restoreR-((R,(sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyR)4siiitrequeuei i iiiii(RtChannelRR!t can_consumetrangeRR*RR&tnexttiterR'tacktrejectR t connectionR.t_flushtrestore_unacked_oncetassertListEqualR(tFalsetgetvaluetrestore_at_shutdown(RtstdouttstderrR)tittag1ttag2ttag3((R,sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyttest_can_consume0s@    .   cC@s0d|jjd<|j|jjdƒdƒdS(Nitfoo(R!R'Rtget(R((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyttest_get_s(RRR"R%RR RERH(((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyR"s    /t test_MessagecB@s#eZd„Zd„Zd„ZRS(cC@s·tƒjƒ}|jdƒ}tƒ}|dd<|j|ƒ}|j|tjƒ|j||j|ƒƒ|j r„|j ƒn|j |j dj dƒƒ|j|j|ƒdS(Nsthe quick brown fox...t propertiest delivery_tagsutf-8(R R tprepare_messageRtmessage_to_pythontassertIsInstanceRtMessagetassertIsterrorst_reraise_errorRtbodytencodeRRK(RtctdatattagR+((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyt test_createfs   cC@s,tjtƒidd6idd6d6ƒdS(NRSiRKRJ(RRORtNone(R((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyttest_create_no_bodytscC@sÀtƒjƒ}tddƒ\}}|j|di|d6ƒ}tƒ}|dd<|j|ƒ}|jƒ}|j|ddjdƒƒ|j|dd|ƒ|j d|dkƒdS( Nsthe quick brown fox...tgziptheaderst compressionRJRKRSsutf-8( R R RRLRRMt serializableRRTR&(RRURSt content_typeRVRWR+tdict_((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyttest_serializableys  (RRRXRZRa(((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyRIds  ttest_AbstractChannelcB@sPeZd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Z RS(cC@s-|jtƒtjƒjdƒWdQXdS(Ntqueue(t assertRaisestNotImplementedErrorRtAbstractChannelt_get(R((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyRHˆscC@s0|jtƒtjƒjddƒWdQXdS(NRctm(RdReRRft_put(R((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyttest_putŒscC@s#|jtjƒjdƒdƒdS(NRci(RRRft_size(R((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyt test_sizescC@s-|jtƒtjƒjdƒWdQXdS(NRc(RdReRRft_purge(R((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyt test_purge“scC@s-|jtƒtjƒjdƒWdQXdS(NRc(RdReRRft_delete(R((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyt test_delete—scC@s |jtjƒjdƒƒdS(NRc(t assertIsNoneRRft _new_queue(R((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyttest_new_queue›scC@s |jtjƒjdƒƒdS(NRc(RRRft _has_queue(R((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyttest_has_queuežscC@sOdtfd„ƒY}|ƒ}|jtjƒj|ƒƒ|j|jƒdS(NtCyclecB@seZeZd„ZRS(cS@s t|_tS(N(R.tcalled(R((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyRG¦s (RRR<RwRG(((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyRv£s(tobjectRRRft_pollRw(RRvtcycle((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyt test_poll¡s ( RRRHRjRlRnRpRsRuR{(((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyRb†s       t test_ChannelcB@s[eZd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Z dd „Z d d „Z d d „Z dd„Z dd„Zd„Zd„Zd„Zedƒedƒd„ƒƒZd„Zd„Zd„Zdd„Zd„Zd„Zd„Zd „Zd!„Zd"„Zd#„Zd$„Zd%„Z d&„Z!d'„Z"d(„Z#RS()cC@stƒjƒ|_dS(N(R R (R((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyR"±scC@s,|jjdk r(|jjjjƒndS(N(R t_qosRYR#R$(R((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyR%´scC@s^tƒ}|j}tddƒ}|_tƒ|j_|jtƒt j |ƒWdQXdS(Ntnamet_avail_channel_ids( R R RRt IndexErrortpopt side_effectRdRRR1(RRURtavail((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyttest_exceeds_channel_max¸s   cC@s0|jtƒ|jjdddƒWdQXdS(Ntdesttsrctkey(RdReR t exchange_bind(R((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyttest_exchange_bind_interfaceÀscC@s0|jtƒ|jjdddƒWdQXdS(NR…R†R‡(RdReR texchange_unbind(R((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyttest_exchange_unbind_interfaceÄscC@s0|jtƒ|jjdddƒWdQXdS(NR…texR‡(RdReR t queue_unbind(R((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyttest_queue_unbind_interfaceÈscC@s:|jjjjƒ}|j|ƒ|jƒ|jƒdS(N(R R8R t get_managerRt get_bindingstclose(RRh((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyttest_managementÌs  c C@s|j}|jtƒ'|jdddtdtdtƒWdQX|jdddtdtƒ|jdddtdtdtƒ|jd|jjƒ|jdddtdtƒ|jd|jjƒ|jtj ƒ!|jdddt dtƒWdQXdS(Nttest_exchange_declaretdirecttdurablet auto_deletetpassive( R RdRtexchange_declareR.tassertIntstateRRtNotEquivalentErrorR<(RRU((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyR“Òs   ttest_exchange_deletecC@s#dtjfd„ƒY}||jjƒ}|j|ddtdtƒ|j||jjƒ|j ||jj ƒ|j |ƒ|j ||jjƒ|j|ddtdtƒ|j |ƒ|j |||ƒ|j|jj |ƒ|j |ƒ|j ||jj ƒ|j||jƒdS(Nt PurgeChannelcB@seZgZd„ZRS(cS@s|jj|ƒdS(N(tpurgedR*(RRc((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyRmìs(RRRžRm(((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyRésR”R•R–(RR1R R8R˜R.R™RšRt assertNotInRtexchange_deletet queue_declaret queue_bindRRž(RRŒRRU((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyRœçs   ttest_queue_delete__if_emptycC@sÝdtjfd„ƒY}||jjƒ}|j|ƒ|j|ƒ|j|||ƒ|j|||ƒ|j|dtƒ|j ||j j ƒd|_ |j|dtƒ|j ||j j ƒ|j ||jƒdS(NRcB@s&eZgZdZd„Zd„ZRS(icS@s|jj|ƒdS(N(RžR*(RRc((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyRmscS@s|jS(N(tsize(RRc((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyRks(RRRžR¤RmRk(((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyRs tif_emptyi(RR1R R8R˜R¡R¢t queue_deleteR.R™RšRR¤RŸRž(RtnRRU((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyR£ÿs    ttest_queue_purgecC@s|dtjfd„ƒY}||jjƒ}|j|ƒ|j|ƒ|j|||ƒ|j|ƒ|j||j ƒdS(NRcB@seZgZd„ZRS(cS@s|jj|ƒdS(N(RžR*(RRc((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyRms(RRRžRm(((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyRs( RR1R R8R˜R¡R¢t queue_purgeR™Rž(RR§RRU((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyR¨s   t test_uniq_tagc C@s6tƒjƒ}tƒjƒ}xA||fD]3}|j|ƒ|j|ƒ|j|||ƒq+W|jdƒ}|jdƒ}|j|||ƒ|j|||ƒ|j|j|ƒƒ}|j|j|ƒƒ}|j |j |j ƒ|j t ƒt |j ƒWdQX|j t ƒt |j ƒWdQXdS(NsGeorge CostanzasElaine Marie Benes(RR R˜R¡R¢RLt basic_publishRMt basic_gettassertNotEqualRKRdt ValueErrortint( RR§tc1tc2RUtm1tm2tr1tr2((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyt'test_basic_publish_unique_delivery_tags(s"  ttest_basic_publishc C@s#tƒjƒ}|j|ƒ|j|ƒ|j|||ƒ|j|dƒ|j|d||ƒ|jdƒ}|j|||ƒ|j|j|ƒƒ}|j |ƒ|j |j dj dƒƒ|j |j|ƒƒtƒ}|j|dtd|dd„ƒ|j|d|jƒ|jƒ\}}|j|ƒ}|j |j dj dƒƒ|j |jd|ƒ|j |jd|ƒ|jtjƒ|jƒWdQX|j|ƒ|j|ƒ|j|j|ƒƒ}|j |ƒ|j |j dj dƒƒ|j |j|ƒƒdS( Nt2snthex quick brown fox...sutf-8t consumer_tagtcallbackcW@sdS(N(RY(ta((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pytTttexchanget routing_key(RR R˜R¡R¢RLR«RMR¬RRRSRTRqRt basic_consumeR<R™t_active_queuest drain_eventst delivery_infoRdRtEmptyt basic_cancelR-( RR§RURhR´R¹Rµt_tr3((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyt)test_basic_publish__get__consume__restore>s>         cC@sXdtjfd„ƒY}||jƒ|j_|jjdƒ|j|jjjƒdS(NtMockQoScB@seZeZd„ZRS(cS@s t|_dS(N(R.t was_acked(RRK((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyR6ks(RRR<RÊR6(((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyRÉhsRF(RRR R}t basic_ackRRÊ(RRÉ((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyttest_basic_ackfscC@s[dtjfd„ƒY}||jƒ|j_|jjdtƒ|j|jjjƒdS(NRÉcB@seZeZd„ZRS(cS@s t|_dS(N(R.t was_restored(R((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pytrestore_unackedws(RRR<RÍRÎ(((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyRÉtsR0(RRR R}t basic_recoverR.RRÍ(RRÉ((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyttest_basic_recover__requeuerscC@s–|jj}tƒ|_idd6|_tƒ|j_t|jj_|jƒ}|j |ddtƒ|j |dddƒ|j |jƒdS(Nii( R tqosRR9R'R-t SystemExitR‚RÎRNRR&(RR!RQ((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyt)test_restore_unacked_raises_BaseException~s   s,kombu.transport.virtual.emergency_dump_stateskombu.transport.virtual.saycC@sÏ|jj}tƒ|_dtfd„ƒY}|idd6ƒ|_tƒ}|_d}y tƒ‚Wntk r‚}|}nX|dfg|_ t |j_ |j ƒ|j |jƒ|j |jƒdS(NtStatecB@seZeZRS((RRR<R((((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyRÔ’si(R RÑRR9tdictR'RÎRYtKeyErrort return_valueR.R/R:RRw(Rtsaytemergency_dump_stateR!RÔtrutexctexc_((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyt)test_restore_unacked_once_when_unrestored‹s      cC@s-|jtƒ|jjdtƒWdQXdS(NR0(RdReR RÏR<(R((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyttest_basic_recover£scC@sXdtjfd„ƒY}||jƒ|j_|jjdƒ|j|jjjƒdS(NRÉcB@seZeZed„ZRS(cS@s t|_dS(N(R.t was_rejected(RRKR0((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyR7¬s(RRR<RßR7(((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyRÉ©sRF(RRR R}t basic_rejectRRß(RRÉ((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyttest_basic_reject§scC@s0|jjddƒ|j|jjjdƒdS(NRi€(R t basic_qosRR}R(R((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyttest_basic_qos³sttest_lookup__undeliverablec C@sytjƒtjdtƒW}|j|jj||dƒdgƒ|j|ƒ|jd|dj j dƒWdQXdS(Ntrecords ae.undeliverscould not be deliveredi( twarningst resetwarningstcatch_warningsR.R;R t_lookupRR™R+targs(RR§tlog((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyRä·s   cC@s@|jjƒ}|j||jƒ|jƒ|j|jƒdS(N(R t __enter__RPt__exit__Rtclosed(Rtx((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyt test_contextÁs cC@s|j|jjƒdS(N(RR Rz(R((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyttest_cycle_propertyÇscC@s*|jtƒ|jjtƒWdQXdS(N(RdReR tflowR<(R((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyt test_flowÊscC@s0d|j_|jjƒ|j|jjƒdS(N(RYR R8R‘RRî(R((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyttest_close_when_no_connectionÎs  cC@su|j}tƒ|_tƒ|_dg|_tƒ|_t|jj_|j ddƒ|jj |j ddƒdS(Nittimeoutg$@( R Rt _get_manyRyt _consumersR}R.R2R×RÂtassert_called_withRÁ(RRU((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyttest_drain_events_has_get_manyÓs     cC@s-|jjddƒ|j|jjƒƒdS(NR¾RF(R R˜Rt get_exchanges(R((sI/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_base.pyttest_get_exchangesÞscC@sh|j}|jjdƒd|jds  "   B")ÿY