σ O'—^c@@sάdZddlmZddlZddlmZddlmZddlm Z ddl m Z d Z d Z d e jfd „ƒYZd eje jfd„ƒYZdejfd„ƒYZde jfd„ƒYZdS(sM kombu.transport.pyamqp ====================== pure python amqp transport. i(tabsolute_importN(titems(t get_manager(tversion_string_as_tuplei(tbasei(i'tMessagecB@seZd„ZRS(cK@s}|j}tt|ƒj|d|jd|jd|jdƒd|jdƒd|jd|jd|jdƒpri|dS( Ntbodyt delivery_tagt content_typetcontent_encodingt delivery_infot propertiestheaderstapplication_headers(R tsuperRt__init__RRtgetR (tselftchanneltmsgtkwargstprops((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/pyamqp.pyRs     (t__name__t __module__R(((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/pyamqp.pyRstChannelcB@s5eZeZdddddejd„Zd„ZRS(c C@s+||d|d|d|d||p'iS(s=Prepares message so that it can be sent using this transport.tpriorityRR R ((RRRRR R R t_Message((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/pyamqp.pytprepare_message)scC@s|j||ƒS(s4Convert encoded message body back to a Python value.(R(Rt raw_message((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/pyamqp.pytmessage_to_python6sN(RRRtNonetamqpRR(((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/pyamqp.pyR&s  t ConnectioncB@seZeZRS((RRR(((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/pyamqp.pyR ;st TransportcB@sζeZeZeZeZejjZejj Z ejj Z ejj Z dZ dZ eZeZddd„Zd„Zd„Zd„Zd„Zd„Zd„Zd „Zd „Zd d „Zd „Zed„ƒZd„ZRS(spy-amqpRcK@s1||_|p|j|_|p'|j|_dS(N(tclientt default_porttdefault_ssl_port(RR"R#R$R((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/pyamqp.pyRRs cC@stjS(N(Rt __version__(R((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/pyamqp.pytdriver_versionXscC@s |jƒS(N(R(Rt connection((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/pyamqp.pytcreate_channel[scK@s |j|S(N(t drain_events(RR'R((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/pyamqp.pyR)^scC@sϊ|j}xBt|jƒD]1\}}t||d ƒst|||ƒqqW|jdkrid|_nti |jd6|j d6|j d6|j d6|j d6|j d6|jd 6|jd 6|jd 6|jpΥi}|j|}|j|_|S( s(Establish connection to the AMQP broker.t localhosts 127.0.0.1thosttuseridtpasswordt login_methodt virtual_hosttinsisttssltconnect_timeoutt heartbeatN(R"Rtdefault_connection_paramstgetattrRtsetattrthostnametdictR+R,R-R.R/R0R1R2R3ttransport_optionsR (Rtconninfotnamet default_valuetoptstconn((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/pyamqp.pytestablish_connectionas(            cC@s|jS(N(t connected(RR'((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/pyamqp.pytverify_connectionxscC@sd|_|jƒdS(s!Close the AMQP broker connection.N(RR"tclose(RR'((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/pyamqp.pytclose_connection{s cC@s|jS(N(R3(RR'((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/pyamqp.pytget_heartbeat_interval€scC@s |j|j|j||ƒdS(N(t add_readertsockt on_readable(RR'tloop((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/pyamqp.pytregister_with_event_loopƒsicC@s|jd|ƒS(Ntrate(theartbeat_tick(RR'RJ((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/pyamqp.pytheartbeat_check†scC@s6|j}|jdƒdkr2t|dƒdkStS(NtproducttRabbitMQtversioni(ii(tserver_propertiesRRtTrue(RR'R((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/pyamqp.pytqos_semantics_matches_spec‰s cC@s?idd6dd6|jjr&|jn|jd6dd6dd6S( NtguestR,R-tportR*R7tAMQPLAINR.(R"R1R$R#(R((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/pyamqp.pyR4s cO@st|j||ŽS(N(RR"(RtargsR((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/pyamqp.pyRšsN( RRR t DEFAULT_PORTR#tDEFAULT_SSL_PORTR$Rtconnection_errorstchannel_errorstrecoverable_connection_errorstrecoverable_channel_errorst driver_namet driver_typeRQtsupports_heartbeatst supports_evRRR&R(R)R?RARCRDRIRLRRtpropertyR4R(((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/pyamqp.pyR!?s0               (t__doc__t __future__RRt kombu.fiveRtkombu.utils.amq_managerRtkombu.utils.textRtRRWRXRRt StdChannelR R!(((s8/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/pyamqp.pyts