σ O'—^c@@sζddlmZddlmZmZmZmZmZddlm Z ddl m Z ddl m Z mZmZddlmZmZdefd„ƒYZd efd „ƒYZd efd „ƒYZd efd„ƒYZdS(i(tabsolute_import(t ConnectiontConsumertExchangetProducertQueue(ttext_t(tMessage(t StdChannelt Transportt Management(tCasetMockttest_StdChannelcB@s5eZd„Zd„Zd„Zd„Zd„ZRS(cC@sHtdƒ|_|jjƒ|_|jjjƒ|jjjjƒdS(Ns memory://(Rtconntchanneltqueuestcleart connectiontstate(tself((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pytsetUp scC@s\tdtdƒƒ}|jjGH|jj|ƒ}|j|tƒ|j|j|jƒdS(Ntfoo(RRRRRtassertIsInstancetassertIs(Rtqtcons((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pyt test_Consumers  cC@s9|jjƒ}|j|tƒ|j|j|jƒdS(N(RRRR(Rtprod((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pyt test_ProducerscC@s'|jtƒtƒjƒWdQXdS(N(t assertRaisestNotImplementedErrorRt get_bindings(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pyttest_interface_get_bindingsscC@s#|jtƒjtdƒƒƒdS(NR(t assertIsNoneRtafter_reply_message_receivedR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pyt+test_interface_after_reply_message_received#s(t__name__t __module__RRRR!R$(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pyR s     t test_MessagecB@sYeZd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Z d„Z RS( cC@s=tdƒ|_|jjƒ|_t|jddƒ|_dS(Ns memory://t delivery_tagi9(RRRRtmessage(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pyR+scC@sLt|jtdƒddƒ}|jtƒ|jƒWdQX|jƒdS(NtFOOt postencodetccyzz(RRRRt LookupErrort_reraise_errortack(Rtm((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pyttest_postencode0scC@sotdgƒ|j_d|jjdR((RR/((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pyttest_ack_not_no_ackGs  cC@s7tƒ}|j_|jjtƒtƒ|jƒdS(N(R R)R/t ack_log_errortKeyErrorR>(RR/((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pyt test_ack_log_error_when_no_errorOscC@s}tƒ}|j_tdƒ|_tƒ}|jj|tƒ|jƒ|j|jj ƒ|j d|jj ddƒdS(NRs Couldn't acki( R R)R/RBt side_effectRAR>t assertTruetcriticalR<tassertInt call_args(RR/tlogger((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pyttest_ack_log_error_when_errorTs  cC@sCtƒ}|j_|jjtƒtdtƒ|jdtƒdS(Ntrequeue(R R)trejecttreject_log_errorRBtTrueR>(RRL((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pyt#test_reject_log_error_when_no_error]scC@sƒtƒ}|j_tdƒ|_tƒ}|jj|tƒ|jdtƒ|j|j j ƒ|j d|j j ddƒdS(NRRKsCouldn't rejecti( R R)RLRBRDRMR>tFalseRERFR<RGRH(RRLRI((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pyt test_reject_log_error_when_errorbs ( R%R&RR1R=R?R@RCRJRORQ(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pyR')s      ttest_interfacecB@sYeZd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Z d„Z RS( cC@s*|jtƒtdƒjƒWdQXdS(N(RRR tNonetestablish_connection(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pyttest_establish_connectionnscC@s-|jtƒtdƒjdƒWdQXdS(N(RRR RStclose_connection(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pyttest_close_connectionrscC@s-|jtƒtdƒjdƒWdQXdS(N(RRR RStcreate_channel(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pyttest_create_channelvscC@s-|jtƒtdƒjdƒWdQXdS(N(RRR RSt close_channel(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pyttest_close_channelzscC@s-|jtƒtdƒjdƒWdQXdS(N(RRR RSt drain_events(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pyttest_drain_events~scC@s tdƒjtddƒƒdS(NtnameR(R RStheartbeat_checkR (R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pyttest_heartbeat_check‚scC@s|jtdƒjƒƒdS(N(RER RStdriver_version(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pyttest_driver_version…scC@s tdƒjtddƒƒdS(NR^tloop(R RStregister_with_event_loopR (R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pyttest_register_with_event_loopˆscC@s|jtdƒjƒdS(N(RER RStmanager(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pyt test_manager‹s( R%R&RURWRYR[R]R`RbReRg(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pyRRls        ttest_ManagementcB@seZd„ZRS(cC@s9ttddƒƒ}|jtƒ|jƒWdQXdS(NR^t transport(R R RRR (RR0((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pyttest_get_bindings‘s(R%R&Rj(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pyRhsN(t __future__RtkombuRRRRRt kombu.fiveRt kombu.messageRtkombu.transport.baseRR R tkombu.tests.caseR R R R'RRRh(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_base.pyts(C#