ó O'—^c@@sˆddlmZddlmZmZmZddlmZmZdefd„ƒYZ de fd„ƒYZ d e fd „ƒYZ d S( i(tabsolute_import(t ConnectiontExchangetQueuei(tCasetMockt SimpleBasecB@szeZeZd„Zd„Zd„Zd„Zd„Zd„Z d„Z d„Z d„Z d „Z d „Zd „ZRS( cO@sP|}t|tƒs=|jj}|r=d||f}q=n|j|||ŽS(Ns%s.%s(t isinstanceRt __class__t__name__t_Queue(tselftnametargstkwargstq((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_simple.pyR s  cO@s tƒ‚dS(N(tNotImplementedError(R R R((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_simple.pyR scC@s_|js[tddƒ|_|jjƒ}|jdƒWdQX|jddtƒ|_ndS(Nt transporttmemorys amq.directtno_ack( tabstractRt connectiontchanneltexchange_declareRtNonetTrueR(R R((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_simple.pytsetUps  cC@s*|js&|jjƒ|jjƒndS(N(RRtcloseR(R ((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_simple.pyttearDowns  cC@s‰|jr dS|jddtƒ}|jidd6ƒ|j|jddƒjidd6ƒ|j|jƒ|jddƒWdQXdS(Nttest_produce__consumeRtSimplethellottimeoutigš™™™™™¹?( RRRtputt assertEqualtgettpayloadt assertRaisestEmpty(R R((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_simple.pyR"s &cC@są|jr dS|jddtƒ}|jidd6ƒ|j|jƒjidd6ƒ|j|jƒ|jƒWdQX|jidd6ƒ|j|j dt ƒjidd6ƒ|j|jƒ|j dt ƒWdQXdS(Nttest_produce__basic_getRt SimpleSyncRtblock( RRRR!R"t get_nowaitR$R%R&R#tFalse(R R((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_simple.pyR'-s  &cC@sn|jr dS|jddtƒ}x/tdƒD]!}|jid|fd6ƒq/W|j|jƒdƒdS(Nt test_clearRi s SimplePurge%dR(RRRtrangeR!R"tclear(R Rti((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_simple.pyR,;s  cC@sY|jr dS|jdƒ}tƒ|_|j|jƒ|ƒ|jƒ|jjƒdS(Nttest_enter_exit(RRRRtassertIst __enter__t__exit__tassert_called_with(R R((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_simple.pyR0Es   cC@s„|jr dS|jddtƒ}x/tdƒD]!}|jid|fd6ƒq/W|j|jƒdƒ|jt|ƒdƒdS(NR,Ri s SimplePurge%dR(RRRR-R!R"tqsizetlen(R RR/((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_simple.pyt test_qsizeOs cC@sE|jr dS|jjƒ}|jddtd|ƒ}|jƒdS(Nttest_autocloseRR(RRRRRR(R RR((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_simple.pyR8Zs  cC@s||jr dS|jj}td|fƒ}td|f|dƒ}|j|ƒ}|j|jjd|ƒ|jƒdS(Ns%s-test.custom.Queuesmy.routing.keyi( RRR RRR"tconsumertqueuesR(R tntexchangetqueueR((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_simple.pyttest_custom_Queueas    cC@s-|jr dS|jdƒ}|j|ƒdS(Nt test_nonzero(RRt assertTrue(R R((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_simple.pyt test_boolns (R t __module__RRRR RRRR'R,R0R7R8R>RA(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_simple.pyRs       ttest_SimpleQueuecB@s eZeZd„Zd„ZRS(cO@s|jj||ŽS(N(Rt SimpleQueue(R R R((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_simple.pyR xscC@s#|jdƒ}|j|jƒdS(Nttest_is_no_ack(Rt assertFalseR(R R((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_simple.pyt test_is_ack{s(R RBR+RR RG(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_simple.pyRCus ttest_SimpleBuffercB@s eZeZd„Zd„ZRS(cO@s|jj||ŽS(N(Rt SimpleBuffer(R R R((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_simple.pyRƒscC@s#|jdƒ}|j|jƒdS(NRE(RR@R(R R((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_simple.pyRE†s(R RBR+RRRE(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_simple.pyRH€s N( t __future__RtkombuRRRtcaseRRRRCRH(((s9/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_simple.pyts m