ó O'—^c@@s€ddlmZddlZddlZddlmZmZmZmZm Z ddl m Z m Z de fd„ƒYZ dS(i(tabsolute_importN(t ConnectiontExchangetQueuetConsumertProducer(tCasetSkipTestttest_FilesystemTransportcB@s#eZd„Zd„Zd„ZRS(cC@sõtjdkrtdƒ‚nytjƒ}tjƒ}Wntk rYtdƒ‚nXtdddi|d6|d6ƒ|_tdddi|d6|d6ƒ|_t d ƒ|_ t d d |j d d ƒ|_ t d d |j d d ƒ|_ dS( Ntwin32sNeeds win32con modules-filesystem transport: cannot create tempfilest transportt filesystemttransport_optionstdata_folder_intdata_folder_outttest_transport_filesystemtexchanget routing_keyttest_transport_filesystem2(tsystplatformRttempfiletmkdtempt ExceptionRtctpRteRtqtq2(tselfR R((sG/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_filesystem.pytsetUp s,         c@sÝt|jjƒ|jƒ}t|jjƒ|jdtƒ}x.tdƒD] }|j i|d6ddƒqIWg‰‡fd†}|j |ƒ|j ƒx't ˆƒdkr²Pn|jj ƒqœW|jt ˆƒdƒdS(Ntno_acki tfooRRc@sˆj|ƒdS(N(tappend(t message_datatmessage(t _received(sG/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_filesystem.pytcallback1s(RRtchannelRRRRtTruetrangetpublishtregister_callbacktconsumetlent drain_eventst assertEqual(RtproducertconsumertiR%((R$sG/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_filesystem.pyttest_produce_consume_noack's!   c @sÓ|jjƒ}|jjƒ}t||jƒ}t||jƒ}t||jƒ}|j|ƒjƒx.t dƒD] }|j i|d6ddƒqtWx.t dƒD] }|j i|d6ddƒq¥Wg‰g‰‡fd†}‡fd†}|j |ƒ|j |ƒ|j ƒ|j ƒx1t ˆƒt ˆƒdkrDPn|jjƒq$W|jt ˆƒt ˆƒdƒ|j itd 6ddd d ƒ|j|ƒjƒ} |j| jitd 6ƒx.t dƒD] }|j i|d6ddƒqÑW|j|j|ƒjƒƒ|j|ƒjƒ|j|ƒjƒ|j|j|ƒjƒƒx.t dƒD] }|j i|d6ddƒq`W|j|j|ƒjƒƒ|j|ƒjƒ|j|j|ƒjƒƒdS( Ni R RRRc@sˆj|ƒ|jƒdS(N(R!tack(R"R#(t _received1(sG/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_filesystem.pyt callback1Ps c@sˆj|ƒ|jƒdS(N(R!R3(R"R#(t _received2(sG/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_filesystem.pyt callback2Ts it compressedt compressiontzlib(RR&RRRRRRtdeclareR(R)R*R+R,R-R.R'tgettassertDictEqualtpayloadt assertTruetdeletet assertIsNonetpurge( Rtproducer_channeltconsumer_channelR/t consumer1t consumer2R1R5R7tm((R4R6sG/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_filesystem.pyttest_produce_consume>sV         (t__name__t __module__RR2RH(((sG/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_filesystem.pyR s  (t __future__RRRtkombuRRRRRtkombu.tests.caseRRR(((sG/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_filesystem.pyts   (