ó O'—^c@@sĪdZddlmZddlmZddlmZddlmZddlm Z dd gZ d „Z d „Z de fd „ƒYZd efd „ƒYZdS(s3 kombu.abstract ============== Object utilities. i(tabsolute_import(tcopyi(t maybe_channel(t NotBoundError(tChannelPromisetObjecttMaybeChannelBoundcC@s ||S(N((tclstkwargs((s0/tmp/pip-unpacked-wheel-UAnTfW/kombu/abstract.pyt unpickle_dictscC@s|S(N((tv((s0/tmp/pip-unpacked-wheel-UAnTfW/kombu/abstract.pyt_anyscB@s;eZdZdZd„Zed„Zd„Zd„ZRS(sTCommon base class supporting automatic kwargs->attributes handling, and cloning.cO@sx†|jD]{\}}|j|ƒ}|dk rPt|||pCt|ƒƒq yt||ƒWq tk r„t||dƒq Xq WdS(N(tattrstgettNonetsetattrR tgetattrtAttributeError(tselftargsRtnamettype_tvalue((s0/tmp/pip-unpacked-wheel-UAnTfW/kombu/abstract.pyt__init__ s  c@s/‡fd†‰t‡‡fd†ˆjDƒƒS(Nc@s9ˆr%t|tƒr%|jdtƒS|r5||ƒS|S(Ntrecurse(t isinstanceRtas_dicttTrue(tobjttype(R(s0/tmp/pip-unpacked-wheel-UAnTfW/kombu/abstract.pytf,sc3@s3|])\}}|ˆtˆ|ƒ|ƒfVqdS(N(R(t.0tattrR(RR(s0/tmp/pip-unpacked-wheel-UAnTfW/kombu/abstract.pys 1s(tdictR (RR((RRRs0/tmp/pip-unpacked-wheel-UAnTfW/kombu/abstract.pyR+scC@st|j|jƒffS(N(R t __class__R(R((s0/tmp/pip-unpacked-wheel-UAnTfW/kombu/abstract.pyt __reduce__4scC@s|j|jƒS(N(R"R(R((s0/tmp/pip-unpacked-wheel-UAnTfW/kombu/abstract.pyt__copy__7s(( t__name__t __module__t__doc__R RtFalseRR#R$(((s0/tmp/pip-unpacked-wheel-UAnTfW/kombu/abstract.pyRs  cB@sweZdZd ZeZeZd„Zd„Z d„Z d„Z d„Z dd„Z ed„ƒZed „ƒZRS( s7Mixin for classes that can be bound to an AMQP channel.cC@s |j|ƒS(s%`self(channel) -> self.bind(channel)`(tbind(Rtchannel((s0/tmp/pip-unpacked-wheel-UAnTfW/kombu/abstract.pyt__call__CscC@st|ƒj|ƒS(s7Create copy of the instance that is bound to a channel.(Rt maybe_bind(RR*((s0/tmp/pip-unpacked-wheel-UAnTfW/kombu/abstract.pyR)GscC@s9|j r5|r5t|ƒ|_|jƒt|_n|S(s.Bind instance to channel if not already bound.(tis_boundRt_channelt when_boundRt _is_bound(RR*((s0/tmp/pip-unpacked-wheel-UAnTfW/kombu/abstract.pyR,Ks   cC@s#|jr||_|jƒndS(syRevive channel after the connection has been re-established. Used by :meth:`~kombu.Connection.ensure`. N(R-R.R/(RR*((s0/tmp/pip-unpacked-wheel-UAnTfW/kombu/abstract.pytreviveSs  cC@sdS(s(Callback called when the class is bound.N((R((s0/tmp/pip-unpacked-wheel-UAnTfW/kombu/abstract.pyR/]stcC@sP|pt|ƒj}|jrCdj|p6t|ƒj|jjƒSdj|ƒS(Ns<{0} bound to chan:{1}>s (RR%R-tformatR*t channel_id(Rtitem((s0/tmp/pip-unpacked-wheel-UAnTfW/kombu/abstract.pyt__repr__as  cC@s|jo|jdk S(s!Flag set if the channel is bound.N(R0R.R(R((s0/tmp/pip-unpacked-wheel-UAnTfW/kombu/abstract.pyR-hscC@s\|j}|dkr6tdjt|ƒjƒƒ‚nt|tƒrX|ƒ}|_n|S(s'Current channel if the object is bound.s/Can't call method on {0} not bound to a channelN(R.RRR3RR%RR(RR*((s0/tmp/pip-unpacked-wheel-UAnTfW/kombu/abstract.pyR*ms  N(R%R&R'RR.R(R0tcan_cache_declarationR+R)R,R1R/R6tpropertyR-R*(((s0/tmp/pip-unpacked-wheel-UAnTfW/kombu/abstract.pyR;s     N(R't __future__RRt connectionRt exceptionsRtutilsRt__all__R R tobjectRR(((s0/tmp/pip-unpacked-wheel-UAnTfW/kombu/abstract.pyts