σ O'—^c@@snddlmZddlZddlmZmZmZmZmZddl m Z de fd„ƒYZ dS(i(tabsolute_importN(t ConnectiontExchangetQueuetConsumertProducer(tCasettest_MemoryTransportcB@sPeZd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Z RS(cC@s¦tddƒ|_tdƒ|_tdd|jddƒ|_tdd|jddƒ|_tddd ƒ|_td d|jƒ|_td d|jƒ|_ dS( Nt transporttmemoryttest_transport_memorytexchanget routing_keyttest_transport_memory2ttest_transport_memory_fanoutttypetfanoutttest_transport_memory_fanout1ttest_transport_memory_fanout2( RtcRteRtqtq2Rtq3tq4(tself((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_memory.pytsetUp s        cC@s|j|jjjƒƒdS(N(t assertTrueRRtdriver_version(R((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_memory.pyttest_driver_versionsc@sΪ|jjƒ}t||jƒ}t||jdtƒ}x.tdƒD] }|ji|d6ddƒqFWg‰‡fd†}|j |ƒ|j ƒx't ˆƒdkr―Pn|jj ƒq™W|j t ˆƒdƒdS(Ntno_acki tfooR R c@sˆj|ƒdS(N(tappend(t message_datatmessage(t _received(sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_memory.pytcallback(s(RtchannelRRRRtTruetrangetpublishtregister_callbacktconsumetlent drain_eventst assertEqual(RR%tproducertconsumertiR$((R#sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_memory.pyttest_produce_consume_noacks  cC@sν|jjƒ}|jj|j|jgƒ}|jidd6d|jd|jƒ|j|j|jƒj ƒj idd6ƒ|j|j|jƒj ƒj idd6ƒ|j |j|jƒj ƒƒ|j |j|jƒj ƒƒdS(NtworldthellotdeclareR ( RRRRRR(tqueuesRR-tgettpayloadt assertIsNone(RR.R/((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_memory.pyttest_produce_consume_fanout5s   ,,c @sΔ|jjƒ}t||jƒ}t||jƒ}t||jƒ}|j|ƒjƒx.tdƒD] }|j i|d6ddƒqeWx.tdƒD] }|j i|d6ddƒq–Wg‰g‰‡fd†}‡fd†}|j |ƒ|j |ƒ|j ƒ|j ƒx1t ˆƒt ˆƒdkr5Pn|jj ƒqW|jt ˆƒt ˆƒdƒ|j itd 6ddd d ƒ|j|ƒjƒ}|j|jitd 6ƒx.tdƒD] }|j i|d6ddƒqΒW|j|j|ƒjƒƒ|j|ƒjƒ|j|ƒjƒ|j|j|ƒjƒƒx.tdƒD] }|j i|d6ddƒqQW|j|j|ƒjƒƒ|j|ƒjƒ|j|j|ƒjƒƒdS( Ni RR R R c@sˆj|ƒ|jƒdS(N(R tack(R!R"(t _received1(sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_memory.pyt callback1Ss c@sˆj|ƒ|jƒdS(N(R R:(R!R"(t _received2(sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_memory.pyt callback2Ws it compressedt compressiontzlib(RR%RRRRRR4R'R(R)R*R+R,R-R&R6tassertDictEqualR7RtdeleteR8tpurge( RR%R.t consumer1t consumer2R0R<R>tm((R;R=sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_memory.pyttest_produce_consumeDsL     cC@s€|jtjƒ|jjddƒWdQX|jjƒ}|jjƒ}|jtjƒ|jjddƒWdQX~~dS(Nttimeoutgš™™™™™Ή?(t assertRaisestsocketRIRR,R%(Rtc1tc2((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_memory.pyttest_drain_events~sc@sd|jjƒ‰dtf‡fd†ƒY}|ƒ|jj_|jtƒ|jjƒWdQXdS(NtCyclec@seZd‡fd†ZRS(c@s dˆfS(NR(RR((RRI(RL(sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_memory.pyR6sN(t__name__t __module__tNoneR6((RL(sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_memory.pyROŽs(RR%tobjectRtcycleRJtKeyErrorR,(RRO((RLsC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_memory.pyt$test_drain_events_unregistered_queue‹s cC@sU|jjƒ}|jjƒ|jdƒ}|j|ƒ|j|jdƒ|ƒdS(NR(RR%R5tcleart _queue_forRtassertIs(Rtchantx((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_memory.pyttest_queue_for—s   ( RPRQRRR1R9RHRNRVR\(((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_memory.pyR s     : ( t __future__RRKtkombuRRRRRtkombu.tests.caseRR(((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_memory.pyts (