σ O'—^c@@s ddlmZddlZddlmZyddlZWnek rUdZnXddl mZddl m Z ddl m Z ddlmZmZmZmZmZdefd „ƒYZd efd „ƒYZd efd „ƒYZdefd„ƒYZdS(i(tabsolute_importN(tcount(tpyamqp(t Connection(tnextfun(tCasetMocktSkipTestt mask_modulestpatchtMockConnectioncB@seZd„ZRS(cC@s|||eZd„Zd„Zd„Zd„Zd„Zd„ZRS(cC@s€tdkrtdƒ‚ndtjfd„ƒY}tƒ|_ttdƒƒ|jj_ i|j_ ||jdƒ|_ dS(Nspy-amqp not installedtChannelcB@s)eZgZd„Zd„Zd„ZRS(c_@sdS(N((R targstkwargs((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyt_x_open"sc_@s|jS(N(t wait_returns(R RR((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pytwait%sc_@sdS(N((R RR((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyt _send_method(s(RRRRRR(((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyRs  i( RtNoneRRRtconnRRt_get_free_channel_idt side_effecttchannelstchannel(R R((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pytsetUps   cC@s|j|jjƒdS(N(t assertFalseRtno_ack_consumers(R ((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyt test_init0scC@s,|j|jjdddddiƒƒdS(Ntfoobari sapplication/datasutf-8t properties(t assertTrueRtprepare_message(R ((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyttest_prepare_message3scC@s8tƒ}i|_i|_|j|jj|ƒƒdS(N(RtheadersR$R%Rtmessage_to_python(R tmessage((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyttest_message_to_python9s   cC@s7|j|jjƒ|jjƒ|j|jjƒdS(N(tassertIsNotNoneRt connectiontcloset assertIsNone(R ((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyt$test_close_resolves_connection_cycle?s cC@sšd|j_|jjddtƒ|jd|jjƒd|j_|jjddtƒ|jd|jjƒ|jjdƒ|jd|jjƒdS(Nsmy-consumer-tagtfootno_acksother-consumer-tagtbar( RRt basic_consumetTruetassertInR!tFalset assertNotInt basic_cancel(R ((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyt'test_basic_consume_registers_ack_statusDs  (RRRR"R'R+R0R:(((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyRs      ttest_TransportcB@sSeZd„Zd„Zd„Zd„Zd„Zd„Zedƒd„ƒZ RS(cC@s=tdkrtdƒ‚ntdƒ|_|jj|_dS(Nspy-amqp not installeds pyamqp://(RRRRR-t transport(R ((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyRSs cC@s*tƒ}|jj|ƒ|jjƒdS(N(RR<tcreate_channelRtassert_called_with(R R-((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyttest_create_channelYs cC@s|j|jjƒƒdS(N(R%R<tdriver_version(R ((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyttest_driver_version^scC@s6tƒ}|jj|ddƒ|jjddƒdS(Nttimeoutg$@(RR<t drain_eventsR>(R R-((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyttest_drain_eventsas cC@sˆdtfd„ƒY}||j_d|jj_|jjƒ}|j|jdƒd|jj_|jjƒ}|j|jdƒdS(NtConncB@seZd„ZRS(c[@st|ƒj|ƒdS(N(tvarstupdate(R R((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyt__init__js(RRRH(((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyREhst localhosts127.0.0.1:5672s example.comsexample.com:5672(tobjectR<Rtclientthostnametestablish_connectiont assertEqualthost(R REtconn1tconn2((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyt$test_dnspython_localhost_resolve_bugfs cC@sFtƒ}tƒ|_|jj|ƒ|j|jƒ|jjƒdS(N(RRKR<tclose_connectionR/R.R>(R R-((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyttest_close_connectionvs   tsslcC@s]tjjdƒ}z'ddlm}|j|jdƒWd|dk rX|tjdeZd„Zd„Zd„Zd„Zd„Zd„ZRS(cC@stdkrtdƒ‚ndS(Nspy-amqp not installed(RRR(R ((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyR‹s cC@sVdtjfd„ƒY}tddd|ƒjƒ}|j|dd|jfƒdS(Nt TransportcB@seZeZRS((RRR R(((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyR^‘stportR<ROs 127.0.0.1:%s(RR^RRtconnectRNt default_port(R R^tc((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyttest_default_ports cC@sLdtjfd„ƒY}tddd|ƒjƒ}|j|ddƒdS(NR^cB@seZeZRS((RRR R(((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyR^šsR_i9R<ROs127.0.0.1:1337(RR^RR`RN(R R^Rb((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyttest_custom_port˜scC@sctjtƒƒ}tddƒ}tddƒ}|j||ƒ|jj|j|j||ƒdS(NtnameRtloop(RR^Rtregister_with_event_loopt add_readerR>tsockt on_readable(R ttRRf((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyttest_register_with_event_loop s  cC@sEtjtƒƒ}tƒ}|j|ddƒ|jjddƒdS(Ntrategmηϋ©ρR@(RR^Rtheartbeat_checktheartbeat_tickR>(R RkR((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyttest_heartbeat_check©s c C@sWtdƒE}tjtƒƒ}|jdddƒ|j|jdddƒWdQXdS(Ns"kombu.transport.pyamqp.get_manageritkwi(R RR^Rt get_managerR>RK(R RrRk((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyttest_get_manager―s(RRRRcRdRlRpRs(((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyR]‰s    (t __future__RRWt itertoolsRtamqpt ImportErrorRRtkombu.transporttkombuRt kombu.fiveRtkombu.tests.caseRRRRR tdictR RR;R](((sC/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_pyamqp.pyts   (88