ó
öEYc@@s/dZd
dl
mZmZ
d
dlZd
dlZd
dlZd
dlmZ
d
dl	m
Z

d
dlmZm
Z

d
dlmZ
d
dlmZ
d	d
lmZmZmZmZmZ
d	dlmZ
d	dlmZ
d	d
lmZmZ
d	dlm Z 
d	dl!m"Z"m#Z#m$Z$m%Z%
d	dl&m'Z'
d	dl(m)Z)m*Z*m+Z+m,Z,
dddgZ-ee.ƒ
Z/e
Z0idd6dd6Z1ie0d6e%d6Z2ej3j4de5ƒZ6ej3j4de5ƒZ7ede8f
d„ƒYƒ
Z9e9Z:def
d„ƒYZ;d ef
d!„ƒYZ<d"„Z=d#„Z>dS($uClient (Connection).i(tabsolute_importtunicode_literalsN(
tOrderedDict(
tcontextmanager(tcounttcycle(
t
itemgetter(
t
exceptionsi
(tbytes_if_py2tpython_2_unicode_compatibletreraisetstring_tttext_t(
t
get_logger(
tResource(tget_transport_clstsupports_librabbitmq(
t	HashedSeq(t
dictfiltertlazytretry_over_timetshufflecycle(
tcached_property(tas_urlt	parse_urltquoteturlparseu
ConnectionuConnectionPooluChannelPooluamqpupyamqpulibrabbitmquround-robinushuffleuKOMBU_LOG_CONNECTIONuKOMBU_LOG_CHANNELt
ConnectioncB@s¥eZ
dZdJZd
ZdZdJZdJZdJZ	dJZ
eZdJZ
dJZdJZdJZdZdJZeZeZdJZZZZZddJdJdJdJeedJddJdJdJdddJd„Zd„Zd„Zd	„Zd
„Zd„Zd„Z d
„Z!dd„
Z"d„Z#d„Z$d„Z%d„Z&d„Z'dJd„
Z(d„Z)e)Z*dJdJddddJe+d„Z,e-e.j/e.j/d„ƒ
Z0e-d„ƒ
Z1d„Z2d„Z3d„Z4dJdJddddJd„Z5dJd „
Z6d!„Z7d"„Z8d#„Z9d$„Z:e+d%„
Z;d&„Z<d'„Z=ed(e>d)d*d+d,d-ƒd.„Z?dJd/„
Z@dJd0„
ZAdJd1„
ZBdJdJd2„ZCdJdJdJdJd3„ZDdJdJdJdJd4„ZEd5„ZFd6„ZGd7„ZHd8„ZId9„ZJd:„ZKd;„ZLeMd<„ƒ
ZNeMd=„ƒ
ZOeMd>„ƒ
ZPeMd?„ƒ
ZQeMd@„ƒ
ZReMdA„ƒ
ZSeTdB„ƒ
ZUdC„ZVeTdD„ƒ
ZWeTdE„ƒ
ZXeTdF„ƒ
ZYeTdG„ƒ
ZZeMdH„ƒ
Z[eMdI„ƒ
Z\RS(Ku
A connection to the broker.

    Example:
        >>> Connection('amqp://guest:guest@localhost:5672//')
        >>> Connection('amqp://foo;amqp://bar',
        ...            failover_strategy='round-robin')
        >>> Connection('redis://', transport_options={
        ...     'visibility_timeout': 3000,
        ... })

        >>> import ssl
        >>> Connection('amqp://', login_method='EXTERNAL', ssl={
        ...    'ca_certs': '/etc/pki/tls/certs/something.crt',
        ...    'keyfile': '/etc/something/system.key',
        ...    'certfile': '/etc/something/system.cert',
        ...    'cert_reqs': ssl.CERT_REQUIRED,
        ... })

    Note:
        SSL currently only works with the py-amqp, and qpid
        transports.  For other transports you can use stunnel.

    Arguments:
        URL (str, Sequence): Broker URL, or a list of URLs.

    Keyword Arguments:
        ssl (bool): Use SSL to connect to the server. Default is ``False``.
            May not be supported by the specified transport.
        transport (Transport): Default transport if not specified in the URL.
        connect_timeout (float): Timeout in seconds for connecting to the
            server. May not be supported by the specified transport.
        transport_options (Dict): A dict of additional connection arguments to
            pass to alternate kombu channel implementations.  Consult the
            transport documentation for available options.
        heartbeat (float): Heartbeat interval in int/float seconds.
            Note that if heartbeats are enabled then the
            :meth:`heartbeat_check` method must be called regularly,
            around once per second.

    Note:
        The connection is established lazily when needed. If you need the
        connection to be established, then force it by calling
        :meth:`connect`::

            >>> conn = Connection('amqp://')
            >>> conn.connect()

        and always remember to close the connection::

            >>> conn.release()

    These options have been replaced by the URL argument, but are still
    supported for backwards compatibility:

    :keyword hostname: Host name/address.
        NOTE: You cannot specify both the URL argument and use the hostname
        keyword argument at the same time.
    :keyword userid: Default user name if not provided in the URL.
    :keyword password: Default password if not provided in the URL.
    :keyword virtual_host: Default virtual host if not provided in the URL.
    :keyword port: Default port if not provided in the URL.
    u
/iuround-robinu	localhosticK@sS|dkrgn|}i|
d
6|d6|d6|d6|d6|d6|d6|d6|	d	6|d
6|
d6}|_
|
r¢t|
tƒr¢|j|
ƒ

|d}
n|
r
d
|
kr
d|
krã|j|
jdƒ
ƒ

|d}
nd|
|
jd
ƒ
 kr0
|
jddƒ\|d<|d
<|d}|_q
|pB
t|
ƒ
j	}t
|ƒ
js€
t|
ƒ
}|j
t|ƒ
d|d
ƒ


n||d<n|j|
||_|p¬
d|_|jj|jƒ
pÍ
|j|_|jr
|j|jƒ
|_t|jƒ

n|
dkri}
n|
|_tr1t|_n|rC||_ntƒ|_dS(Nuhostnameuuseridupassworduvirtual_hostuportuinsistusslu	transportuconnect_timeoutulogin_methodu	heartbeatiu://u
;u
+i
thostnameuround-robin(tNonet_initial_paramst
isinstanceRtextendtsplittindext
uri_prefixRtschemeRt
can_parse_urlRtupdateRt_init_paramstaltt_failover_strategytfailover_strategiestgettfailover_strategyRtnextttransport_optionst_log_connectiontTruet_loggertsettdeclared_entities(tselfRtuseridtpasswordtvirtual_hosttporttinsisttsslt	transporttconnect_timeoutR.tlogin_methodR#t	heartbeatR,t
alternatestkwargsR(tparamst
url_params((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyt__init__•sP














 






	
	

	


	
	

cC@sC|jƒ
|j
jƒ
t|_|jt|jt|
ƒ


d
S(ufSwitch connection parameters to use a new URL.

        Note:
            Does not reconnect!
        N(	tcloseR3tcleartFalset_closedR'tdictRR(R4turl((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pytswitch×s



	
c

C@s&|jr"|j
t|jƒ
ƒ

nd
S(u:Switch to next URL given by the current failover strategy.N(RRJR-(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pytmaybe_switch_nextâs	
cC@s¯|p	d
}|d
kr*tƒr*d}n|
|_
||_||_|
|_|pZ|j|_|pl|j|_||_|	|_||_	||_
|o¥t|ƒ
|_dS(Nuamqpulibrabbitmq(
RRR5R6R=R7R8R9R<R:t
transport_clstfloatR>(R4RR5R6R7R8R9R:R;R<R=R>((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyR'çs

	
	
	
	
	


	
	
	
	
cC@s|jj
|j|
ƒ
dS(
N(R;tregister_with_event_loopt
connection(R4tloop((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyRNùs
cO@sG|jrCd
}t
j|jdt|ƒ
dt|
ƒ
ƒ||Ž

ndS(Nu [Kombu connection:{id:#x}] {msg}tidtmsg(R1tloggertdebugtformatRQR(R4RRtargsR@tfmt((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyt_debugüs
	

'
c

C@st|_
|jS(
u+Establish connection to server immediately.(RFRGRO(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pytconnect
s	
c
C@sL|jd
ƒ

|j
j|jƒ
}
trHddlm}
||
ddƒS|
S(u Create and return a new channel.ucreate channeli
(
t
Logwrappedu
kombu.channelu[Kombu channel:{0.channel_id}] (RXR;tcreate_channelROt_log_channeltutils.debugRZ(R4tchanRZ((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pytchannel
s




	

icC@s|jj
|jd
|
ƒ

S(uvCheck heartbeats.

        Allow the transport to perform any periodic tasks
        required to make heartbeats work.  This should be called
        approximately every second.

        If the current transport does not support heartbeats then
        this is a noop operation.

        Arguments:
            rate (int): Rate is how often the tick is called
                compared to the actual heartbeat value.  E.g. if
                the heartbeat is set to 3 seconds, and the tick
                is called every 3 / 2 seconds, then the rate is 2.
                This value is currently unused by any transports.
        trate(R;theartbeat_checkRO(R4R`((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyRa
sc
K@s|jj
|j|

S(
uÑWait for a single event from the server.

        Arguments:
            timeout (float): Timeout in seconds before we give up.

        Raises:
            socket.timeout: if the timeout is exceeded.
        (R;tdrain_eventsRO(R4R@((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyRb$
s	cC@s0y|
jƒ
Wn|j
|jk
r+


n
Xd
S(u>Close given channel, but ignore connection and channel errors.N(RDtconnection_errorstchannel_errors(R4R_((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pytmaybe_close_channel/
s


c

C@s}|jj
ƒ
|jr)|j|jƒ

n|jryy|jj|jƒ

Wn!|jtt	j
fk
rl


n
Xd|_ndS(
N(R3REt_default_channelRet_connectionR;tclose_connectionRctAttributeErrortsocketterrorR(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyt_do_close_self6
s

	

	




c

C@s.|jƒ
|j
ƒ
|jd
ƒ

t|_dS(u;Really close connection, even if part of a connection pool.uclosedN(Rlt_do_close_transportRXR0RG(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyt_closeB
s





c

C@s%|jr!d|j_d|_ndS(
N(t
_transportRtclient(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyRmI
s
	

cC@s¨y|jj
}Wndtk
rv


tjƒ}tj|
ƒ

z)y|jƒ
Wntjk
r`


n
XWdtj|ƒ

XnX||jƒ

|j	ƒ
|j
jƒ
d|_dS(
N(
Rot_collectRiRjtgetdefaulttimeouttsetdefaulttimeoutRlttimeoutRgRmR3RER(R4tsocket_timeouttgc_transportt_timeo((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pytcollectN
s














c


C@s|jƒ
d
S(uClose the connection (if open).N(
Rn(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pytreleased
sic
@sod
‡‡
fd†
}ˆ
j}	|s0ˆ
j
}	n|	ƒ0
tˆ
jˆ
jdi||||||ƒ

WdQXˆ
S(uëEnsure we have a connection to the server.

        If not retry establishing the connection with the settings
        specified.

        Arguments:
            errback (Callable): Optional callback called each time the
                connection can't be established.  Arguments provided are
                the exception raised and the interval that will be
                slept ``(exc, interval)``.

            max_retries (int): Maximum number of times to retry.
                If this limit is exceeded the connection error
                will be re-raised.

            interval_start (float): The number of seconds we start
                sleeping for.
            interval_step (float): How many seconds added to the interval
                for each retry.
            interval_max (float): Maximum number of seconds to sleep between
                each retry.
            callback (Callable): Optional callback that is called for every
                internal iteration (1 s).
        ic@sRˆ
j|ƒ
}|r$t
|
ƒ
}nˆr:ˆ||ƒ
nˆ
jƒ
|rN|Sd
S(Ni(tcompletes_cycleR-RK(texct	intervalstretriestintervaltround(terrbackR4(sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyton_error„
s






N((t_reraise_as_library_errorst_dummy_contextRRYtrecoverable_connection_errors(
R4R€tmax_retriestinterval_startt
interval_steptinterval_maxtcallbacktreraise_as_library_errorsRtctx((R€R4sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pytensure_connectioni
s
	






	


cc@s y	dV
Wn|
|fk
r%


‚nw|jk
r`
}
t
|
|
t|ƒ
ƒ
tjƒd
ƒ
n<|jk
r›
}
t
||t|ƒ
ƒ
tjƒd
ƒ
n
XdS(Ni(R„R
Rtsystexc_infotrecoverable_channel_errors(R4tConnectionErrortChannelErrorR{((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyR‚˜
s
	







c


c@s	dV
dS(
N((
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyRĬ
scC@s#|jr|
d
t
|jƒ
StS(u?Return true if the cycle is complete after number of `retries`.i
(R(tlenR0(R4R}((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyRz¬
scC@s8|jr4|
|jk	r4|j
|jƒ

d
|_nd
S(u2Revive connection after connection re-established.N(RfReR(R4tnew_channel((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pytrevive°
s

cC@stj
d
|
|dtƒ

dS(Nu)Ensure: Operation error: %r. Retry in %ssRŽ(RSRkR0(R4R{R~((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyt_default_ensure_callback¶
s
	
i
c	
	@s^‡‡
‡‡‡‡‡‡‡f	d
†}	tdj
ˆ
jƒ
ƒ
|	_ˆ
j|	_ˆ
j|	_|	S(uëEnsure operation completes.

        Regardless of any channel/connection errors occurring.

        Retries by establishing the connection, and reapplying
        the function.

        Arguments:
            fun (Callable): Method to apply.

            errback (Callable): Optional callback called each time the
                connection can't be established.  Arguments provided are
                the exception raised and the interval that will
                be slept ``(exc, interval)``.

            max_retries (int): Maximum number of times to retry.
                If this limit is exceeded the connection error
                will be re-raised.

            interval_start (float): The number of seconds we start
                sleeping for.
            interval_step (float): How many seconds added to the interval
                for each retry.
            interval_max (float): Maximum number of seconds to sleep between
                each retry.

        Examples:
            >>> from kombu import Connection, Producer
            >>> conn = Connection('amqp://')
            >>> producer = Producer(conn)

            >>> def errback(exc, interval):
            ...     logger.error('Error: %r', exc, exc_info=1)
            ...     logger.info('Retry in %s seconds.', interval)

            >>> publish = conn.ensure(producer, producer.publish,
            ...                       errback=errback, max_retries=3)
            >>> publish({'hello': 'world'}, routing_key='dest')
        c
@s¶
d
}ˆj}ˆj
}tˆjdƒ}ˆjƒz

xr
td
ƒ
D]d
}yˆ
||
ŽSWqD|k
rN

}
|r€|r€‚nˆdk	rž|ˆkrž‚nˆjd|ddƒ

ˆjƒ
ˆoЈ|d
ƒ
d}ˆdk	rùt	ˆ|dƒ}nˆj
ˆ|ˆˆˆdtƒ

ˆj}	ˆj
|	ƒ

ˆrA
ˆ|	ƒ

n|d7}qD|k
r§

}
ˆdk	r{
|ˆkr{
‚nˆjd|ddƒ

ˆo£
ˆ|d
ƒ
qDXqDWWdQXdS(Niurecoverable_connection_errorsuensure connection error: %rRŽi
RŠuensure channel error: %r(R„RthasattrR;R‚RRRXRxtmaxRŒRFtdefault_channelR”(
RVR@tgot_connectiontconn_errorstchan_errorsthas_modern_errorsR}R{tremaining_retriesR_(	R€tfunRˆR†R‡R…tobjt	on_reviveR4(sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyt_ensuredä
sJ

	
	











	












	










	


u{0}(ensured)(RRUt__name__t__doc__t
__module__(
R4RŸRžR€R…R†R‡RˆR R¡((	R€RžRˆR†R‡R…RŸR R4sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pytensureº
s
*',


c@sG|g
‰d
tf
‡‡
fd†ƒY}||ƒ
}|j
|||S(uñDecorator for functions supporting a ``channel`` keyword argument.

        The resulting callable will retry calling the function if
        it raises connection or channel related errors.
        The return value will be a tuple of ``(retval, last_created_channel)``.

        If a ``channel`` is not provided, then one will be automatically
        acquired (remember to close it afterwards).

        See Also:
            :meth:`ensure` for the full list of supported keyword arguments.

        Example:
            >>> channel = connection.channel()
            >>> try:
            ...    ret, channel = connection.autoretry(
            ...         publish_messages, channel)
            ... finally:
            ...    channel.close()
        tRevivalc@sheZ
eˆ
ddƒZeˆ
d
dƒZ
eˆ
ddƒZd„Z‡f
d†Z‡‡
fd†ZRS(u__name__u
__module__u__doc__cS@s
|
|_dS(
N(
RO(R4RO((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyRC1s
c@s|
ˆd
<dS(Ni((R4R_(
tchannels(sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyR”4s
c
@sGˆd
dkr&|j
|jjƒ

nˆ
dˆd
|
|Ž
ˆd
fS(NiR_(RR”ROR˜(R4RVR@(R§Rž(sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyt__call__7s


N(R¢R¤tgetattrRR£RCR”R¨((R§Rž(sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyR¦,s


	(tobjectR¥(R4RžR_tensure_optionsR¦R”((R§RžsE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyt	autoretrys	
c

C@s|jƒd
|ƒ
S(NRp(
R(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pytcreate_transport?s
c
C@s2|j}
|
st
|
tƒr.t|
ƒ
}
n|
S(
u'Get the currently used transport class.(RLRRR(R4RL((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyRBs	


c
K@s"|jt
|jd
tƒ
|

S(u3Create a copy of the connection with same settings.tresolve(t	__class__RHt_infoRF(R4R@((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pytcloneIsc

C@s|jj
|jƒ
S(
N(R;tget_heartbeat_intervalRO(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyR²Ms
cC@sm
|j}|
r'|j
j||ƒ}n|jj}|jpH|jd
ƒ
}|jrjd|j|f}nd
|fd|jp‹|jdƒ
fd|jp¦|jdƒ
fd|j	pÁ|jdƒ
fd|j
pÜ|jdƒ
fd|jfd|jfd	|fd
|j
fd|jfd|jp0
|jdƒ
fd
|jfd|jfd|jfd|jff}|S(Nuhostnameu%s+%suuseridupassworduvirtual_hostuportuinsistusslu	transportuconnect_timeoututransport_optionsulogin_methodu
uri_prefixu	heartbeatufailover_strategyu
alternates(RLtresolve_aliasesR+R;tdefault_connection_paramsRR#R5R6R7R8R9R:R<R.R=R>R)R((R4R®RLt
DRtinfo((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyR°Ps0
	

	


	
	






	






c

C@st|j
ƒƒ
S(
uGet connection info.(RR°(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyR¶nsc

	C@s7t|j
|j|j|j|j|jt|jƒ
ƒS(
N(	RRLRR5R6R7R8treprR.(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyt
__eqhash__rs


u**uportuuseridupassworduvirtual_hostu	transportcC@s©|jpd
}|j
jr<|jr5d|j|fS|jS|jrVd|j|fS|jƒ}||ƒ
\}}}}	}
t|
||||t|	ƒ
d|
d|ƒS(u*Convert connection parameters to URL form.u	localhostu%s+%stsanitizetmask(RR;R%R#R¶RR(R4tinclude_passwordRºt	getfieldsRtfieldsR8R5R6tvhostR;((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pytas_uriws

	


	




cK@st||
|S(
uýPool of connections.

        See Also:
            :class:`ConnectionPool`.

        Arguments:
            limit (int): Maximum number of active connections.
                Default is no limit.

        Example:
            >>> connection = Connection('amqp://')
            >>> pool = connection.Pool(2)
            >>> c1 = pool.acquire()
            >>> c2 = pool.acquire()
            >>> c3 = pool.acquire()
            Traceback (most recent call last):
              File "<stdin>", line 1, in <module>
              File "kombu/connection.py", line 354, in acquire
              raise ConnectionLimitExceeded(self.limit)
                kombu.exceptions.ConnectionLimitExceeded: 2
            >>> c1.release()
            >>> c3 = pool.acquire()
        (
tConnectionPool(R4tlimitR@((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pytPoolŠscK@st||
|S(
uõPool of channels.

        See Also:
            :class:`ChannelPool`.

        Arguments:
            limit (int): Maximum number of active channels.
                Default is no limit.

        Example:
            >>> connection = Connection('amqp://')
            >>> pool = connection.ChannelPool(2)
            >>> c1 = pool.acquire()
            >>> c2 = pool.acquire()
            >>> c3 = pool.acquire()
            Traceback (most recent call last):
              File "<stdin>", line 1, in <module>
              File "kombu/connection.py", line 354, in acquire
              raise ChannelLimitExceeded(self.limit)
                kombu.connection.ChannelLimitExceeded: 2
            >>> c1.release()
            >>> c3 = pool.acquire()
        (
tChannelPool(R4RÁR@((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyRäscO@s&d
dlm
}
||
p|||Ž
S(u,Create new :class:`kombu.Producer` instance.i
(
tProducer(t	messagingRÄ(R4R_RVR@RÄ((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyRľs
cO@s)d
dlm
}
||p||
||ŽS(u,Create new :class:`kombu.Consumer` instance.i
(
tConsumer(RÅRÆ(R4tqueuesR_RVR@RÆ((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyRÆÃs
cK@s/d
dlm
}
||p||
||||S(u¿Simple persistent queue API.

        Create new :class:`~kombu.simple.SimpleQueue`, using a channel
        from this connection.

        If ``name`` is a string, a queue and exchange will be automatically
        created using that name as the name of the queue and exchange,
        also it will be used as the default routing key.

        Arguments:
            name (str, kombu.Queue): Name of the queue/or a queue.
            no_ack (bool): Disable acknowledgments. Default is false.
            queue_opts (Dict): Additional keyword arguments passed to the
                constructor of the automatically created :class:`~kombu.Queue`.
            exchange_opts (Dict): Additional keyword arguments passed to the
                constructor of the automatically created
                :class:`~kombu.Exchange`.
            channel (ChannelT): Custom channel to use. If not specified the
                connection default channel is used.
        i
(
tSimpleQueue(tsimpleRÈ(R4tnametno_ackt
queue_optst
exchange_optsR_R@RÈ((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyRÈÈs

cK@s/d
dlm
}
||p||
||||S(uÁ
Simple ephemeral queue API.

        Create new :class:`~kombu.simple.SimpleQueue` using a channel
        from this connection.

        See Also:
            Same as :meth:`SimpleQueue`, but configured with buffering
            semantics. The resulting queue and exchange will not be durable,
            also auto delete is enabled. Messages will be transient (not
            persistent), and acknowledgments are disabled (``no_ack``).
        i
(
tSimpleBuffer(RÉRÎ(R4RÊRËRÌRÍR_R@RÎ((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyRÎâs


c
C@s0|jd
ƒ

|j
jƒ}
|jd|ƒ
|
S(Nuestablishing connection...uconnection established: %r(RXR;testablish_connection(R4tconn((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyt_establish_connectionós




cC@s|
|jj
jkS(
N(R;t
implementst
exchange_type(R4RÓ((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pytsupports_exchange_typeùs
c

C@sd
j|j
ƒt|ƒ
ƒS(Nu<Connection: {0} at {1:#x}>(RUR¿RQ(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyt__repr__üs
c


C@s
|jƒS(
N(
R±(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyt__copy__ÿs
c

C@s"|jt
|jƒjƒƒ
dfS(
N(R¯ttupleR¶tvaluesR(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyt
__reduce__s
c


C@s|S(
N((
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyt	__enter__s
c

G@s|jƒ
dS(
N(
Ry(R4RV((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyt__exit__s
c

C@s|jj
|jƒ
S(
N(R;tqos_semantics_matches_specRO(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyRÜsc

C@s,|jo+|j
d
k	o+|jj|j
ƒ
S(u3Return true if the connection has been established.N(RGRgRR;tverify_connection(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyt	connecteds


c

C@sN|jsJ|j
sC|jjƒ
d
|_|jƒ|_t|_n|jSd
S(u«The underlying connection object.

        Warning:
            This instance is transport specific, so do not
            depend on the interface of this object.
        N(	RGRÞR3RERRfRÑRgRF(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyROs	
	


	


c

C@s/|j
|j
d
kr(|jƒ|_
n|j
S(uj
Default channel.

        Created upon access and closed when the connection is closed.

        Note:
            Can be used for automatic channel handling when you only need one
            channel, and also it is the channel implicitly used if
            a connection is passed instead of a channel, to functions that
            require a channel.
        N(RORfRR_(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyR˜&s



c

C@sd
j|j
t|jƒ
gƒ
S(u5The host as a host name/port pair separated by colon.u
:(tjoinRtstrR8(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pythost8sc

C@s(|jdkr!|jƒ|_n|jS(
N(RoRR­(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyR;=s

c


C@s
|jj
S(
u¦AMQP Management API.

        Experimental manager that can be used to manage/monitor the broker
        instance.

        Not available for all transports.
        (R;tmanager(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyRâCs	c
O@s|jj
|
|ŽS(
N(R;tget_manager(R4RVR@((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyRãNs
c

C@s1y|jj
SWntk
r,


|j|jSXd
S(u¼Recoverable connection errors.

        List of connection related exceptions that can be recovered from,
        but where the connection must be closed and re-established first.
        N(R;R„RiRcRd(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyR„Qs


c

C@s'y|jj
SWntk
r"


dSXd
S(u©Recoverable channel errors.

        List of channel related exceptions that can be automatically
        recovered from without re-establishing the connection.
        N((R;RRi(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyRas



c


C@s
|jj
S(
u8List of exceptions that may be raised by the connection.(R;Rc(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyRcmsc


C@s
|jj
S(
u5List of exceptions that may be raised by the channel.(R;Rd(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyRdrsc


C@s
|jj
jS(
N(R;RÒt
heartbeats(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pytsupports_heartbeatswsc


C@s
|jj
jS(
N(R;RÒtasync(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyt
is_evented{sN(]R¢R¤R£RR8R7R<RGRgRfRoRFR1R#R3RR.R,R>R³R*RR5R6R:R=RCRJRKR'RNRXRYR_RaRbReRlRnRmRxRyRDR0RŒRRtOperationalErrorR‚RƒRzR”R•R¥R¬R­RR±R²R°R¶R¸RR¿RÂRÃRÄRÆRÈRÎRÑRÔRÕRÖRÙRÚRÛtpropertyRÜRÞROR˜RáR;RRâRãR„RRcRdRåRç(((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyR0sº?









	
	

=							
						
	
-
			
	
Y*						



								RÀcB@steZ
dZejZeZd
d
„
Z	d„Z
d„Zd„Zdd„
Z
eed„
ƒ
Zd„Zd	„ZRS(uPool of connections.cK@s&|
|_t
t|ƒjd
|ƒ

dS(NRÁ(ROtsuperRÀRC(R4RORÁR@((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyRC‡s
	
c


C@s
|jj
ƒS(
N(ROR±(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pytnew‹s
cC@s)y|
jd
ƒ

Wnt
k
r$


n
XdS(Nureleased(RXRi(R4tresource((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pytrelease_resourceŽs




c
C@s|
jƒ
dS(
N(
Rn(R4Rì((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pytclose_resource”s
gš™™™™™¹?cC@s t|
t
ƒs|
j|ƒ
SdS(
N(RRRx(R4RìRu((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pytcollect_resource—s

cc@s-|jd
|
ƒ
}||j
fV
WdQXdS(Ntblock(tacquireR˜(R4RðRO((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pytacquire_channel›s
c
C@sQ|jrM|j
j}
x5t|
ƒ
|jkrI|j
jt|jƒ
ƒ

qWndS(
N(RÁt	_resourcetqueueR’t
put_nowaitRRë(R4t
q((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pytsetup s
	


cC@s)t|
ƒ
r|
ƒ}
n|
j
d
ƒ

|
S(Nuacquired(tcallableRX(R4Rì((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pytprepare¦s




N(R¢R¤R£RtConnectionLimitExceededt
LimitExceededR0tclose_after_forkRRCRëRíRîRïRRFRòR÷Rù(((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyRÀs
	
			
	RÃcB@s>eZ
dZejZdd
„
Zd„Zd„Z	d„Z
RS(uPool of channels.cK@s&|
|_t
t|ƒjd
|ƒ

dS(NRÁ(RORêRÃRC(R4RORÁR@((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyRC²s
	
c

C@st|j
jƒ
S(
N(RROR_(
R4((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyRë¶s
c
C@sZ|jƒ}
|j
rV|jj}x2t|ƒ
|j
krR|jjt|
ƒ
ƒ

q$WndS(
N(RëRÁRóRôR’RõR(R4R_Rö((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyR÷¹s


	


cC@st|
ƒ
r|
ƒ}
n|
S(
N(
Rø(R4R_((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyRùÀs


N(R¢R¤R£RtChannelLimitExceededRûRRCRëR÷Rù(((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyRís
			c

C@st|ƒ
r|j
S|S(
uGet channel from object.

    Return the default channel if argument is a connection instance,
    otherwise just return the channel given.
    (t
is_connectionR˜(
R_((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyt
maybe_channelÆs

c

C@s
t|t
ƒS(
N(RR(
RŸ((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyRþÑs
(?R£t
__future__RR
tosRjRtcollectionsRt
contextlibRt	itertoolsRRtoperatorRtkombuRtfiveRR	R
RRtlogR
RìRR;RRtutils.collectionsRtutils.functionalRRRRt
utils.objectsRt	utils.urlRRRRt__all__R¢RStroundrobin_failoverR³R*tenvironR+RFR/R\RªRtBrokerConnectionRÀRÃRÿRþ(((sE/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/connection.pyt<module>
sL





(



"

"







ÿÿÿP,