σ O'—^c@@s‘ddlmZddlmZddlZddlmZdejfd„ƒYZdejfd„ƒYZ d e fd „ƒYZ d ej fd „ƒYZ dS( i(tabsolute_import(tcountN(tbasetMessagecB@seZd„Zd„ZRS(cO@s2|jdtƒ|_tt|ƒj||ŽdS(Ntthrow_decode_error(tgettFalseRtsuperRt__init__(tselftargstkwargs((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyR scC@s+|jrtdƒ‚ntt|ƒjƒS(Nscan't decode message(Rt ValueErrorRRtdecode(R ((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyR s (t__name__t __module__RR (((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyR s tChannelcB@s(eZeZeZedƒZd„Zd„Z d„Z d„Z ddddid„Z ddeed„Zd „Zd „Zd „Zd „Zeed „Zd„Zd„Zd„Zd„Zd„Zed„Zd„Zd„Zd„Zd„Zd„Zed„Zdded„Z RS(icC@sS||_g|_tdƒ|_g|_itƒd6|_t|jƒ|_ dS(Nit basic_return( t connectiontcalledRt deliveriest to_delivertsetteventstnextt_idst channel_id(R R((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyRs    cC@s|jj|ƒdS(N(Rtappend(R tname((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyt_called#scC@s ||jkS(N(R(R tkey((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyt __contains__&scO@s|jdƒdS(Ntexchange_declare(R(R R R ((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyR )sic C@s8|jdƒtd|d|d|d|d|d|ƒS(Ntprepare_messagetbodytheaderst propertiestpriorityt content_typetcontent_encoding(Rtdict(R R"R%R&R'R#R$((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyR!,s  tcK@s|jdƒ|||fS(Nt basic_publish(R(R tmessagetexchanget routing_keyt mandatoryt immediateR ((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyR*6s cO@s|jdƒdS(Ntexchange_delete(R(R R R ((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyR0;scO@s|jdƒdS(Nt queue_declare(R(R R R ((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyR1>scO@s|jdƒdS(Nt queue_bind(R(R R R ((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyR2AscO@s|jdƒdS(Nt queue_unbind(R(R R R ((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyR3DscK@s|jdƒdS(Nt queue_delete(R(R tqueuet if_unusedtif_emptyR ((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyR4GscO@s6|jdƒy|jjƒSWntk r1nXdS(Nt basic_get(RRtpopt IndexError(R R R ((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyR8Js   cO@s|jdƒdS(Nt queue_purge(R(R R R ((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyR;QscO@s|jdƒdS(Nt basic_consume(R(R R R ((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyR<TscO@s|jdƒdS(Nt basic_cancel(R(R R R ((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyR=WscO@s|jdƒdS(Nt basic_ack(R(R R R ((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyR>ZscC@s|jdƒdS(Nt basic_recover(R(R trequeue((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyR?]scO@s|jdƒdS(Nt exchange_bind(R(R R R ((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyRA`scO@s|jdƒdS(Ntexchange_unbind(R(R R R ((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyRBcscC@s|jdƒdS(Ntclose(R(R ((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyRCfsc O@sJ|jdƒt|dtj|ƒdt|jƒd|jddddƒS( Ntmessage_to_pythonR"t delivery_tagRR&sapplication/jsonR'sutf-8(RRtanyjsontdumpsRRR(R R+R R ((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyRDis   cC@s|jdƒdS(Ntflow(R(R tactive((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyRHqscC@s |r|jdƒS|jdƒS(Nsbasic_reject:requeuet basic_reject(R(R RER@((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyRJts cC@s|jdƒdS(Nt basic_qos(R(R t prefetch_sizetprefetch_countt apply_global((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyRKysN(!RRtTruetopenRRRRRRRR tNoneR!R*R0R1R2R3R4R8R;R<R=R>R?RARBRCRDRHRJRK(((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyRs<                      t ConnectioncB@s eZeZd„Zd„ZRS(cC@s ||_dS(N(tclient(R RS((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyRscC@s t|ƒS(N(R(R ((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pytchannel„s(RRROt connectedRRT(((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyRR~s t TransportcB@s,eZd„Zd„Zd„Zd„ZRS(cC@s t|jƒS(N(RRRS(R ((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pytestablish_connectionŠscC@s |jƒS(N(RT(R R((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pytcreate_channelscK@sdS(Ntevent((R RR ((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyt drain_eventsscC@s t|_dS(N(RRU(R R((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pytclose_connection“s(RRRWRXRZR[(((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyRVˆs   ( t __future__Rt itertoolsRRFtkombu.transportRRt StdChannelRtobjectRRRV(((s3/tmp/pip-unpacked-wheel-UAnTfW/kombu/tests/mocks.pyts  h