σ O'—^c@@sΘddlmZddlmZddlmZddlmZmZddl m Z defd„ƒYZ de fd „ƒYZ d e fd „ƒYZ d e fd „ƒYZde fd„ƒYZdS(i(tabsolute_import(t Connection(texchange(tCasetMock(t Transportt ExchangeCasecB@seZdZd„ZRS(cC@s1|jr-|jtdtƒjƒƒ|_ndS(Nt transport(ttypeRRtchannelte(tself((sM/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_exchange.pytsetUp s N(t__name__t __module__tNoneRR (((sM/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_exchange.pyR st test_DirectcB@s,eZejZd d d d gZd„ZRS( trFootqFootqFoxtrBartqBartrBaztqBazcC@s…|j|jj|jdddƒddgƒ|j|jj|jdddƒgƒ|j|jj|jdd dƒd gƒdS( NteFooRRRteMoztrMoztDEFAULTteBarRR(tassertListEqualR tlookupttableR(R ((sM/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_exchange.pyt test_lookups N(RNR(RNR(RNR(RNR(R RRtDirectExchangeRRRR (((sM/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_exchange.pyRs   t test_FanoutcB@s;eZejZddd gZd„Zd„Zd„Z RS( RRRcC@s5|j|jj|jdddƒdddgƒdS(NRRRRR(RR RRR(R ((sM/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_exchange.pyR .scC@s]tƒ|j_t|jj_tƒ}|jj|ddƒ|jjjjd|dƒdS(NRtrkey(RR R tTruetsupports_fanouttdelivert _put_fanouttassert_called_with(R tmessage((sM/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_exchange.pyt"test_deliver_when_fanout_supported4s  cC@sTtƒ|j_t|jj_|jjtƒddƒ|j|jjjj ƒdS(NR( RR R tFalseR%R&Rt assertFalseR'tcalled(R ((sM/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_exchange.pyt$test_deliver_when_fanout_unsupported>sN(NNR(NNR(NNR( R RRtFanoutExchangeRRRR R*R.(((sM/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_exchange.pyR"(s    t test_TopiccB@sAeZejZd d gZd„Zd„Zd„Z d„Z RS( sstock.#Rs stock.us.*RcC@sTtt|ƒjƒg|jD]*\}}}||jj|ƒ|f^q|_dS(N(tsuperR0R RR tkey_to_pattern(R R#t_tqueue((sM/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_exchange.pyR MscC@s/|jjdddiƒ}|j|dƒdS(NRRsstock.#s ^stock\..*?$(sstock.#s ^stock\..*?$R(R t prepare_bindtassertTupleEqual(R tx((sM/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_exchange.pyttest_prepare_bindRscC@sΐ|j|jj|jdddƒddgƒ|j|jjƒ|j|jj|jdddƒdgƒ|j|jj|jdddƒgƒ|j|jj|jdddƒgƒdS(NRsstock.us.nasdaqRRsstock.europe.OSEtstockxeuropexOSEs candy.schleckpulver.snap_crackle(RR RRRt assertTruet _compiled(R ((sM/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_exchange.pyR Vs   cC@s„tƒ|j_d|jjj_tƒ}|jj|ddƒd|fifd|fifg}|j|jjjj|ƒdS(NtatbRR#(R<R=( RR R t_lookupt return_valueR&Rt_puttcall_args_list(R R)texpected((sM/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_exchange.pyt test_deliverjs N(sstock.#NR(s stock.us.*NR( R RRt TopicExchangeRRRR R8R RC(((sM/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_exchange.pyR0Fs     ttest_ExchangeTypecB@s,eZejZd„Zd„Zd„ZRS(c C@s3|jtƒ|jjgdddƒWdQXdS(NRR(t assertRaisestNotImplementedErrorR RR(R ((sM/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_exchange.pyR xscC@s)|j|jjdddiƒdƒdS(NRRR(RNR(R6R R5R(R ((sM/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_exchange.pyR8|sc C@sktdddtdtdiƒ}|j|jj|ddttiƒƒ|j|jj|ddttiƒƒ|j|jj|ddttiƒƒ|j|jj|ddttiƒƒ|j|jj|ddttidd 6ƒƒt|didd 6ƒ}|j|jj|ddttidd 6ƒƒ|j|jj|ddttid d 6ƒƒdS( NRtdirecttdurablet auto_deletet argumentsRttopiciΈ texpiresip(tdictR$R:R t equivalentR,R+(R te1te2((sM/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_exchange.pyttest_equivalent‚s. """"(R RRt ExchangeTypeRR R8RR(((sM/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_exchange.pyREus   N(t __future__RtkombuRtkombu.transport.virtualRtkombu.tests.caseRRtkombu.tests.mocksRRRR"R0RE(((sM/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/virtual/test_exchange.pyts/