σ O'—^c@@s(dZddlmZddlZddlZddlZddlZddlmZm Z ddl m Z m Z ddl mZddlmZdd lmZd Zd Zd Zd Zdejfd„ƒYZdejejfd„ƒYZdejfd„ƒYZdejfd„ƒYZdS(s kombu.transport.librabbitmq =========================== `librabbitmq`_ transport. .. _`librabbitmq`: http://pypi.python.org/librabbitmq/ i(tabsolute_importN(t ChannelErrortConnectionError(titemstvalues(t get_manager(tversion_string_as_tuplei(tbases‘ librabbitmq version too old to detect RabbitMQ version information so make sure you are using librabbitmq 1.5 when using rabbitmq > 3.3 i(i'sAssl not supported by librabbitmq, please use pyamqp:// or stunneltMessagecB@seZd„ZRS(cC@shtt|ƒj|d|d|d|d|jdƒd|jdƒd|jdƒd|jdƒƒdS(Ntbodyt delivery_infot propertiest delivery_tagt content_typetcontent_encodingtheaders(tsuperRt__init__tget(tselftchanneltpropstinfoR ((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/librabbitmq.pyR's(t__name__t __module__R(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/librabbitmq.pyR%stChannelcB@s&eZeZdddddd„ZRS(cC@sK|dk r|ni}|ji|d6|d6|d6|d6ƒ||fS(s%Encapsulate data into a AMQP message.R RRtpriorityN(tNonetupdate(RR RR RRR ((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/librabbitmq.pytprepare_message6s  N(RRRRR(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/librabbitmq.pyR3st ConnectioncB@seZeZeZRS((RRRR(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/librabbitmq.pyRBst TransportcB@sΠeZeZeZeZejj e e j e efZ ejjefZdZdZeZd„Zd„Zd„Zd„Zd„Zd„Zd„Zd „Zd „Zd „Zd „Ze d „ƒZ!RS(tamqpt librabbitmqcK@sL||_|jdƒp|j|_|jdƒp9|j|_d|_dS(Nt default_porttdefault_ssl_port(tclientRR"R#Rt_Transport__reader(RR$tkwargs((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/librabbitmq.pyRYs   cC@stjS(N(R t __version__(R((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/librabbitmq.pytdriver_version`scC@s |jƒS(N(R(Rt connection((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/librabbitmq.pytcreate_channelcscK@s |j|S(N(t drain_events(RR)R&((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/librabbitmq.pyR+fscC@sό|j}xBt|jƒD]1\}}t||d ƒst|||ƒqqW|jrfttƒ‚nt i|j d6|j d6|j d6|j d6|jd6|jd6|jd6|jd6|jpΘi}|j|}|j|_|j|j_|S( s(Establish connection to the AMQP broker.thosttuseridtpasswordt virtual_hostt login_methodtinsisttssltconnect_timeoutN(R$Rtdefault_connection_paramstgetattrRtsetattrR2tNotImplementedErrort NO_SSL_ERRORtdictR,R-R.R/R0R1R3ttransport_optionsRR+(Rtconninfotnamet default_valuetoptstconn((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/librabbitmq.pytestablish_connectionis(           cC@sd|j_|jƒdS(s!Close the AMQP broker connection.N(RR$R+tclose(RR)((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/librabbitmq.pytclose_connection€s cC@s|dk rwx t|jƒD]}d|_qWytj|jƒƒWntk rYnX|jjƒ|j jƒnd|j _ d|_ dS(N( RRtchannelsR)tosRAtfilenotOSErrortcleart callbacksR$R+(RR)R((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/librabbitmq.pyt_collect…s     cC@s|jS(N(t connected(RR)((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/librabbitmq.pytverify_connection’scC@s#|j|jƒ|j||ƒdS(N(t add_readerREt on_readable(RR)tloop((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/librabbitmq.pytregister_with_event_loop•scO@st|j||ŽS(N(RR$(RtargsR&((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/librabbitmq.pyRšscC@say |j}Wn$tk r3tjttƒƒn*X|jdƒdkr]t|dƒdkStS(NtproducttRabbitMQtversioni(ii( tserver_propertiestAttributeErrortwarningstwarnt UserWarningt W_VERSIONRRtTrue(RR)R((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/librabbitmq.pytqos_semantics_matches_specs  cC@s?idd6dd6|jjr&|jn|jd6dd6dd6S( NtguestR-R.tportt localhostthostnametAMQPLAINR0(R$R2R#R"(R((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/librabbitmq.pyR4§s ("RRRt DEFAULT_PORTR"tDEFAULT_SSL_PORTR#RRtconnection_errorsRtsocketterrortIOErrorRFtchannel_errorsRt driver_typet driver_nameRZt supports_evRR(R*R+R@RBRIRKRORR[tpropertyR4(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/librabbitmq.pyRGs*           (t__doc__t __future__RRDRdRVR!R RRt kombu.fiveRRtkombu.utils.amq_managerRtkombu.utils.textRtRRYRaRbR8RRt StdChannelRR(((s=/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/librabbitmq.pyt s$