๓ O'—^c@@sศddlmZyddlZWnek r9dZnXddlmZddlmZmZm Z m Z defd„ƒYZ de fd„ƒYZ d e fd „ƒYZ d e fd „ƒYZdS( i(tabsolute_importN(t librabbitmq(tCasetMocktSkipTesttpatchtlrmqCasecB@seZd„ZRS(cC@stdkrtdƒ‚ndS(Nslibrabbitmq is not installed(RtNoneR(tself((sH/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_librabbitmq.pytsetUps (t__name__t __module__R (((sH/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_librabbitmq.pyR st test_MessagecB@seZd„ZRS(cC@svtddƒ}tj|idd6idd6dƒ}|j|jdƒ|j|jdƒ|j|jddƒdS(Ntnametchanneli*tpropiQt delivery_tagtbody(RRtMessaget assertEqualRRt properties(Rtchantmessage((sH/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_librabbitmq.pyt test_inits  (R R R(((sH/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_librabbitmq.pyR st test_ChannelcB@seZd„ZRS(c C@s9tddƒ}tj|dƒ}|j|ƒd}idd6}|j|d|ddd d d d d idd6ƒ\}}|j|ddƒ|j|ddƒ|j|d d ƒ|j|d d ƒ|j|d idd6ƒ|j||ƒ|j|ddƒ\}}|j|ddƒ|j||ƒdS(NR t connectionisthe quick brown fox...s Elaine M.Rtpriorityi็t content_typetctypetcontent_encodingtcenctheadersitHi (RRtChannelt assertTruetprepare_messageR( RtconnRRRtbody2tprops2tbody3tprops3((sH/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_librabbitmq.pyttest_prepare_message"s(   (R R R)(((sH/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_librabbitmq.pyR sttest_TransportcB@skeZd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Z d„Z d „Z d „Z RS( cC@s>tt|ƒjƒtddƒ|_tj|jƒ|_dS(NR tclient(tsuperR*R RR+Rt TransporttT(R((sH/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_librabbitmq.pyR @scC@s|j|jjƒƒdS(N(R"R.tdriver_version(R((sH/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_librabbitmq.pyttest_driver_versionEscC@s?tddƒ}|jj|ƒ}|j|ƒ|jjƒdS(NR R(RR.tcreate_channelR"Rtassert_called_with(RR$R((sH/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_librabbitmq.pyttest_create_channelHs cC@s<tddƒ}|jj|ddƒ|jjddƒdS(NR RttimeoutgHแzฎG๕?(RR.t drain_eventsR2(RR$((sH/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_librabbitmq.pyttest_drain_eventsNscC@s3t|j_|jtƒ|jjƒWdQXdS(N(tTrueR+tsslt assertRaisestNotImplementedErrorR.testablish_connection(R((sH/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_librabbitmq.pyt+test_establish_connection_SSL_not_supportedSs cC@sญtddƒ|j_t|jj_d|jj_i|jj_|jj ƒ}|j |jjj|jj dƒ|j |j|jjƒ|j |jjj |j ƒdS(NR t Connectiontport( RR.R=tFalseR+R8RR>ttransport_optionsR;Rtdefault_connection_paramsR5(RR$((sH/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_librabbitmq.pyttest_establish_connectionXs cC@sId|jj_|jjdƒ|j|jjƒ|j|jjƒdS(Niา(R.R+R5t_collectRt assertIsNone(R((sH/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_librabbitmq.pyttest_collect__no_connfscC@sŸd|jj_tddƒ}itddƒd6tddƒd6}|_itddƒd 6tdd ƒd 6|_x,t|jjƒƒD]\}}||_qŠWt d ƒ*}|jj |ƒ|j |j ƒƒWdQX|j |jƒ|j |jƒx$|jƒD]}|j|jƒqW|j|jjƒ|j|jjƒt d ƒE}|j|j_tƒ|_|jj |ƒ|j |j ƒƒWdQXdS( NiาR Rtchan1itchan2itcb1tfootcb2tbarsos.close(R.R+R5Rtchannelst callbackst enumeratetvaluesRRRCR2tfilenot assertFalseRDtOSErrort side_effect(RR$tchanstiRtclose((sH/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_librabbitmq.pyttest_collect__with_connls(-)"  cC@sZtddƒ}tddƒ}|jj||ƒ|jj|jƒ|jj||ƒdS(NR R$tloop(RR.tregister_with_event_loopt add_readerR2RPt on_readable(RR$RX((sH/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_librabbitmq.pyttest_register_with_event_loop„s  cC@s5tddƒ}t|_|j|jj|ƒƒdS(NR R(RR7t connectedR"R.tverify_connection(RR$((sH/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_librabbitmq.pyttest_verify_connectionŒs cC@sOtddƒ}d|j_|jj|ƒ|j|jjƒ|jjƒdS(NR Riา(RR+R5R.tclose_connectionRDRVR2(RR$((sH/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_librabbitmq.pyttest_close_connection‘s  ( R R R R0R3R6R<RBRERWR\R_Ra(((sH/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_librabbitmq.pyR*>s          (t __future__RRt ImportErrorRtkombu.transporttkombu.tests.caseRRRRRR RR*(((sH/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_librabbitmq.pyts  "