Why Gemfury? Push, build, and install  RubyGems npm packages Python packages Maven artifacts PHP packages Go Modules Debian packages RPM packages NuGet packages

trilio-internal / tvault-contego-common deb

Repository URL to install this package:

Version: 
3.0.172  ▾
Details    
tvault-contego-common / home / tvault / .virtenv / lib / python2.7 / site-packages / amqp / abstract_channel.pyc
Size: Mime: 
ó
õEYc@@s‘dZddlmZmZddlmZmZddlmZm	Z	ddl
mZddlm
Z
mZdgZd	efd
„ƒYZdS(u.Code common to Connection and Channel objects.i(tabsolute_importtunicode_literals(tensure_promisetpromisei(tAMQPNotImplementedErrortRecoverableConnectionError(tbytes_if_py2(tdumpstloadsuAbstractChanneltAbstractChannelcB@sneZdZd„Zd„Zd„Zddddded„Zd„Z	dded„Z
d„ZiZRS(	uSuperclass for Connection and Channel.

    The connection is treated as channel 0, then comes
    user-created channel objects.

    The subclasses must have a _METHOD_MAP class property, mapping
    between AMQP method signatures and Python methods.
    cC@sQ||_||_||j|<g|_t|_i|_i|_|jƒdS(N(	t
connectiont
channel_idtchannelstmethod_queuetFalsetauto_decodet_pendingt
_callbackst_setup_listeners(tselfR
R((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/abstract_channel.pyt__init__&s		
				cC@s|S(N((R((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/abstract_channel.pyt	__enter__1scG@s|jƒdS(N(tclose(Rtexc_info((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/abstract_channel.pyt__exit__4sc
C@sÈtƒ}|j}	|	dkr-tdƒ‚n|rBt||ƒn	tdƒ}y |	jd|j|||ƒWntk
rtdƒ‚nX|r¤|j	|ƒn|ƒ|rÄ|j
|d|ƒS|S(Nuconnection already closeduit
returns_tuple(RR
tNoneRRRtframe_writerRt
StopIterationtthentwait(
RtsigtformattargstcontentRtcallbackRtptconn((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/abstract_channel.pytsend_method7s		! 
cC@stdƒ‚dS(u!Close this Channel or Connection.uMust be overriden in subclassN(tNotImplementedError(R((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/abstract_channel.pyRLscC@st|ƒ}|j}g}t|tƒs6|g}nx.|D]&}|j|j|ƒƒ|||<q=WzWx |jsŒ|jjd|ƒqmW|j	r½|j	\}	}
|r¯|	S|	o¼|	dSWdxKt
|ƒD]=\}}||dk	rû||||<qÎ|j|dƒqÎWXdS(Nttimeouti(
RRt
isinstancetlisttappendtgettreadyR
tdrain_eventstvaluet	enumerateRtpop(RtmethodR#R(RR$tpendingtprev_ptmR!tkwargsti((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/abstract_channel.pyRPs$	
	c
C@sw|rQ|jrQt|dƒrQy|jj|jƒ|_WqQtk
rMqQXny|j|}Wn&tk
rŠtdj	|ƒƒ‚nXy|j
|g}Wntk
r¸d}nXy|jj
|ƒ}Wntk
rì|sdSn&X|dkr|g}n
|j|ƒg}|jr?t|j|dƒ\}}n|jrX|j|ƒnx|D]}	|	|Œq_WdS(Nucontent_encodinguUnknown AMQP method {0!r}i(Rthasattrtbodytdecodetcontent_encodingt	Exceptiont_METHODStKeyErrorRR RRRR1R+R!RR"(
Rt
method_sigtpayloadR"tamqp_methodt	listenerstone_shotR!t_tlistener((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/abstract_channel.pytdispatch_methodis>	





		
N(
t__name__t
__module__t__doc__RRRRRR&RRRFR=(((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/abstract_channel.pyR	s						)N(RIt
__future__RRtvineRRt
exceptionsRRtfiveRt
serializationRRt__all__tobjectR	(((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/abstract_channel.pyt<module>s	

Products

About

Resources

Contact Gemfury