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

d
dlmZ
d
dl
mZ
d
dlmZmZmZ
d
d	lmZ
d
dlmZmZ
d
dlmZmZ
d
d
lmZ
d
dlmZ
d
dl mZ
yd
dl!m"Z"
WnIe#k
rg



yd
dl$m"Z"
Wqh
e#k
rc



d
dl%m"Z"
qh
Xn
Xdddddddddg	Z&dZ'ee(ƒ
Z)da+d„Z,d„Z-e.d„
Z/def
d„ƒYZ0d „Z1de2d!„Z3dd"„
Z4dd#„
Z5d
ddd$„Z6d
ddd%„Z7dde2d&„Z8de2dd'„Z9d(„Z:d)„Z;e
d*„ƒ
Z<dd+„
Z=dd,„
Z>ddd-„Z?d.e@f
d/„ƒYZAdS(0uCommon Utilities.i(tabsolute_importtunicode_literalsN(
tdeque(
tcontextmanager(
tpartial(
tcount(tuuid4tuuid3t
NAMESPACE_OID(
tRecoverableConnectionErrori
(tExchangetQueue(tbytes_if_py2trange(
t
get_logger(
tregistry(
tuuid(
t	get_identu	Broadcastu
maybe_declareuuuiduitermessagesu
send_replyucollect_repliesuinsuredudrain_consumeru	eventloopiÿÿcC@stdkrtƒjantS(
N(t_node_idtNoneRtint(((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pytget_node_id+s

cC@s5td
||
|t
|ƒ
fƒ
}ttt|ƒƒ
S(Nu%x-%x-%x-%x(RtidtstrRR(tnode_idt
process_idt	thread_idtinstancetent((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pytgenerate_oid2s


cC@s+tt
ƒtjƒ|
r!tƒnd
|ƒS(Ni(RRtostgetpidR(Rtthreads((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pytoid_from8s



	

t	BroadcastcB@s3eZ
dZejdZddeddd„ZRS(u&Broadcast queue.

    Convenience class used to define broadcast queues.

    Every queue instance will have a unique name,
    and both the queue and exchange is configured with auto deletion.

    Arguments:
        name (str): This is used as the name of the exchange.
        queue (str): By default a unique id is used for the queue
            name for every consumer.  You can specify a custom
            queue name here.
        **kwargs (Any): See :class:`~kombu.Queue` for a list
            of additional keyword arguments supported.
    uqueuecK@sp|pd
jt
ƒƒ
}tt|ƒjd|p3|
d|d|d|d|dk	rZ|nt|
ddƒ

|S(	Nu	bcast.{0}taliastqueuetnametauto_deletetexchangettypeufanout(tformatRtsuperR"t__init__RR
(tselfR%R$R&R'R#tkwargs((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pyR+Ts







N(uqueueN(
(uqueueN(t__name__t
__module__t__doc__RtattrsRtTrueR+(((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pyR"As
	
cC@s||
jj
jkS(
N(t
connectiontclienttdeclared_entities(tentitytchannel((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pytdeclaration_cachedbs
cK@sÖ|j}|}|s3|
s!t
‚
|j|
ƒ
}n|
d
krW|sKt
‚
|j}
nd
}}|
jr¡|jr¡|
jjj}t	|ƒ
}||kr¡t
Sn|rÀt||||
||St||||
|ƒS(uDeclare entity (cached).N(
tis_boundtAssertionErrortbindRR7R3tcan_cache_declarationR4R5thashtFalset_imaybe_declaret_maybe_declare(R6R7tretrytretry_policyR9torigtdeclaredtident((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pyt
maybe_declarefs$	














cC@si|jst
d
ƒ
‚
n|jd|ƒ

|
dk	rJ|rJ|
j|ƒ

n|dk	re|j|_ntS(Nuchannel disconnectedR7(R3R	tdeclareRtaddR%R2(R6RDRER7RC((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pyR@€s
	






cK@s.|jj
jj|t|||
|||ƒS(
N(R7R3R4tensureR@(R6RDRER7RCRB((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pyR?‹s

c
#@s”tƒ‰‡f
d
†}|g
|p'g|_
|Z
xRt|jjjd|
d|dtƒ
D])}yˆjƒV
Wq]tk
r…


q]Xq]WWdQXdS(u&Drain messages from consumer instance.c@sˆj||
fƒ

dS(
N(
tappend(tbodytmessage(
tacc(sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pyt
on_message–s
tlimitttimeouttignore_timeoutsN(	Rt	callbackst	eventloopR7R3R4R2tpopleftt
IndexError(tconsumerRORPRRRNt
_((
RMsA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pytdrain_consumer’s	






cK@s4t|j
d
|g
d|
|d|d|d|ƒ
S(uIterator over messages.tqueuesR7RORPRR(RXtConsumer(tconnR7R$RORPRRR-((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pytitermessages¤s

cc@sixb|
rt|
ƒ
pt
ƒD]E}y|jd
|ƒ
V
Wqtjk
r`


|ra|ra‚qaqXqWdS(uèBest practice generator wrapper around ``Connection.drain_events``.

    Able to drain events forever, with a limit, and optionally ignoring
    timeout errors (a timeout of 1 is often used in environments where
    the socket can get "stuck", and is a best practice for Kombu consumers).

    ``eventloop`` is a generator.

    Examples:
        >>> from kombu.common import eventloop

        >>> def run(conn):
        ...     it = eventloop(conn, timeout=1, ignore_timeouts=True)
        ...     next(it)   # one event consumed, or timed out.
        ...
        ...     for _ in eventloop(conn, timeout=1, ignore_timeouts=True):
        ...         pass  # loop forever.

    It also takes an optional limit parameter, and timeout errors
    are propagated by default::

        for _ in eventloop(connection, limit=1, timeout=1):
            pass

    See Also:
        :func:`itermessages`, which is an event loop bound to one or more
        consumers, that yields any messages received.
    RPN(R
Rtdrain_eventstsocketRP(R[RORPRQt
i((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pyRS­s"





cK@sg|j|d
|d|d|t
i|
jdd6|
jjdƒ
d6tj|
jd6|
jd6|

S(	u³
Send reply for request.

    Arguments:
        exchange (kombu.Exchange, str): Reply exchange
        req (~kombu.Message): Original request, a message with
            a ``reply_to`` property.
        producer (kombu.Producer): Producer instance
        retry (bool): If true must retry according to
            the ``reply_policy`` argument.
        retry_policy (Dict): Retry settings.
        **props (Any): Extra properties.
    R'RARBureply_tourouting_keyucorrelation_idu
serializerucontent_encoding(tpublishtdictt
propertiestgettserializersttype_to_nametcontent_typetcontent_encoding(R'treqtmsgtproducerRARBtprops((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pyt
send_replyÒs

	



c	o@s„|jd
t
ƒ}t}zKxDt||
|||ŽD]*\}}|sS|jƒ
nt
}|V
q4WWd|r|
j|jƒ

nXdS(u,Generator collecting replies from ``queue``.uno_ackN(t
setdefaultR2R>R\tacktafter_reply_message_receivedR%(	R[R7R$targsR-tno_acktreceivedRKRL((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pytcollect_repliesês










cC@stj
d
||
dtƒ

dS(Nu#Connection error: %r. Retry in %ss
texc_info(tloggerterrorR2(texctinterval((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pyt_ensure_errbackús


c

c@s+y	dV
Wn|j|j
k
r&


n
XdS(
N(tconnection_errorstchannel_errors(
R[((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pyt_ignore_errors

s
	

cO@s3|
r)t|ƒ

|
||ŽSWd
QXnt|ƒ
S(uÚIgnore connection and channel errors.

    The first argument must be a connection object, or any other object
    with ``connection_error`` and ``channel_error`` attributes.

    Can be used as a function:

    .. code-block:: python

        def example(connection):
            ignore_errors(connection, consumer.channel.close)

    or as a context manager:

    .. code-block:: python

        def example(connection):
            with ignore_errors(connection):
                consumer.channel.close()


    Note:
        Connection and channel errors should be properly handled,
        and not ignored.  Using this function is only acceptable in a cleanup
        phase, like when a connection is lost or at shutdown.
    N(
R|(R[tfunRpR-((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pyt
ignore_errors	
s



cC@s|r||
ƒ

ndS(
N((R3R7t	on_revive((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pytrevive_connection*
s

c

K@sŸ|p	t}|j
d
tƒ
{}|jd|ƒ

|j}tt|d|ƒ
}	|j|
|d|d|	|}
|
|t|d|ƒ

Ž\}}|SWdQXdS(u›Function wrapper to handle connection errors.

    Ensures function performing broker commands completes
    despite intermittent connection failures.
    tblockterrbackRR3N(	RytacquireR2tensure_connectiontdefault_channelRR€t	autoretryRa(
tpoolR}RpR-R‚RtoptsR[R7trevivetinsuredtretvalRW((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pyRŠ/
s
	



!
tQoScB@sGeZ
dZdZd
„Zdd„
Zdd„
Zd„Zd„Z	RS(uÞThread safe increment/decrement of a channels prefetch_count.

    Arguments:
        callback (Callable): Function used to set new prefetch count,
            e.g. ``consumer.qos`` or ``channel.basic_qos``.  Will be called
            with a single ``prefetch_count`` keyword argument.
        initial_value (int): Initial prefetch count value..

    Example:
        >>> from kombu import Consumer, Connection
        >>> connection = Connection('amqp://')
        >>> consumer = Consumer(connection)
        >>> qos = QoS(consumer.qos, initial_prefetch_count=2)
        >>> qos.update()  # set initial

        >>> qos.value
        2

        >>> def in_some_thread():
        ...     qos.increment_eventually()

        >>> def in_some_other_thread():
        ...     qos.decrement_eventually()

        >>> while 1:
        ...    if qos.prev != qos.value:
        ...        qos.update()  # prefetch changed so update.

    It can be used with any function supporting a ``prefetch_count`` keyword
    argument::

        >>> channel = connection.channel()
        >>> QoS(channel.basic_qos, 10)


        >>> def set_qos(prefetch_count):
        ...     print('prefetch count now: %r' % (prefetch_count,))
        >>> QoS(set_qos, 10)
    cC@s+|
|_t
jƒ|_|p!d
|_dS(Ni(tcallbackt	threadingtRLockt_mutextvalue(R,Rt
initial_value((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pyR+n
s
	

i
cC@s<|j*
|j
r/|j
t|
d
ƒ|_
nWdQX|j
S(u¶Increment the value, but do not update the channels QoS.

        Note:
            The MainThread will be responsible for calling :meth:`update`
            when necessary.
        iN(RR‘tmax(R,t
n((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pytincrement_eventuallys
s

	
"
cC@sM|j;
|j
r@|j
|
8_
|j
d
kr@d
|_
q@nWdQX|j
S(u¶Decrement the value, but do not update the channels QoS.

        Note:
            The MainThread will be responsible for calling :meth:`update`
            when necessary.
        i
N(RR‘(R,R”((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pytdecrement_eventually
s

	



cC@sj|
|jkrf|
}|
t
kr:tjd
t
ƒ
d}ntjd|ƒ
|jd|ƒ

|
|_n|
S(u#Set channel prefetch_count setting.u(QoS: Disabled: prefetch_count exceeds %riubasic.qos: prefetch_count->%stprefetch_count(tprevtPREFETCH_COUNT_MAXRutwarntdebugR(R,tpcountt	new_value((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pytset
s


	

	



c

C@s$|j
|j
|jƒ
SWd
QXd
S(u)Update prefetch count with current value.N(RRžR‘(
R,((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pytupdateš
s

N(
R.R/R0RR˜R+R•R–RžRŸ(((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pyRŒC
s'		
(BR0t
__future__RR
RR^RŽtcollectionsRt
contextlibRt	functoolsRt	itertoolsRRRRRtamqpR	R6R
RtfiveRR
tlogRt
serializationRRdt
utils.uuidt_threadRtImportErrortthreadtdummy_threadt__all__R™R.RuRRRRR2R!R"R8R>RFR@R?RXR\RSRlRsRyR|R~R€RŠtobjectRŒ(((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/common.pyt<module>
sb


















	

	
				!	
&		!