O'^c@@s\ddlmZddlZddlZddlmZmZddlmZmZm Z m Z ddl m Z ddl mZmZddlmZmZmZmZmZdd lmZd efd YZd efd YZdefdYZde fdYZdefdYZdefdYZdefdYZdS(i(tabsolute_importN(tcopytdeepcopy(t ConnectiontConsumertProducert parse_url(tResource(titemstrangei(tCasetMocktSkipTesttpatchtskip_if_not_module(t Transportttest_connection_utilscB@sneZdZdZdZdZeddZdZdZ dZ d Z d Z RS( cC@sId|_d|_idd6dd6dd6d d 6d d 6d d6|_dS(Ns(amqp://user:pass@localhost:5672/my/vhosts&amqp://user:**@localhost:5672/my/vhosttamqpt transporttusertuseridtpasstpasswordt localhostthostnamei(tportsmy/vhostt virtual_host(turltnopasstexpected(tself((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pytsetUps  cC@s&t|j}|j||jdS(N(RRtassertDictEqualR(Rtresult((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_parse_urlscC@st|j}|j}x1|jjD] \}}|j|||q+W|j|j|j|j|jdt|jdS(Ntinclude_password( RRtinfoRRt assertEqualtas_uriRtTrue(RtconnR$tktv((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_parse_generated_as_uri"s  cC@s&td}|j|jddS(Ns*redis+socket:///var/spool/x/y/z/redis.sock(RR%R&(RR(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_as_uri_when_prefix+s tpymongocC@s#td}|j|jdS(Nsmongodb://localhost(Rt assertTrueR&(Rtx((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_as_uri_when_mongodb1s cC@s'|jttdjWdQXdS(Nsbogus://localhost:7421(t assertRaisestKeyErrorRR(R((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_bogus_scheme6scK@sA|j}x.t|D] \}}|j|||qWdS(N(R$RR%(RR(tfieldsR$tfieldR((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyt assert_info:s c C@s|jtddddddddd d d |jtd dd dddddd d d|jtdddddddddd d|jtdddddddddd d|jtdddddddddd d|jtdddddddddd d|jtdddddddddd d|jtddddddddd d d|jtdddddddddd d |jtdddddddddd d|jtdddddddddd ddS(Ns!amqp://user:pass@host:10000/vhostRRRRRthostRi'Rtvhosts-amqp://user%61:%61pass@ho%61st:10000/v%2fhosttuseratapassthoastsv/hostsamqp://tguestRi(t/s amqp://:@/s amqp://user@/samqp://user:pass@/s amqp://hosts amqp://:10000s amqp:///vhosts amqp://host/samqp://host/%2f(R6R(R((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_rabbitmq_example_urls?sX                     c C@sAtd|jtddddddddd d d dS( Nsurllib can't parse ipv6 urlss amqp://[::1]RR<RRs[::1]Ri(RR=(R R6R(R((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyt test_url_IPV6s   cC@s>t|jddg}t|}|j|jdgdS(Nt alternatess amqp://host(RRRR%talt(RR(tclone((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_connection_copys ( t__name__t __module__RR"R+R,RR0R3R6R>R?RC(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyRs     E ttest_ConnectioncB@sgeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZ dZ!d Z"d!Z#d"Z$d#Z%d$Z&d%Z'd&Z(RS('cC@stdddt|_dS(NRi(R(RRR((R((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyRscC@s|j}|j|j|jj|j|jd|j}|j|j|j|j d|j}|j |j |j|j |j tdS(Nslocalhost:5672tevent(R(tconnectR.t connectiont connectedR%R7tchanneltopent drain_eventstcloset assertFalsetassertIsInstanceRR(RR(RKt _connection((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_establish_connections     cC@sztd}|j|jd|j|jddgtddg}|j|jd|j|jddgdS(Nsamqp://foo;amqp://bartfoos amqp://foos amqp://bar(RR%RtassertListEqualRA(Rtconn1tconn2((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_multiple_urlss  cC@std}tdd}|_tdd}|_tdd}|_tdd|_tdd}|_|j|j|j |j ||jj j |j |j |j |j|j |jdS(Ns memory://tnameRstransport._collectsconnection._closet decl_entitiesRQ(RR t _transportt_collectt_closetdeclared_entitiesRQtcollectROtcalledtassert_called_withtcleart assertIsNonetclient(RRIttransR[R\tuconn((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyt test_collects   cC@sXtd}d|_t|_|j|jjtj|j_ |jdS(Ns memory://( RtNoneRZR R\R^R`tsocketttimeoutt side_effect(RRI((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_collect_no_transports     c@stdtdd}_tdd}_tdd}|_fd}||_j|j||jjdS(Ns memory://RXs conn._connRstransport._collectc@s d_dS(N(RgRZ(R((RI(s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pytses( RR RQRZR[RjR^R`Rb(RReRdR^Rl((RIs=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_collect_transport_gones    c C@s2tdd}td}||_t|_tde}td}|j|jd|j|j |j|j d|j |j j dWdQXtdO}tddd}|j|jd|j|j |j|j dWdQXWdQXtd }|j |j j d dS( NRXRs"kombu.connection.get_transport_clsskombu.connection.parse_urlsfoo+mysql://some_hostRSsmysql://some_hostsfoo+spyamqp+sqlite://some_hostspyamqp+(R R t return_valueR't can_parse_urlRR%t transport_clsROR_RR.R&t startswith(RRtgtcRtc((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_uri_passthroughs"   " cC@sNtd<}tdt}|jtd|j|jjWdQXdS(Nskombu.connection.loggerRi(R RR t_default_ensure_callbackR2R.terrorR_(RtloggerRs((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_default_ensure_callbacksc C@std}td}|j|j|j|jd}|d}tdddddg}|j|t|dd|j|t|dd|j|t|dd|j|t|dd|j|t|dd|j|t|dd|j|t|d d|j|t|d dt }|jd ||jd}|d}|j|t|dd|j|jWdQXdS( Nsamqp://A;amqp://Bs kombu.connection.retry_over_timeiiiiiiiiterrback( RR tensure_connectionR.R_t call_argstiterR%R2R (RRstrottargstcbt intervalsRy((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_ensure_connection_on_errors*       cC@s/tdt}t|j_|j|jdS(NR(RR tFalseRtsupports_heartbeatsRO(RRs((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_supports_heartbeatss cC@s/tdt}t|j_|j|jdS(NR(RR RRt supports_evROt is_evented(RRs((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_is_evented s cC@sHtdt}tdd}|j||jjj|j|dS(NRRXtloop(RR tregister_with_event_loopRR`RI(RRsR((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_register_with_event_loops   cC@s,tdt}|j|j|jjdS(NR(RR tassertIstmanagerR(RRs((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyt test_managerscC@s2td}|jt|j|jdS(Nsamqp://example.com(RR%RR$(RRs((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyt test_copys cC@sBtd}|j|jt|}|j|j|jdS(Ns)amqp://A.example.com;amqp://B.example.com(RR.RARR%(RRstd((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_copy_multiples"s  cC@sotd}t|_|jd|j|j|j|jd|j|jd|j|jddS(Ns amqp://foosredis://example.com//3s example.comtrediss/3( RR't_closedtswitchROR%RRpR(RRs((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyt test_switch(s   cC@sctd}|j|j|j|j|jd|j|jd|j|jddS(Ns!amqp://foo;redis://example.com//3s example.comRs/3(Rtmaybe_switch_nextRORR%RRpR(RRs((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_maybe_switch_next1s   cC@sPtd}|j|j|j|j|jd|j|jddS(Ns amqp://fooRSt librabbitmqtpyamqpR(RRR(RRRORR%RtassertInRp(RRs((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_maybe_switch_next_no_cycle9s   cC@sKtdt}t|j_|jd|jjj|jdddS(NRitrate(RRR Rtheartbeat_checkR`RI(RRs((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_heartbeat_check@s cC@s<td}|j|jd|j|jddS(Nsamqp://ii(RR.tcompletes_cycle(RRs((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_completes_cycle_no_cycleFs cC@sRtd}|j|jd|j|jd|j|jddS(Nsamqp://a;amqp://b;amqp://ciii(RRORR.(RRs((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_completes_cycleKs cC@sj|j}|j}|j|||j|j|jj|j|j|j|j dS(N( R(t __enter__RRHR.RIRJt__exit__RbRN(RR(tcontext((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest__enter____exit__Qs    c@sidtfdYdtffdY}td|}|j|j|j|jdS(Nt _CustomErrorcB@seZRS((RDRE(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyR]st MyTransportc@s eZfZfdZRS(c@sddS(NRS((RRI(R(s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pytclose_connectioncs(RDREtconnection_errorsR((R(s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyR`s R(t ExceptionRRRHRNR.R(RRR(((Rs=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_close_survives_connerror[s   cC@s3|j}t|_|j|jjjdS(N(R(R t_default_channelR\RNR`(RR(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_close_when_default_channelks   cC@s^dtfdY}|d}t|_t|jj_|j|jjjdS(NtConncB@seZedZRS(cS@stfS(N(R2(R((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyRus(RDREtpropertyR(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyRsss memory://(RR RR2RNRjR\R`(RRR(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyt,test_close_when_default_channel_close_raisesqs    cC@sJ|j}t}|_|jt|jj|j|jdS(N(R(R RtreviveRNR`Rb(RR(tdefchan((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyt test_revive_when_default_channels   cC@s|j|jjdS(N(R.R(Rz(R((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_ensure_connectionscC@s5d}|jjd|}|j|ddS(NcS@sdS(Ntfoobar((((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pytpublishsR(R(tensureRgR%(RRtensured((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_ensure_successs c@s[dtfdYfd}|jjd|}|j |WdQXdS(NRcB@seZRS((RDRE(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyRsc@sddS(Ntbar(((R(s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyRs(RR(RRgR1(RRR((Rs=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_ensure_failures c@spdtfdYfd}f|jj_|jj|j|}|j |WdQXdS(Nt_ConnectionErrorcB@seZRS((RDRE(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyRsc@sddS(Nsfailed connection(((R(s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyRs(RR(RRRR1(RRR((Rs=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_ensure_connection_failures c@s`ttf|jj_fd}|_|jj}||jjdS(Nc@sd_tddS(NRS(RgRjR2(R~tkwargs(tmyfun(s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyton_calls ( R R2R(RRRjt autoretryR.R_(RRtinsured((Rs=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_autoretrys  cC@sf|j}|jd}|j|j|j|j}|jdd|}|j|j|dS(NRSRK(R(t SimpleQueueRRKtdefault_channel(RR(tqtchantq2((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_SimpleQueues   cC@sf|j}|jd}|j|j|j|j}|jdd|}|j|j|dS(NRSRK(R(t SimpleBufferRRKR(RR(RRR((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_SimpleBuffers   cC@s?|j}|j|jt|j|j|jtdS(N(R(RPRR(RR(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyt test_Producers cC@sN|j}|j|jdgt|j|jdgd|jtdS(NtqueuesRK(R(RPRR(RR(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyt test_Consumers cC@s|jt|jdS(N(R.treprR((R((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyt test__repr__scC@s>tjtj|j}|j|j|jjdS(N(tpickletloadstdumpsR(R R$(RR/((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest__reduce__scC@sBdtfdY}td|}|j|jttfdS(NRcB@seZeefZRS((RDRER2t ValueErrortchannel_errors(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyRsR(RRtassertTupleEqualRR2R(RRR(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_channel_errorsscC@sBdtfdY}td|}|j|jttfdS(NRcB@seZeefZRS((RDRER2RR(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyRsR(RRRRR2R(RRR(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_connection_errorss()RDRERRRRWRfRkRmRtRxRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRR(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyRFsN                               t&test_Connection_with_transport_optionscB@s.eZidd6ed6ZdZdZRS(it pool_recyclertechocC@s%tdddtd|j|_dS(NRi(Rttransport_options(RRRR((R((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyRscC@s#|j}|j|j|jdS(N(R(R%R(RR(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyRRs (RDRER'RRRR(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyRs t xResourcecB@seZdZRS(cC@sdS(N((R((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pytsetups(RDRER(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyRst ResourceCasecB@szeZeZdZdZdZdZdZdZ dZ dZ dZ d Z d Zd ZRS( cC@stddS(Nssubclass responsibility(tNotImplementedError(Rtlimittpreload((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pytcreate_resourcescC@s6|j|jj||jt|j|dS(N(R%t _resourcetqsizetlent_dirty(RtPtavailtdirty((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyt assertStatescC@s-|jr)|jt tWdQXndS(N(tabstractR1RR(R((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyt test_setups cC@s|jr dS|jdd}|j|ddgtdD]}|j^q?}|j|dd|j|j|jWdQX|jj|j|ddg|D]}|j^q|j|dddS(Ni iii ( RRRR tacquireR1t LimitExceededtpoptrelease(RRt_tchansR((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_acquire__release s %cC@s|jr dS|jdd}|jt|jjdt|_t|j_ |j t|j dt WdQX|jt|jjddS(Ni itblock( RRR%RRtqueueR tpreparetIOErrorRjR1RR'(RR((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_acquire_prepare_raisess  cC@s3|jr dS|jdd}|jjdS(Ni(RRRgRR(RR((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_acquire_no_limit's cC@sw|jr dS|jdd}|j}t|_t|_|j||jjj||jj|dS(Ni i( RRRR Rtclose_resourcetreplacetdiscardR`(RRtr((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_replace_when_limit-s     cC@sz|jr dS|jdd}|j}t|_t|_|j||j|jj j |jj |dS(Ni( RRRgRR RRRRORR_R`(RRR((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_replace_no_limit9s     cC@s3|js dSt}|j|jdddS(Ni (RRR%R(RR/((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_interface_prepareEs  cC@sf|jr dS|jdd}t}|_td|_|j|j|j|j dS(Ni R/( RRR tcollect_resourcetAttributeErrorRjRR.Rtforce_close_all(RRtcr((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyt+test_force_close_all_handles_AttributeErrorKs  cC@sa|jr dS|jdd}t|_t}|_d|_t|jj _ |j dS(Ni ( RRR RRRgtmutext IndexErrorRRRjR(RRtm((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_force_close_all_no_mutexWs   cC@s`|jr dS|jdd}g|jj(|j|jj|j|j|jjdS(N(RRRgRRROt_add_when_emptyR.(RR((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_add_when_emptycs   (RDRER'RRRRRRRRRRRR R (((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyRs       ttest_ConnectionPoolcB@sMeZeZdZdZdZdZdZdZ dZ RS(cC@stdddtj||S(NRi(R(RRtPool(RRR((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyRpscC@sa|jdd}|jj}|j|dj|j|dj|j|djdS(Ni iii(RRRtassertIsNotNoneRQRb(RRR((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyRss  c C@s|jdd}|j}|jt|_t|j_t|_|jt$|jtsxt WdQXWdQX|jj |dS(Nii( RRRR Rt MemoryErrorRjR1RtAssertionErrorR`(RRR((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_acquire_raises_evaluatedzs     cC@s;|jdd}t}t|j_|j|dS(Ni i(RR Rt_debugRjtrelease_resource(RRtR((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_release_no__debugs cC@s9|jdd}|j|jj|j|jdS(N(RRgRORRRbR(RR((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_setup_no_limitscC@s;|jdd}td}|j|j||dS(Ns memory://(RRgRRR(RRR(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_prepare_not_callables cC@sD|jdd}|j \}}|j||jWdQXdS(Ni i(Rtacquire_channelRR(RRR(RK((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyttest_acquire_channels( RDRERRRRRRRRR(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyR ms     ttest_ChannelPoolcB@s2eZeZdZdZdZdZRS(cC@stdddtj||S(NRi(R(RRt ChannelPool(RRR((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyRscC@sq|jdd}|jj}|j|dj|j|dj|jtt|ddWdQXdS(Ni iiit basic_consume(RRRR.RR1Rtgetattr(RRR((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyRs  cC@s9|jdd}|j|jj|j|jdS(N(RRgRORRRbR(RR((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyRscC@sD|jdd}td}|j}|j|j||dS(Ni is memory://(RRRRR(RRR(R((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyRs  (RDRERRRRRR(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyRs    (t __future__RRRhRRtkombuRRRRtkombu.connectionRt kombu.fiveRR tcaseR R R R RtmocksRRRFRRRR R(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/test_connection.pyts   "(Y o0