σ O'—^c@@sddlmZddlZddlmZddlmZmZmZm Z de fd„ƒYZ ye dƒWne k rdZZn*XddlmZd ejfd „ƒYZd efd „ƒYZd efd„ƒYZdefd„ƒYZdefd„ƒYZdS(i(tabsolute_importN(t Connection(tCasetSkipTesttMockt mask_modulestMockConnectioncB@seZd„ZRS(cC@s|||eZd„Zd„Zd„Zd„Zd„Zd„ZRS(cC@s1tƒ|_i|j_t|jdƒ|_dS(Ni(RtconntchannelsRtchannel(R((sD/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_amqplib.pyR0s  cC@s|j|jjƒdS(N(t assertFalseRtno_ack_consumers(R((sD/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_amqplib.pyt test_init5scC@s,|j|jjdddddiƒƒdS(Ntfoobari sapplication/datasutf-8t properties(t assertTrueRtprepare_message(R((sD/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_amqplib.pyttest_prepare_message8scC@s8tƒ}i|_i|_|j|jj|ƒƒdS(N(RtheadersR!R"Rtmessage_to_python(Rtmessage((sD/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_amqplib.pyttest_message_to_python>s   cC@s7|j|jjƒ|jjƒ|j|jjƒdS(N(tassertIsNotNoneRt connectiontcloset assertIsNone(R((sD/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_amqplib.pyt$test_close_resolves_connection_cycleDs cC@sšd|j_|jjddtƒ|jd|jjƒd|j_|jjddtƒ|jd|jjƒ|jjdƒ|jd|jjƒdS(Nsmy-consumer-tagtfootno_acksother-consumer-tagtbar( RRt basic_consumetTruetassertInRtFalset assertNotInt basic_cancel(R((sD/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_amqplib.pyt'test_basic_consume_registers_ack_statusIs  (R R RRR$R(R-R7(((sD/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_amqplib.pyR.s      ttest_TransportcB@sSeZd„Zd„Zd„Zd„Zd„Zd„Zedƒd„ƒZ RS(cC@s"tdƒ|_|jj|_dS(Ns amqplib://(RR*t transport(R((sD/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_amqplib.pyRXscC@s*tƒ}|jj|ƒ|jjƒdS(N(RR9tcreate_channelRtassert_called_with(RR*((sD/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_amqplib.pyttest_create_channel\s cC@s6tƒ}|jj|ddƒ|jjddƒdS(Nttimeoutg$@(RR9t drain_eventsR;(RR*((sD/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_amqplib.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(RR((sD/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_amqplib.pyt__init__js(R R RC(((sD/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_amqplib.pyR@hst localhosts127.0.0.1:5672s example.comsexample.com:5672(tobjectR9Rtclientthostnametestablish_connectiont assertEqualthost(RR@tconn1tconn2((sD/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_amqplib.pyt$test_dnspython_localhost_resolve_bugfs cC@sFtƒ}tƒ|_|jj|ƒ|j|jƒ|jjƒdS(N(RRFR9tclose_connectionR,R+R;(RR*((sD/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_amqplib.pyttest_close_connectionvs   cC@s_tƒ}d|_|j|jj|ƒƒidd6dd6|_|j|jj|ƒƒdS(Nii(RRRRR9tverify_connectionR"(RR*((sD/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_amqplib.pyttest_verify_connection~s   tsslcC@s]tjjdƒ}z'ddlm}|j|jdƒWd|dk rX|tjds "   (;