Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
triliodata-4-0-patch / contego deb
Repository URL to install this package:
|
Version:
4.0.109 ▾
|
ó
õEYc @@ s d Z d d l m Z m Z d d l m Z m Z d d l m Z m Z d d l
m Z d d l m
Z
m Z d g Z d e f d
YZ d S( u. Code common to Connection and Channel objects.i ( t absolute_importt unicode_literals( t ensure_promiset promisei ( t AMQPNotImplementedErrort RecoverableConnectionError( t bytes_if_py2( t dumpst loadsu AbstractChannelt AbstractChannelc B@ sn e Z d Z d Z d Z d Z d d d d d e d Z d Z d d e d Z
d Z i Z RS( u Superclass 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.
c C@ sQ | | _ | | _ | | j | <g | _ t | _ i | _ i | _ | j d S( N( t
connectiont
channel_idt channelst method_queuet Falset auto_decodet _pendingt
_callbackst _setup_listeners( t selfR
R ( ( sJ /home/tvault/.virtenv/lib/python2.7/site-packages/amqp/abstract_channel.pyt __init__& s
c C@ s | S( N( ( R ( ( sJ /home/tvault/.virtenv/lib/python2.7/site-packages/amqp/abstract_channel.pyt __enter__1 s c G@ s | j d S( N( t close( R t exc_info( ( sJ /home/tvault/.virtenv/lib/python2.7/site-packages/amqp/abstract_channel.pyt __exit__4 s c
C@ sÈ t } | j } | d k r- t d n | rB t | | n t d } y | j d | j | | | Wn t k
r t d n X| r¤ | j | n | | rÄ | j
| d | S| S( Nu connection already closedu i t
returns_tuple( R R
t NoneR R R t frame_writerR t
StopIterationt thent wait(
R t sigt formatt argst contentR t callbackR t pt conn( ( sJ /home/tvault/.virtenv/lib/python2.7/site-packages/amqp/abstract_channel.pyt send_method7 s !
c C@ s t d d S( u! Close this Channel or Connection.u Must be overriden in subclassN( t NotImplementedError( R ( ( sJ /home/tvault/.virtenv/lib/python2.7/site-packages/amqp/abstract_channel.pyR L s c C@ s t | } | j } g } t | t s6 | g } n x. | D]& } | j | j | | | | <q= WzW x | j s | j j d | qm W| j r½ | j \ } }
| r¯ | S| o¼ | d SWd xK t
| D]= \ } } | | d k rû | | | | <qÎ | j | d qÎ WXd S( Nt timeouti (
R R t
isinstancet listt appendt gett readyR
t drain_eventst valuet enumerateR t pop( R t methodR# R( R R$ t pendingt prev_pt mR! t kwargst i( ( sJ /home/tvault/.virtenv/lib/python2.7/site-packages/amqp/abstract_channel.pyR P s$
c
C@ sw | rQ | j rQ t | d rQ y | j j | j | _ WqQ t k
rM qQ Xn y | j | } Wn& t k
r t d j | n Xy | j
| g } Wn t k
r¸ d } n Xy | j j
| } Wn t k
rì | sd Sn& X| d k r| g } n
| j | g } | j r?t | j | d \ } } n | j rX| j | n x | D] } | | q_Wd S( Nu content_encodingu Unknown AMQP method {0!r}i ( R t hasattrt bodyt decodet content_encodingt Exceptiont _METHODSt KeyErrorR R R R R R1 R+ R! R R" (
R t
method_sigt payloadR" t amqp_methodt listenerst one_shotR! t _t listener( ( sJ /home/tvault/.virtenv/lib/python2.7/site-packages/amqp/abstract_channel.pyt dispatch_methodi s>
N(
t __name__t
__module__t __doc__R R R R R R& R R RF R= ( ( ( sJ /home/tvault/.virtenv/lib/python2.7/site-packages/amqp/abstract_channel.pyR s )N( RI t
__future__R R t vineR R t
exceptionsR R t fiveR t
serializationR R t __all__t objectR ( ( ( sJ /home/tvault/.virtenv/lib/python2.7/site-packages/amqp/abstract_channel.pyt <module> s