O'^c@@sddlmZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z ddl m Z ddlmZddlmZmZmZmZddlmZmZmZmZmZmZmZmZdd lmZdd l m!Z!m"Z"m#Z#m$Z$dd l m%Z%dd l&m'Z'd Z(dZ)de*fdYZ+de,fdYZ-de,fdYZ.e$e#de!fdYZ/e$e#de!fdYZ0e$e#de!fdYZ1e$e#de!fdYZ2e$e#de!fdYZ3e$e#de!fd YZ4e$e#d!e!fd"YZ5e$e#d#e+e5fd$YZ6e$e#d%e5fd&YZ7e$e#d'e5fd(YZ8e$e#d)e5fd*YZ9e$e#d+e5fd,YZ:e$e#d-e!fd.YZ;e$e#d/e;fd0YZ<e$e#d1e;fd2YZ=e$e#d3e;fd4YZ>e$e#d5e;fd6YZ?e$e#d7e;fd8YZ@e$e#d9e;fd:YZAe$e#d;e;fd<YZBe$e#d=e;e+fd>YZCe$e#d?e;e+fd@YZDe$e#dAe;fdBYZEe$e#dCe+e!fdDYZFe$e#e)dEe!fdFYZGe$e#e)dGe!fdHYZHe$e#e)dIe!fdJYZIe$e#e)dKe!fdLYZJe$e#dMe!fdNYZKe$e#e)dOe!fdPYZLe$e#e)dQe!fdRYZMe$e#e)dSe!fdTYZNe$e#e)dUe!fdVYZOe$e#e)dWe!fdXYZPe$e#e)dYe+e!fdZYZQdS([i(tabsolute_importN(tCallable(tcount(twraps(tcall(tEmptytkeystranget monotonic(tAuthenticationFailuretChannelt ConnectiontConnectionErrortMessagetNotFoundtQoSt Transport(tBase64(tCasetMockt case_no_pypytcase_no_python3(tpatch(t OrderedDictskombu.transport.qpidc@st|j|jttdtfd}tfd}||_||_|S(s2A decorator to disable runtime dependency checkings.dependency_is_nonec@s#j}t|_|dS(N(tstarttFalset return_value(tselftmock_dependency_is_none(tdependency_is_none_patchertsetup(sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt around_setup#s  c@sj|dS(N(tstop(R(Rtteardown(sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pytaround_teardown)s (tsetUpttearDownRt QPID_MODULER(tclsRR"((RRR!sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt disable_runtime_dependency_checks    tExtraAssertionsMixincB@s&eZdZddZddZRS(sAA mixin class adding assertDictEqual and assertDictContainsSubsetcC@s[|jtt|tt|x,t|D]}|j||||q5WdS(s9 Test that two dictionaries are equal. Implemented here because this method was not available until Python 2.6. This asserts that the unique set of keys are the same in a and b. Also asserts that the value of each key is the same in a and b using the is operator. N(t assertEqualtsetR(Rtatbtmsgtkey((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pytassertDictEqual6s (cC@sCx<t|D].}|j|||j||||q WdS(sF Assert that all the key/value pairs in a exist in b. N(RtassertInR)(RR+R,R-R.((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pytassertDictContainsSubsetCsN(t__name__t __module__t__doc__tNoneR/R1(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR(3s t QpidExceptioncB@seZdZdddZRS(sQ An object used to mock Exceptions provided by qpid.messaging.exceptions cC@s,tt|j|||_||_dS(N(tsupert Exceptiont__init__tcodettext(RR:R;((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR9Qs N(R2R3R4R5R9(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR6LstBreakOutExceptioncB@seZRS((R2R3(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR<WstTestQoS__init__cB@s,eZdZdZdZdZRS(cC@s"t|_t|j|_dS(N(Rt mock_sessionRtqos(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR#_s cC@s|j|jjddS(Ni(R)R?tprefetch_count(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt?test__init__prefetch_default_set_correct_without_prefetch_valuecscC@s&t|j}|j|jddS(Ni(RR>R)R@(Rt qos_limit_two((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt'test__init__prefetch_is_hard_set_to_onefscC@s|j|jjtdS(N(tassertIsInstanceR?t_not_yet_ackedR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt)test__init___not_yet_acked_is_initializedjs(R2R3R#RARCRF(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR=[s   tTestQoSCanConsumecB@s,eZdZdZdZdZRS(cC@st}t||_dS(N(RRR?(Rtsession((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR#rs cC@s2d|j_g|j_|j|jjdS(Ni(R?R@REt assertTruet can_consume(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt%test_True_when_prefetch_limit_is_zerovs  cC@s8d|j_ddg|j_|j|jjdS(NiR+R,(R?R@RERIRJ(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt9test_True_when_len_of__not_yet_acked_is_lt_prefetch_count{s cC@s;d|j_dddg|j_|j|jjdS(NiR+R,tc(R?R@REt assertFalseRJ(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt:test_False_when_len_of__not_yet_acked_is_eq_prefetch_counts (R2R3R#RKRLRO(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyRGns   tTestQoSCanConsumeMaxEstimatecB@s#eZdZdZdZRS(cC@s"t|_t|j|_dS(N(RR>RR?(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR#s cC@s)d|j_|j|jjddS(Nii(R?R@R)tcan_consume_max_estimate(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt+test_return_one_when_prefetch_count_eq_zeros cC@s;ddg|j_d|j_|j|jjddS(NR+R,ii(R?RER@R)RQ(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt1test_return_prefetch_count_sub_len__not_yet_ackeds (R2R3R#RRRS(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyRPs  t TestQoSAckcB@s#eZdZdZdZRS(cC@s"t|_t|j|_dS(N(RR>RR?(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR#s cC@s\t}|jj|d|jd|jj|jjd|jd|jjdS(Ni(RR?tappendR0REtackt assertNotIn(Rtmessage((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_ack_pops__not_yet_ackeds  cC@sIt}|jj|d|jjd|jjjjd|dS(NiRX(RR?RURVRHt acknowledgetassert_called_with(RRX((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt/test_ack_calls_session_acknowledge_with_messages (R2R3R#RYR\(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyRTs  t TestQoSRejectcB@s5eZdZdZdZdZdZRS(cC@st|_t|_t|j|_ttd|_|jj|_ |j j j |_ |j j j |_|j j j|_dS(Ns.qpid(RR>t mock_messageRR?RR%t patch_qpidRt mock_qpidt messagingt Dispositiontmock_DispositiontRELEASEDt mock_RELEASEDtREJECTEDt mock_REJECTED(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR#s  cC@s|jjdS(N(R_R (R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR$scC@sV|jj|jd|jd|jj|jjd|jd|jjdS(Ni(R?RUR^R0REtrejectRW(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_reject_pops__not_yet_ackedscC@sk|jj|jd|jjddt|jj|j|jjj jd|jd|jj dS(NitrequeueRXt disposition( R?RUR^RhtTrueRcR[ReRHRZR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_reject_requeue_trues  cC@snt}|jj|d|jjddt|jj|j|jjj jd|d|jj dS(NiRjRXRk( RR?RURhRRcR[RgRHRZR(RRX((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_reject_requeue_falses  (R2R3R#R$RiRmRn(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR]s    tTestQoScB@s>eZdZdZdZdZdZdZRS(cC@s&|jj}d|f}||fS(s6Create and return a mock message tag and delivery_tag.s message %s(tdelivery_tag_generatortnext(Rtm_delivery_tagtm((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pytmock_message_factorys cC@s(x!t|D]}|j|q WdS(s1Add N mock messages into the passed in qos objectN(Rtadd_message_to_qos(RtnR?ti((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pytadd_n_messages_to_qosscC@s&|j\}}|j||dS(sAdd a single mock message into the passed in qos object. Uses the mock_message_factory() to create the message and delivery_tag. N(RtRU(RR?RsRr((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyRuscC@sIt|_t|j|_t|jdd|_td|_dS(NR@ii(RR>Rt qos_no_limitt qos_limit_2RRp(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR#s c C@s|j}|j\}}|j\}}|j||t|j}|j|d|j|}|j|||j||t|j}|j|d|j|}|j||dS(sAppend two messages and check inside the QoS object that they were put into the internal data structures correctly iiN(RyRtRUtlenRER)tassertIs( RR?tm1tm1_tagtm2tm2_tagtlength_not_yet_ackedtchecked_message1tchecked_message2((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt test_appends   cC@s|j}|j\}}|j\}}|j|||j|||j|}|j|}|j|||j||dS(s0Append two messages, and use get to receive themN(RyRtRUtgetR|(RR?R}R~RRtmessage1tmessage2((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_gets (R2R3RtRxRuR#RR(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyRos     tConnectionTestBasecB@s!eZeeddZRS(s.qpidcC@sQidd6dd6dd6dd6d d 6|_|jj|_t|j|_dS( Nt localhostthosti(tportttcpt transporti ttimeoutt ANONYMOUStsasl_mechanisms(tconnection_optionsRaR tmock_qpid_connectiontconn(RR`((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR#s (R2R3RR%R#(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyRstTestConnectionInitcB@seZdZdZdZdZeeddefeedeeddZ eeddefeedeedd Z eeddefeedeedd Z eeddefeedeedd Z ej ed defeedeedded ZeedeeddedZRS(cC@s#|j}|j||jjdS(N(RR/R(Rtmodified_conn_opts((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_stores_connection_options*s cC@s0|j|jjt|j|jjtdS(N(RDRtchannelstlistt _callbackstdict(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_class_variables2scC@s |j}|jjj|dS(N(RRt establishR[(RR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_establishes_connection6s  cC@s)|jjj}|j|jj|dS(N(RRRR|Rt _qpid_conn(Rt created_conn((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt!test_saves_established_connection<ss.ConnectionErrortnews .sys.exc_infos.qpidcC@sd}td|}||jjj_d|_yt|j|_WnTt k r}t j }|j |t|j |dd|j|dnX|jddS( Ns-connection-forced: Authentication failed(320)R;R+R,iis.ConnectionError type was not mutated correctly(R+R,N(R6RaR Rt side_effectR5RRRR tsystexc_infotassertNotIsInstanceR|t assertIsNonetfail(RR`t mock_exc_infoR;t my_conn_errorterrorR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt!test_mutates_ConnError_by_message@s  cC@stdddd}||jjj_d |_yt|j|_WnTt k r}t j }|j |t|j |dd|j|dnX|jd dS( NR:i@R;t someothertextR+R,iis.ConnectionError type was not mutated correctly(R+R,N(R6RaR RRR5RRRR RRRR|RR(RR`RRRR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_mutates_ConnError_by_codeRs  cC@st}d|_||jjj_d|_yt|j|_ Wndt k r}t j }|j t|t |j |ddk|j |ddknX|jddS( s Test for PLAIN connection via python-saslwrapper, sans cyrus-sasl-plain This test is specific for what is returned when we attempt to connect with PLAIN mech and python-saslwrapper is installed, but cyrus-sasl-plain is not installed. s@Error in sasl_client_start (-4) SASL(-4): no mechanism availableR+R,iis.ConnectionError type was not mutated correctlyN(R+R,N(R6R;RaR RRR5RRRR RRRIt isinstanceR(RR`RRRR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt4test_connection__init__mutates_ConnError_by_message2cs    cC@stdddd}||jjj_d|_yt|j|_Wn)t k rq}|j |j dknX|j ddS( NR:iR;RR+R,s*Connection should have thrown an exception(R+R,N( R6RaR RRR5RRRR8RIR:R(RR`RRR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_unknown_connection_error~s tchannel_errorscC@sQ|jj}t}d|_||j_|jtt|jWdQXdS(Ns#some non auth related error message(RaR t SyntaxErrorR;RRt assertRaisesR(RR`tmock_Qpid_ConnectionR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_non_qpid_error_raisess     cC@sQ|jj}t}d|_||j_|jtt|jWdQXdS(Ns#some non auth related error message(RaR tIOErrorR;RRRR(RR`RR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_non_auth_conn_error_raisess     (R2R3RRRRRR%R6RRRRtobjectRRRR(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR&s*         % tTestConnectionClassAttributescB@seZdZRS(cC@s|jttjdS(N(R)R R (R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt'test_connection_verify_class_attributess(R2R3R(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyRstTestConnectionGetQpidConnectioncB@seZdZRS(cC@s8t|j_|jj}|j|jj|dS(N(RRRtget_qpid_connectionR|(Rtreturned_connection((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt#test_connection_get_qpid_connections(R2R3R(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyRstTestConnectionClosecB@seZdZRS(cC@s3t|j_|jj|jjjjdS(N(RRRtclosetassert_called_once_with(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_connection_closes (R2R3R(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyRstTestConnectionCloseChannelcB@s,eZdZdZdZdZRS(cC@s&tt|jt|j_dS(N(R7RR#RRR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR#scC@s3t}|jj||jjjj|dS(N(RRt close_channelRtremoveR(Rt mock_channel((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt?test_connection_close_channel_removes_channel_from_channel_lists cC@s2tdt|jj_|jjtdS(NR(Rt ValueErrorRRRR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt=test_connection_close_channel_handles_ValueError_being_raisedscC@sQt}t|_tdt|jj_|jj||j|jdS(NR( RRt connectionRRRRRR(RR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt<test_connection_close_channel_set_channel_connection_to_Nones   (R2R3R#RRR(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyRs   tChannelTestBasecB@seZdZdZRS(cC@shttd|_|jj|_|jj|_t|_t|_ t |j|j |_ dS(Ns .qpidtoollibs( RR%tpatch_qpidtoollibsRtmock_qpidtoollibst BrokerAgenttmock_broker_agentRRRR tchannel(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR#s   cC@s|jjdS(N(RR (R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR$s(R2R3R#R$(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyRs tTestChannelPurgecB@sTeZdZdZdZdZdZeedde dZ RS(cC@s#tt|jt|_dS(N(R7RR#Rt mock_queue(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR#scC@s6|jj|j|jjj}|j|jdS(N(Rt_purgeRRRtgetQueueR(RR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_gets_queuescC@sRidd6}|jjjj}||_|jj|j|j|jj dS(NitmsgDepth( RRRtvaluesRRRRNtpurgetcalled(RRt queue_obj((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt1test_does_not_call_purge_if_message_count_is_zeros   cC@sOidd6}|jjjj}||_|jj|j|jjddS(NiR( RRRRRRRRR[(RRR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt#test_purges_all_messages_from_queues   cC@sQidd6}|jjjj}||_|jj|j}|j|ddS(NiR(RRRRRRRR)(RRRtresult((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_returns_message_counts   s .NotFoundRcC@s2d|jjj_|jt|jj|jdS(N( R5RRRRR6RRR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt1test_raises_channel_error_if_queue_does_not_exist s( R2R3R#RRRRRR%R6R(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyRs      tTestChannelPutcB@s:eZeeddZeeddZRS(s.qpidcC@sd}t}|jj}|jj||dj|}|jjjj ||j d|dd|jjjj }|j j |j dt |jj dS(Nt routingkeys.{0}; {{assert: always, node: {{type: queue}}}}tcontenttsubjecttsync(RRaR Rt_puttformatRRHtsenderR[R5RtsendRlR(RR`t routing_keyR^tmock_Message_clst address_strt mock_sender((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_channel__put_onto_queues      cC@sd}d}t}|jj}|jj|||dj||}|jjjj ||j d|d||jjjj }|j j |j dt |j j dS(NRt myexchanges2{0}/{1}; {{assert: always, node: {{type: topic}}}}RRR(RRaR RRRRRHRR[RRRlR(RR`tmock_routing_keytmock_exchange_nameR^RtaddrstrR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_channel__put_onto_exchange*s      (R2R3RR%RR(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyRstTestChannelGetcB@seZdZRS(cC@s}t}|jj|}|jjjj||jjjj}|jjdd|j j|j |jj|dS(NRi( RRt_getRRHtreceiverRRtfetchRR|(RRRtmock_rx((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_channel__getEs  (R2R3R(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyRAstTestChannelClosecB@sPeZdZdZdZdZdZdZdZdZ RS(cC@stt|jtj|jd|_|jj|_t |_ t |_ i|j d6|j d6|j_ t |j_dS(Nt basic_cancelii(R7RR#RRRtpatch_basic_cancelRtmock_basic_cancelRtmock_receiver1tmock_receiver2t _receiversRtclosed(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR#Us  cC@s$|jjtt|jdS(N(RR R7RR$(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR$`s cC@s$|jj|j|jjdS(N(RRRIR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt'test_channel_close_sets_close_attributeds cC@s3|jj|jjtdtdgdS(Nii(RRRtassert_has_callsR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt6test_channel_close_calls_basic_cancel_on_all_receivershs cC@s'|jj|jjj|jdS(N(RRRRR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt4test_channel_close_calls_close_channel_on_connectionls cC@s$|jj|jjjjdS(N(RRt_brokerR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt.test_channel_close_calls_close_on_broker_agentps cC@s0t|j_|jj|j|jjdS(N(RlRRRRNRR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt1test_channel_close_does_nothing_if_already_closedts  cC@s3d|j_|jj|j|jjjdS(N(R5RRRRNRRR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt>test_channel_close_does_not_call_close_channel_if_conn_is_Noneys  ( R2R3R#R$RRRRR R (((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyRQs      tTestChannelBasicQoScB@seZdZRS(cC@s-|jjd|j|jjjddS(Nii(Rt basic_qosR)R?R@(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt)test_channel_basic_qos_always_returns_ones(R2R3R (((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR stTestChannelBasicGetcB@sPeZdZdZdZdZdZdZdZdZ RS(cC@s5tt|jt|j_t|j_dS(N(R7RR#RRR R(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR#scC@s0t}|jj||jjj|dS(N(RRt basic_getRR(RR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt,test_channel_basic_get_calls__get_with_queues cC@sHt}|jj||jjjj}|jjj|j|dS(N(RRRRRRR R(RRtmock_raw_message((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt0test_channel_basic_get_creates_Message_correctlys   cC@sKt}|jj||jjj}|jjj}|jd|dS(NRX( RRRRRRRHRZR(RRtmock_qpid_messageRZ((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt6test_channel_basic_get_acknowledges_message_by_defaults  cC@sQt}|jj|dt|jjj}|jjj}|j d|dS(Ntno_ackRX( RRRRRRRRHRZR(RRRRZ((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt=test_channel_basic_get_acknowledges_message_with_no_ack_Falses  cC@sQt}|jj|dt|jjj}|jjj}|j d|dS(NRRX( RRRRlRRRRHRZR(RRRRZ((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt<test_channel_basic_get_acknowledges_message_with_no_ack_Trues  cC@s>t}|jj|}|jjj}|j||dS(N(RRRR RR|(RRtbasic_get_resulttexpected_message((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt.test_channel_basic_get_returns_correct_messages cC@sZt}tdt|j_|jj|}|j|jjjd|j|dS(NRi( RRRRRR)R t call_countR(RRR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt:test_basic_get_returns_None_when_channel__get_raises_Emptys  ( R2R3R#RRRRRRR(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyRs       tTestChannelBasicCancelcB@s>eZdZdZdZdZdZdZRS(cC@s-tt|jitd6|j_dS(Ni(R7RR#RRR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR#scC@s|jjddS(Ni(RR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt<test_channel_basic_cancel_no_error_if_consumer_tag_not_foundscC@s*|jjd|jd|jjdS(Ni(RRRWR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt'test_channel_basic_cancel_pops_receiverscC@s1|jjd}|jjd|jjdS(Ni(RRRRR(Rt mock_receiver((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt)test_channel_basic_cancel_closes_receiverscC@s<t|j_|jjd|jjjjdddS(Ni(RRt _tag_to_queueRtpopRR5(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt,test_channel_basic_cancel_pops__tag_to_queuescC@sNt|j_|jjd|jjjj}|jjjj|ddS(Ni( RRR"RR#RRRRR5(RR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt4test_channel_basic_cancel_pops_connection__callbackss(R2R3R#RRR!R$R%(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyRs      tTestChannelInitcB@seZdZRS(cC@s|j|j|jj|j|j|jj|j|jj|jjj|j j }|j|jj ||j |jj i|j |jji|j|jjddS(N(R|RRRRRNRRRRRRR/R"Rt_qosR5(Rtexpected_broker_agent((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt/test_channel___init__sets_variables_as_expecteds (R2R3R)(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR&stTestChannelBasicConsumecB@seZdZdZdZdZdZdZeedZ dZ dZ d Z d Z d ZRS( cC@s#tt|ji|j_dS(N(R7R*R#RR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR#scC@sXt}t}|jj|tt|i||6}|j||jjdS(N(RRt basic_consumeR/R"(Rtmock_tagRt expected_dict((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt6test_channel_basic_consume_adds_queue_to__tag_to_queues    cC@s_t}|jj|ttt|j||jj|j|jj|tdS(N(RRR+R0RRRDR(RR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt>test_channel_basic_consume_adds_entry_to_connection__callbackss "cC@sEt}|jj|ttt|jjjj|dS(N(RRR+RRHRR(RR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt/test_channel_basic_consume_creates_new_receivers "cC@sdt}|jjttt||jjjj}i||6}|j||jjdS(N( RRR+RRHRRR/R(RR,tnew_mock_receiverR-((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt-test_channel_basic_consume_saves_new_receiver s  " cC@sit}||jj_|jjtttt|jjjj}|j |j |kdS(N( RRR?R@R+RRHRRRItcapacity(Rtmock_prefetch_countt new_receiver((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt8test_channel_basic_consume_sets_capacity_on_new_receivers  %cC@sBt|j_t}|jj|||t|jj|S(N(RRR R+RR(RRt original_cbR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt get_callbacks cC@sE|j}t}|||j}|jjj|j|dS(N(R8RRRR R(RtcallbackRt mock_content((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt=test_channel_basic_consume_callback_creates_Message_correctlys      cC@s]t|j_|j}t}|||jjjj}|jjjj||dS(N( RRR'R8R Rt delivery_tagRUR(RR9Rtmock_delivery_tag((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt7test_channel_basic_consume_callback_adds_message_to_QoS(s   cC@sWt|j_|j}t}|||jjjj}|jjj|dS(N(RRt basic_ackR8R RR<R(RR9RR=((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt5test_channel_basic_consume_callback_gratuitously_acks2s    cC@sNt|j_|jdt}t}|||j|jjjdS(NR(RRR?R8RRNR(RR9R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt<test_channel_basic_consume_callback_does_not_ack_when_needed:s   cC@s]t|j_t}|jd|}t}|||jjj}|j|dS(NR7(RRR?R8R RR(Rtmock_original_callbackR9RR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt7test_channel_basic_consume_callback_calls_real_callbackAs   (R2R3R#R.R/R0R2R6RR8R;R>R@RARC(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR*s        tTestChannelQueueDeletecB@sYeZdZdZdZdZdZdZdZdZ dZ RS( cC@stt|jtj|jd|_|jj|_tj|jd|_ |j j|_ tj|jd|_ |j j|_ t |_dS(Nt _has_queuet_sizet_delete(R7RDR#RRRtpatch__has_queueRtmock__has_queuet patch__sizet mock__sizet patch__deletet mock__deleteRR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR#OscC@s>|jj|jj|jjtt|jdS(N(RHR RJRLR7RDR$(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR$Ys   cC@s*|jj|j|jj|jdS(N(Rt queue_deleteRRIR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_checks_if_queue_exists_scC@s6t|j_|jj|j|j|jjdS(N( RRIRRRNRRNRMR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt)test_does_nothing_if_queue_does_not_existcs cC@sHd|j_|jj|jdt|jj}|j|jj dS(Nitif_empty( RKRRRNRRlRRNRR(Rt mock_broker((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt*test_not_empty_and_if_empty_True_no_deletehs  cC@s6|jj|j|jjj}|j|jdS(N(RRNRRRRR(RR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_calls_get_queuenscC@s6|jj|j|jjjj}|jjdS(N(RRNRRRRt getAttributesR(RR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_gets_queue_attributesscC@sU|jjjj}idd6|j_|jj|jdt|j|j j dS(Nit consumerCountt if_unused( RRRRURRNRRlRNRMR(RR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt)test_queue_in_use_and_if_unused_no_deletexscC@s*|jj|j|jj|jdS(N(RRNRRMR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_calls__delete_with_queue~s( R2R3R#R$RORPRSRTRVRYRZ(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyRDKs       t TestChannelcB@seZeeddZdZdZdZdZdZ dZ dZ d Z ed d Z d Zd ZdZdZdZdZdZdZdZdZdZdZeeddZeeddZdZdZdZedeedeed eed!d"Zeed#d$Z eed#d%Z!eed#d&Z"eed#d'Z#d(Z$d)Z%RS(*s .qpidtoollibscC@st|_t|_t|_td|j|j_td|j|j_t|_t|_t|_|j |_ |j|j _ t |j|j|_ |j|j _dS(NR(Rtmock_connectionRtmock_qpid_sessionRHRtmock_transportRRt mock_MessageRtmock_BrokerAgentRR t my_channelR (RR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR#s       cC@s|jttjdS(s<Verify that the class attribute QoS refers to the QoS objectN(R|RR (R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_verify_QoS_class_attributescC@s|jttjdS(sMVerify that the class attribute Message refers to the Message object.N(R|R R (R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt#test_verify_Message_class_attributescC@s|jdtjdS(s>Verify that the class attribute body_encoding is set to base64tbase64N(R)R t body_encoding(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt"test_body_encoding_class_attributescC@sA|jtjt|jdtj|jtjdtdS(sKVerify that the codecs class attribute has a correct key and value.RdN(RDR tcodecsRR0R(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_codecs_class_attributescC@spd}t}t}i|d6|_||jj_|jj|}|jjj||j||dS(s\Test getting the number of messages in a queue specified by name and returning them.iRN( RRRRRRRaRFR[R)(Rt message_countRtmock_queue_to_checkR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt test_sizes  cC@sat}t|j_|jj|}|jjj||jjj||j|dS(s?Test deleting a queue calls purge and delQueue with queue name.N(RRaRRGR[RRtdelQueueR(RRR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt test_deletes  cC@s;t}t|jj_|jj|}|j|dS(s-Test checking if a queue exists, and it does.N(RRlRRRRRaRERI(RRR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_has_queue_trues cC@s;t}t|jj_|jj|}|j|dS(s1Test checking if a queue exists, and it does not.N(RRRRRRRaRERN(RRR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_has_queue_falses s amqp.protocol.queue_declare_ok_tcC@sjt}t}t}t}t}t}t}t} t|j_t|j_i|d6|d6|d6|d6|d6} t} t} i| d6| d6} t}| |_td}||jj_ ||jj _| |_|j j |d|d|d|d |d |d|}|jjj |d | |j || | |j| |d S( s>Test declare_queue, where an exception is raised and silenced.tpassivetdurablet exclusives auto-deletet argumentsRRWsThe foo object already exists.t auto_deletetnowaittoptionsN(RRt startswithRtendswithRR8RRtaddQueueRRRat queue_declareR[R|(Rtmock_queue_declare_ok_tRt mock_passivet mock_durabletmock_exclusivetmock_auto_deletet mock_nowaittmock_argumentstmock_msg_countRvtmock_consumer_counttmock_return_valuet values_dicttmock_queue_datatexception_to_raiseR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt(test_queue_declare_with_exception_raisedsP                       cC@st}t|j_t|j_itd6td6td6td6d d6dd6}t}t}i|d6|d 6}t}||_d |jj _||jj _|j j ||jj d |jj j |d |d S( s1Test declare_queue sets ring_policy for celeryev.RpRqRrs auto-deleteRstringsqpid.policy_typeRRWtceleryevRvN(RRlRwRRRxR5RRRRyRRaRzR[(RRtexpected_default_optionsRRRR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt/test_queue_declare_set_ring_policy_for_celeryevs.          cC@st}t|j_t|j_itd6td6td6td6d d6dd6}t}t}i|d6|d 6}t}||_d |jj _||jj _|j j ||jj d |jj j |d |d S( s/Test declare_queue sets ring_policy for pidbox.RpRqRrs auto-deleteRsRsqpid.policy_typeRRWtpidboxRvN(RRRwRRlRxR5RRRRyRRaRzR[(RRRRRRR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt-test_queue_declare_set_ring_policy_for_pidbox"s.          cC@st}t|j_t|j_itd6td6td6td6d d6}t}t}i|d6|d6}t}||_d |jj _||jj _|j j ||jj d|jj d |jj j |d |d S( s8Test declare_queue does not set ring_policy as expected.RpRqRrs auto-deleteRsRRWRRRvN(RRRwRRxRlR5RRRRyRRaRzR[(RRRRRRR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt2test_queue_declare_ring_policy_not_set_as_expected?s.          cC@st}t|j_t|j_itd6td6td6td6d d6}t}t}i|d6|d6}t}||_d |jj _||jj _|j j ||jj j |d|d S( sTest declare_queue defaults.RpRqRrs auto-deleteRsRRWRvN(RRRwRRxRlR5RRRRyRRaRzR[(RRRRRRR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt test_queue_declare_test_defaults\s,          cC@std}t}||jj_|j|j|jj|WdQX|jjj |dit d6t d6dd6t d6dd6t d 6dS( Ns%This exception should not be silencedRvRrRqRsqpid.policy_typeRpRss auto-delete( R8RRRRyRRt __class__RaRzRRR5Rl(Rtunique_exceptionR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt0test_queue_declare_raises_exception_not_silencedxs   cC@s&td|jj_|jjdS(s>Create exchange where an exception is raised and then silencedsThe foo object already exists.N(R8RRt addExchangeRRatexchange_declare(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt3test_exchange_declare_raises_exception_and_silencedscC@sEtd}||jj_|j|j|jjWdQXdS(s>Create Exchange where an exception is raised and not silenced.s%This exception should not be silencedN(R8RRRRRRRaR(RR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt3test_exchange_declare_raises_exception_not_silenceds cC@sjt}t}t}i|d6}|jj|||}|jjj||||j|dS(s1Create Exchange where an exception is NOT raised.RqN(RRaRRRRR[R(Rt mock_exchanget mock_typeR}RvR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_exchange_declares       cC@s?t}|jj|}|jjj||j|dS(s)Test the deletion of an exchange by name.N(RRatexchange_deleteRRt delExchangeR[R(RRR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_exchange_deletes cC@sNt}t}t}|jj||||jjj|||dS(s8Test binding a queue to an exchange using a routing key.N(RRat queue_bindRRtbindR[(RRRR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_queue_binds      cC@sNt}t}t}|jj||||jjj|||dS(s<Test unbinding a queue from an exchange using a routing key.N(RRat queue_unbindRRtunbindR[(RRRR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_queue_unbinds      cC@s`t}t}td||j_|jj|}|jjj||j||dS(sTest purging a queue by name.RN(RRaRt queue_purgeR[R|(RRt purge_resultR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_queue_purges   s .Channel.qoscC@s-t}|jj||jj|dS(s2Test that basic_ack calls the QoS object properly.N(RRaR?RVR[(Rtmock_qosR=((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_basic_acks cC@s?t}t}|jj|||jj|d|dS(s5Test that basic_reject calls the QoS object properly.RjN(RRat basic_rejectRhR[(RRR=tmock_requeue_value((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_basic_rejects    cC@sBd|j_|jj}|j|t|j||jjdS(s>Test the qos property if the QoS object did not already exist.N(R5RaR'R?RDRR)(RR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_qos_manager_is_nones  cC@s5t}||j_|jj}|j||dS(s7Test the qos property if the QoS object already exists.N(RRaR'R?R|(Rtmock_existing_qosR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_qos_manager_already_existss   c C@s$t}t}t}t}t}t}t}t}i|d6|d6} i|d6|d6} |jj|d|d|d|d| d | } |j|| d |j|| d |j|| d |j| | d|j| | d |j|| d d ddS(s7Test that prepare_message() returns the correct result.theader1theader2t properties1t properties2tpriorityt content_typetcontent_encodingtheaderst propertiestbodyscontent-encodings content-typet delivery_infoN(RRatprepare_messageR|R/R1( Rt mock_bodyt mock_prioritytmock_content_encodingtmock_content_typet mock_header1t mock_header2tmock_properties1tmock_properties2RRR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_prepare_messages2            s__builtin__.buffers.Channel.body_encodings.Channel.encode_bodys .Channel._putc C@s&t}d}i|d6iid6d6}||f|_t}t} t} | |_|jj||| |j|||j||j|d| |j|dd||j|ddtj|j|ddd||j|ddd| |j | ||d S( sTest basic_publish().sthis is my encoded bodyRRRReR<texchangeRN( RRRat basic_publishRR|RDtuuidtUUIDR[( Rtmock_puttmock_encode_bodytmock_body_encodingt mock_buffertmock_original_bodytmock_encoded_bodyR^RRtmock_encoded_buffered_body((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_basic_publish s6          s.Channel.codecscC@skt}t}t}||j_||j_|jj|dd}|df}|j||dS(s:Test if encode_body() works when encoding is set correctlytencodingRdN(RRRtencodeRat encode_bodyR)(Rt mock_codecsRt mock_encodertmock_encoded_resultRtexpected_result((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt"test_encode_body_expected_encoding7s      cC@sAt}|jj|dd}|df}|j||dS(s?Test if encode_body() works when encoding is not set correctly.RN(RRaRR5R)(RRRRR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt&test_encode_body_not_expected_encodingCs  cC@s_t}t}t}||j_||j_|jj|dd}|j||dS(s;Test if decode_body() works when encoding is set correctly.RRdN(RRRtdecodeRat decode_bodyR)(RRRt mock_decodertmock_decoded_resultR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt"test_decode_body_expected_encodingKs     cC@s5t}|jj|dd}|j||dS(s?Test if decode_body() works when encoding is not set correctly.RN(RRaRR5R)(RRRR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt&test_decode_body_not_expected_encodingVs cC@slt}t}i}t}||d<||j_||jj_|jj|}|j||dS(s9Test that typeof() finds an exchange that already exists.ttypeN(RRURRRt getExchangeRattypeofR|(RRtmock_qpid_exchangetmock_attributesRR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_typeof_exchange_exists]s     cC@sMt}t}d|jj_|jj|d|}|j||dS(s:Test that typeof() finds an exchange that does not exists.tdefaultN(RR5RRRRRaRR|(RRt mock_defaultR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt#test_typeof_exchange_does_not_existis   (&R2R3RR%R#RbRcRfRhRkRmRnRoRRRRRRRRRRRRRRRRRRRRRRRRR(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR[sJ      2                "+   tTestTransportInitcB@s5eZdZdZdZdZdZRS(cC@sPtjtd|_|jj|_ttd|_|jj|_dS(Ntverify_runtime_environments.base.Transport.__init__( RRRtpatch_aRtmock_verify_runtime_environmentR%tpatch_btmock_base_Transport__init__(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR#wscC@s|jj|jjdS(N(RR R(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR$~s cC@stt|jjdS(N(RRRR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt8test_Transport___init___calls_verify_runtime_environments cC@s't}t||jj|dS(N(RRRR(RRs((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt3test_transport___init___calls_parent_class___init__s  cC@s#tt}|j|jdS(N(RRRNtuse_async_interface(RR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt6test_transport___init___sets_use_async_interface_Falses(R2R3R#R$RRR(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyRrs     tTestTransportDrainEventscB@s>eZdZdZdZdZdZdZRS(cC@sntt|_t|j_t|_t|_t|_t|_i|j|j6|j_dS(N( RRRRHRR^t mock_connt mock_callbackR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR#s    cC@s5tjdt}|j|_|j|j_|S(Ng333333?(ttimetsleepRRtsourceR^RR(RRR ((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pytmock_next_receivers    c C@sbttddtFt|jjj_|jtj |jj t WdQXWdQXdS(Ns .QpidEmptyR( RR%R6RRHt next_receiverRRtsocketRt drain_eventsR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt3test_socket_timeout_raised_when_all_receivers_emptyscC@sH|j|jj_|jtj|jj|jddWdQXdS(NRi( RRRHRRRRRR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt*test_socket_timeout_raised_when_by_timeoutscC@sp|j|jj_t}y|jj|jddWntjk rNnXt|}|j |ddS(NRig?( RRRHRRRRRRtassertGreaterEqual(Rt start_timetelapsed_time_in_s((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt.test_timeout_returns_no_earlier_then_asked_fors  cC@s]|j|jj_y|jj|jddWntjk rEnX|jj |j dS(NRi( RRRHRRRRRRR[R^(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_callback_is_calleds (R2R3R#RRRRR(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyRs     tTestTransportCreateChannelcB@s#eZdZdZdZRS(cC@sXtt|_t|_t|_|j|jj_|jj|j|_dS(N( RRRRtmock_new_channelR Rtcreate_channeltreturned_channel(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR#s   cC@s6|j|j|j|jjj|j|jdS(N(R|RRRR R[R(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt(test_new_channel_created_from_connections cC@s#|jjj}|j|jdS(N(RRRUR[R(Rt append_method((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt1test_new_channel_added_to_connection_channel_lists(R2R3R#RR (((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyRs  t TestTransportEstablishConnectioncB@seZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZRS(cC@sdtfdY}||_d|j_t|j_i|j_d|j_d|j_d|j_ t |j|_ t |_ |j |j _dS(Nt MockClientcB@seZRS((R2R3(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR si(Rtclienttconnect_timeoutRtsslttransport_optionsR5tuseridtpasswordt login_methodRRRRR (RR ((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR#s        cC@sld|j_d|j_|jj|jjd|jjd|jjddddd d d d d ddS(Ns new-userids new-passwordtusernameRRtPLAINRRRiRi(RR(R RRRtestablish_connectionRR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt;test_transport_establish_conn_new_option_overwrites_defaults      c C@s<|jj|jjddddddddd d dS( NRRRRRiRi(RR(RRRR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt5test_transport_establish_conn_empty_client_is_defaults  c C@sXd}||jjd<|jj|jjddddddd|d d d d dS( Nt mynewparamt new_paramRRRRRiRi(RR(R RRRRR(Rtnew_param_value((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt9test_transport_establish_conn_additional_transport_options  c C@sHd|j_|jj|jjddddddddd d dS( NRRRRRiRi(RR(R thostnameRRRR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt>test_transport_establish_conn_transform_localhost_to_127_0_0_1s   cC@s&d|j_|jt|jjdS(Ntsomepass(R RRR8RR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt2test_transport_password_no_userid_raises_exceptions cC@s&d|j_|jt|jjdS(Nt someusername(R RRR8RR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt2test_transport_userid_no_password_raises_exception#s c C@sHd|j_|jj|jjddddddddd d dS( NtEXTERNALRRRRiRi(RR(R RRRRR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt4test_transport_overrides_sasl_mech_from_login_method's   c C@s`d|j_d|j_|jj|jjd|jjddddddd d d d dS( Ns new-useridR"RRRRRiRi(RR(R RRRRRR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt/test_transport_overrides_sasl_mech_has_username2s     cC@s`d|j_d|j_|jj|jjddddddddd d d d d ddS(NtsomeuserRRRRRRRRiRi(RR(R RRRRRR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt*test_transport_establish_conn_set_password?s    c C@sHt|j_|jj|jjddddddddd d dS( NRRRRRiRi(RR(RR RRRRR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt7test_transport_establish_conn_no_ssl_sets_transport_tcpMs   cC@sidd6dd6dd6tjd6|j_|jj|jjddd dd d d td ddddddddd dS(Nt my_keyfiletkeyfilet my_certfiletcertfilet my_cacertstca_certst cert_reqst ssl_certfilet ssl_trustfileRitssl_skip_hostname_checkRRRRt ssl_keyfileRi(RR(Rt CERT_REQUIREDR RRRRR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt:test_transport_establish_conn_with_ssl_with_hostname_checkXs  cC@sidd6dd6dd6tjd6|j_|jj|jjddd dd d d td ddddddddd dS(NR(R)R*R+R,R-R.R/R0RiR1RRRRR2Ri(RR(Rt CERT_OPTIONALR RRRRRl(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt:test_transport_establish_conn_with_ssl_skip_hostname_checkks  cC@s-|jj|j|jjj|jdS(N(RRR|RRR (R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt>test_transport_establish_conn_sets_client_on_connection_object~s cC@sE|jj|jjj}|jjj}|j|jj|dS(N(RRRRRRHR|(Rt qpid_conntnew_mock_session((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt:test_transport_establish_conn_creates_session_on_transports cC@s)|jj}|j||jjdS(N(RRR|RR(Rtnew_conn((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt;test_transport_establish_conn_returns_new_connection_objectsc C@sHd|j_|jj|jjddddddddd d dS( Ntsome_other_hostnameRRRRiRi(RR(R RRRRR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt:test_transport_establish_conn_uses_hostname_if_not_defaults   cC@sQ|jj|jjj}|jjj}|j}|jj}|j|dS(N( RRRRRRHt#set_message_received_notify_handlert_qpid_message_ready_handlerR(Rtqpid_conn_callR>tmock_set_callbacktexpected_msg_callback((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt.test_transport_sets_qpid_message_ready_handlers    cC@sQ|jj|jjj}|jjj}|j}|jj}|j|dS(N( RRRRRRHt"set_async_exception_notify_handlert$_qpid_async_exception_notify_handlerR(RRAR>RBt exc_callback((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt-test_transport_sets_session_exception_handlers    cC@sK|jj|jjj}|j}|j}|jj}|j|dS(N(RRRRRRERFR(RRAR8RBRG((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt0test_transport_sets_connection_exception_handlers     (R2R3R#RRRRRR!R#R$R&R'R4R6R7R:R<R>RDRHRI(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR s(            tTestTransportClassAttributescB@sGeZdZdZdZdZdZdZdZRS(cC@s|jttjdS(N(R|R R(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt test_verify_Connection_attributescC@s|jtjdS(N(RRtpolling_interval(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_verify_polling_disabledscC@s|jtjdS(N(RIRt supports_ev(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt2test_transport_verify_supports_asynchronous_eventsscC@s*|jdtj|jdtjdS(Ntqpid(R)Rt driver_typet driver_name(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt test_verify_driver_type_and_namescC@s0tj}|jt||jtj|dS(N(Rtrecoverable_connection_errorsR0R tselectR(Rtconnection_errors((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt3test_transport_verify_recoverable_connection_errorss cC@stj}|jt|dS(N(Rtrecoverable_channel_errorsR0R(RR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt0test_transport_verify_recoverable_channel_errorss cC@s0|jtjtj|jtjtjdS(N(R)RRXRRTRV(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt4test_transport_verify_pre_kombu_3_0_exception_labelss   ( R2R3RKRMRORSRWRYRZ(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyRJs      t"TestTransportRegisterWithEventLoopcB@seZdZRS(cC@sTtt}t}t}|j|||jj|j|j||dS(N(RRtregister_with_event_loopt add_readerR[trt on_readable(RRR\t mock_loop((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt8test_transport_register_with_event_loop_calls_add_readers    (R2R3Ra(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR[st&TestTransportQpidCallbackHandlersAsynccB@s,eZdZdZdZdZRS(cC@sTttd|_|jj|_tt|_|jjttdS(Ns .os.write( RR%RRt mock_os_writeRRRR\(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR#scC@s|jjdS(N(RR (R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR$scC@s0|jjt|jj|jjddS(Nt0(RR@RRcRt_w(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt4test__qpid_message_ready_handler_writes_symbol_to_fdscC@s6|jjtt|jj|jjddS(Nte(RRFRRcRRe(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt=test__qpid_async_exception_notify_handler_writes_symbol_to_fds(R2R3R#R$RfRh(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyRbs   t%TestTransportQpidCallbackHandlersSynccB@s,eZdZdZdZdZRS(cC@s;ttd|_|jj|_tt|_dS(Ns .os.write(RR%RRRcRRR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR#scC@s|jjdS(N(RR (R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR$scC@s+|jjt|j|jj dS(N(RR@RRIRcR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt/test__qpid_message_ready_handler_dows_not_writescC@s1|jjtt|j|jj dS(N(RRFRRIRcR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt8test__qpid_async_exception_notify_handler_does_not_writes(R2R3R#R$RjRk(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyRis   tTestTransportOnReadablecB@s>eZdZdZdZdZdZdZRS(cC@s{ttd|_|jj|_tjtd|_|jj|_tt |_ |j j t t dS(Ns.os.readR( RR%RRt mock_os_readRRRtmock_drain_eventsRRR\(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR#s cC@s|jj|jjdS(N(RR R(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR$s cC@s6|jjtt|jj|jjddS(Ni(RR_RRmRR^(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt/test_transport_on_readable_reads_symbol_from_fdscC@s3t}|jj|t|jj|dS(N(RRR_RnR[(RR\((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt-test_transport_on_readable_calls_drain_events#s cC@s/tj|j_|jjttdS(N(RRRnRRR_R(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt1test_transport_on_readable_catches_socket_timeout(scC@sBt|j_|jt|jjttWdQXdS(N(RRnRRRR_R(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt?test_transport_on_readable_ignores_non_socket_timeout_exception,s(R2R3R#R$RoRpRqRr(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyRl s     t%TestTransportVerifyRuntimeEnvironmentcB@seZdZdZeeddedZeddZeeddZ eedd Z d Z RS( cC@sDtj|_tjtd|_|jjtt|_dS(NR(RRRRRRRR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR#7s  cC@s|jjdS(N(RR (R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR$=ss.PY3RcC@s*|jt|j|jWdQXdS(N(Rt RuntimeErrorRR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt!test_raises_exception_for_Python3@ss__builtin__.getattrcC@s3t|_|jt|j|jWdQXdS(N(RlRRRtRR(Rt mock_getattr((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_raises_exc_for_PyPyEs s.dependency_is_nonecC@s3t|_|jt|j|jWdQXdS(N(RlRRRtRR(Rtmock_dep_is_none((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_raises_exc_dep_missingKs cC@s-t|_|j|j|j|jdS(N(RRRRRIR(RRx((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_calls_dependency_is_noneQs cC@s|j|jdS(N(RR(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_raises_no_exceptionWs( R2R3R#R$RR%RlRuRwRyRzR{(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyRs2s  t TestTransportcB@sneZdZdZdZeeddZeeddZeeddZ RS(cC@st|_dS(s,Creates a mock_client to be used in testing.N(Rt mock_client(R((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR#`scC@s6t|j}t}|j||jjdS(s9Test that close_connection calls close on the connection.N(RR}Rtclose_connectionRR(Rt my_transportR\((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_close_connectionds  cC@s@idd6dd6}t|j}|j}|j||dS(s3Test that the default_connection_params are correctRRi(RN(RR}tdefault_connection_paramsR/(Rtcorrect_paramsRt result_params((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_default_connection_paramsks   s .os.closecC@s-t|j}|j|j|jdS(N(RR}t__del__RNR(RRR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyt test_del_syncus cC@sCt|j}|jtt|j|j|jdS(N(RR}R\RRRIR(RRR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_del_async{s cC@sOt|_t|j}|jtt|j|j|jdS(N( tOSErrorRRR}R\RRRIR(RRR((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyttest_del_async_faileds   ( R2R3R#RRRR%RRR(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyR|[s    (Rt __future__RRURRRRRt collectionsRt itertoolsRt functoolsRtmockRt kombu.fiveRRRRtkombu.transport.qpidR R R R R RRRtkombu.transport.virtualRtkombu.tests.caseRRRRRtkombu.utils.compatRR%R'RR(R8R6R<R=RGRPRTR]RoRRRRRRRRRRRR RRR&R*RDR[RRRR RJR[RbRiRlRsR|(((sA/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/transport/test_qpid.pyts      ":"  (;|&.,7X60 "&