σ O'—^c@@sεdZddlmZddlZddlZddlmZddlmZm Z ddl m Z ddl m Z ddlmZd d d d gZd „Zd efd„ƒYZd efd„ƒYZd efd„ƒYZdS(sG kombu.transport.base ==================== Base transport interface. i(tabsolute_importN(tRecoverableConnectionError(t ChannelErrortConnectionError(tMessage(tcached_property(t get_errnoRt StdChannelt Managementt TransportcC@stdj|j|ƒƒS(Ns<Transport {0.__module__}.{0.__name__} does not implement {1}(tNotImplementedErrortformatt __class__(tobjtmethod((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pyt _LeftBlankscB@sDeZdZd„Zd„Zd„Zd„Zd„Zd„Z RS(cO@s ddlm}||||ŽS(Ni(tConsumer(tkombu.messagingR(tselftargstkwargsR((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pyR scO@s ddlm}||||ŽS(Ni(tProducer(RR(RRRR((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pyR$scC@st|dƒ‚dS(Nt get_bindings(R(R((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pyR(scC@sdS(sireply queue semantics: can be used to delete the queue after transient reply message received.N((Rtqueue((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pytafter_reply_message_received+scC@s|S(N((R((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pyt __enter__0scG@s|jƒdS(N(tclose(Rtexc_info((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pyt__exit__3sN( t__name__t __module__tNonetno_ack_consumersRRRRRR(((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pyRs     cB@seZd„Zd„ZRS(cC@s ||_dS(N(t transport(RR!((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pyt__init__9scC@st|dƒ‚dS(NR(R(R((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pyR<s(RRR"R(((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pyR7s cB@s%eZdZeZdZeZdZe fZ e fZ dZ dZeZeZdZd„Zd„Zd„Zd„Zd„Zd„Zdd „Zd „Zd „Zd „Zd „Zd„Zejej e!e"j#e"j$fd„Z%d„Z&d„Z'e(d„ƒZ)d„Z*e+d„ƒZ,RS(sBase class for transports.sN/AcK@s ||_dS(N(tclient(RR#R((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pyR"escC@st|dƒ‚dS(Ntestablish_connection(R(R((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pyR$hscC@st|dƒ‚dS(Ntclose_connection(R(Rt connection((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pyR%kscC@st|dƒ‚dS(Ntcreate_channel(R(RR&((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pyR'nscC@st|dƒ‚dS(Nt close_channel(R(RR&((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pyR(qscK@st|dƒ‚dS(Nt drain_events(R(RR&R((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pyR)tsicC@sdS(N((RR&trate((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pytheartbeat_checkwscC@sdS(NsN/A((R((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pytdriver_versionzscC@sdS(Ni((RR&((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pytget_heartbeat_interval}scC@sdS(N((Rtloop((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pytregister_with_event_loop€scC@sdS(N((RR.((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pytunregister_from_event_loopƒscC@stS(N(tTrue(RR&((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pytverify_connection†sc@s.ˆj‰‡‡‡‡‡‡‡fd†‰ˆS(Nc@s}ˆjstdƒ‚nyˆddƒWn=ˆk r=dSˆk rh}ˆ|ƒˆkrbdS‚nX|jˆ|ƒdS(NsSocket was disconnectedttimeouti(t connectedRt call_soon(R.texc(t_readt_unavailR&R)terrorRR3(s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pyR7Žs  (R)(RR&R3R9RR8((R7R8R&R)R9RR3s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pyt _make_reader‰s ! cC@stS(N(R1(RR&((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pytqos_semantics_matches_specscC@s<|j}|dkr.|j|ƒ}|_n||ƒdS(N(t_Transport__readerRR:(RR&R.treader((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pyt on_readable s  cC@siS(N((R((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pytdefault_connection_params¦scO@s |j|ƒS(N(R(RRR((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pyt get_managerͺscC@s |jƒS(N(R@(R((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pytmanager­sN(-RRt__doc__RRR#tFalset can_parse_urlt default_portRtconnection_errorsRtchannel_errorst driver_typet driver_nametsupports_heartbeatst supports_evR<R"R$R%R'R(R)R+R,R-R/R0R2tsocketR3R9RterrnotEAGAINtEINTRR:R;R>tpropertyR?R@RRA(((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pyR @s@                  (RBt __future__RRMRLtamqp.exceptionsRtkombu.exceptionsRRt kombu.messageRt kombu.utilsRtkombu.utils.compatRt__all__RtobjectRRR (((s6/tmp/pip-unpacked-wheel-UAnTfW/kombu/transport/base.pyts