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

triliodata-3-3 / contego deb

Repository URL to install this package:

Version: 
3.3.42  ▾
Details    
contego / home / tvault / .virtenv / lib / python2.7 / site-packages / kombu / entity.pyc
Size: Mime: 
ó
öEYc@@s(dZddlmZmZddlZddlmZmZddlm	Z	ddl
mZmZddl
mZdZd	Zied
6ed6Zdd
ddgZdfZd„Zd„Zeed„Zedefd„ƒYƒZedefd„ƒYƒZedefd„ƒYƒZdS(u Exchange and Queue declarations.i(tabsolute_importtunicode_literalsNi(tMaybeChannelBoundtObject(tContentDisallowed(tpython_2_unicode_compatibletstring_t(tprepare_accept_contentiu	transientu
persistentuExchangeuQueueubindingumaybe_delivery_modeuamq.cC@s@t|ƒ}t|tƒr5|jdƒr5|dd!S|dd!S(Nuu'iiÿÿÿÿi(treprt
isinstanceRt
startswith(ts((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyt_reprstrscC@sdjdjtt|ƒƒƒS(Nu[{0}]u, (tformattjointmaptstr(tbindings((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pytpretty_bindingsscC@s(|r$t|tjƒr|S||S|S(u1Get delivery mode by name (or none if undefined).(R	tnumberstIntegral(tvtmodestdefault((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pytmaybe_delivery_mode stExchangec	B@saeZdZeZeZdZdZeZe	Z
e	ZdZ
e	Zddddefdefdefd	d
„fdeffZdddd„Zd
„Zd„Ze	ddd„Zddde	dd„Zdde	ddd„Zddd„Zde	e	dd„Ze	e	d„Zdddd„Zd„Zd„Zd„Zd„Zed„ƒZ RS(uþAn Exchange declaration.

    Arguments:
        name (str): See :attr:`name`.
        type (str): See :attr:`type`.
        channel (kombu.Connection, ChannelT): See :attr:`channel`.
        durable (bool): See :attr:`durable`.
        auto_delete (bool): See :attr:`auto_delete`.
        delivery_mode (enum): See :attr:`delivery_mode`.
        arguments (Dict): See :attr:`arguments`.
        no_declare (bool): See :attr:`no_declare`

    Attributes:
        name (str): Name of the exchange.
            Default is no name (the default exchange).

        type (str):
            *This description of AMQP exchange types was shamelessly stolen
            from the blog post `AMQP in 10 minutes: Part 4`_ by
            Rajith Attapattu. Reading this article is recommended if you're
            new to amqp.*

            "AMQP defines four default exchange types (routing algorithms) that
            covers most of the common messaging use cases. An AMQP broker can
            also define additional exchange types, so see your broker
            manual for more information about available exchange types.

                * `direct` (*default*)

                    Direct match between the routing key in the message,
                    and the routing criteria used when a queue is bound to
                    this exchange.

                * `topic`

                    Wildcard match between the routing key and the routing
                    pattern specified in the exchange/queue binding.
                    The routing key is treated as zero or more words delimited
                    by `"."` and supports special wildcard characters. `"*"`
                    matches a single word and `"#"` matches zero or more words.

                * `fanout`

                    Queues are bound to this exchange with no arguments. Hence
                    any message sent to this exchange will be forwarded to all
                    queues bound to this exchange.

                * `headers`

                    Queues are bound to this exchange with a table of arguments
                    containing headers and values (optional). A special
                    argument named "x-match" determines the matching algorithm,
                    where `"all"` implies an `AND` (all pairs must match) and
                    `"any"` implies `OR` (at least one pair must match).

                    :attr:`arguments` is used to specify the arguments.


                .. _`AMQP in 10 minutes: Part 4`:
                    http://bit.ly/amqp-exchange-types

        channel (ChannelT): The channel the exchange is bound to (if bound).

        durable (bool): Durable exchanges remain active when a server restarts.
            Non-durable exchanges (transient exchanges) are purged when a
            server restarts.  Default is :const:`True`.

        auto_delete (bool): If set, the exchange is deleted when all queues
            have finished using it. Default is :const:`False`.

        delivery_mode (enum): The default delivery mode used for messages.
            The value is an integer, or alias string.

                * 1 or `"transient"`

                    The message is transient. Which means it is stored in
                    memory only, and is lost if the server dies or restarts.

                * 2 or "persistent" (*default*)
                    The message is persistent. Which means the message is
                    stored both in-memory, and on disk, and therefore
                    preserved if the server dies or restarts.

            The default value is 2 (persistent).

        arguments (Dict): Additional arguments to specify when the exchange
            is declared.

        no_declare (bool): Never declare this exchange
            (:meth:`declare` does nothing).
    uudirectunameutypeu	argumentsudurableupassiveuauto_deleteu
delivery_modecC@stj|ƒp|S(N(tDELIVERY_MODEStget(tm((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyt<lambda>˜su
no_declarecK@sKtt|ƒj||p"|j|_|p4|j|_|j|ƒdS(N(tsuperRt__init__tnamettypet
maybe_bind(tselfR R!tchanneltkwargs((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyRœscC@std|jfƒS(NuE|%s(thashR (R#((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyt__hash__¢scC@s$|jo#|jo#|jjtƒS(N(t
no_declareR R
tINTERNAL_EXCHANGE_PREFIX(R#((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyt_can_declare¥s
cC@sw|jƒrs|dkr!|jn|}|p3|jjd|jd|jd|jd|jd|j	d|d|ƒSdS(	uIDeclare the exchange.

        Creates the exchange on the broker, unless passive is set
        in which case it will only assert that the exchange exists.

        Argument:
            nowait (bool): If set the server will not respond, and a
                response will not be waited for. Default is :const:`False`.
        texchangeR!tdurabletauto_deletet	argumentstnowaittpassiveN(
R*tNoneR0R$texchange_declareR R!R,R-R.(R#R/R0R$((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pytdeclareªs
cK@sOt|tƒr|j}n|p'|jjd|jd|d|d|d|ƒS(uñBind the exchange to another exchange.

        Arguments:
            nowait (bool): If set the server will not respond, and the call
                will not block waiting for a response.
                Default is :const:`False`.
        tdestinationtsourcetrouting_keyR/R.(R	RR R$t
exchange_bind(R#R+R6R.R/R$R%((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pytbind_to¼s		cC@sOt|tƒr|j}n|p'|jjd|jd|d|d|d|ƒS(u;Delete previously created exchange binding from the server.R4R5R6R/R.(R	RR R$texchange_unbind(R#R5R6R/R.R$((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pytunbind_fromÏs	cK@sD|dkrin|}t|jƒ|d<|jj|d||S(u7Create message instance to be sent with :meth:`publish`.

        Arguments:
            body (Any): Message body.

            delivery_mode (bool): Set custom delivery mode.
                Defaults to :attr:`delivery_mode`.

            priority (int): Message priority, 0 to broker configured
                max priority, where higher is better.

            content_type (str): The messages content_type.  If content_type
                is set, no serialization occurs as it is assumed this is either
                a binary object, or you've done your own serialization.
                Leave blank if using built-in serialization as our library
                properly sets content_type.

            content_encoding (str): The character set in which this object
                is encoded. Use "binary" if sending in raw binary objects.
                Leave blank if using built-in serialization as our library
                properly sets content_encoding.

            properties (Dict): Message properties.

            headers (Dict): Message headers.
        u
delivery_modet
propertiesN(R1Rt
delivery_modeR$tprepare_message(R#tbodyR<R;R%((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pytMessageÜs	cC@sXt|tƒr!|j|ƒ}n|p-|j}|jj|d|d|d|d|ƒS(u+Publish message.

        Arguments:
            message (Union[kombu.Message, str, bytes]):
                Message to publish.
            routing_key (str): Message routing key.
            mandatory (bool): Currently not supported.
            immediate (bool): Currently not supported.
        R+R6t	mandatoryt	immediate(R	RR?R R$t
basic_publish(R#tmessageR6R@RAR+((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pytpublishÿs	cC@s"|jjd|jd|d|ƒS(uNDelete the exchange declaration on server.

        Arguments:
            if_unused (bool): Delete only if the exchange has no bindings.
                Default is :const:`False`.
            nowait (bool): If set the server will not respond, and a
                response will not be waited for. Default is :const:`False`.
        R+t	if_unusedR/(R$texchange_deleteR (R#RER/((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pytdeletes	cC@st||||ƒS(N(tbinding(R#R6R.tunbind_arguments((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyRH"scC@s}t|tƒry|j|jkox|j|jkox|j|jkox|j|jkox|j|jkox|j|jkStS(N(	R	RR R!R.R,R-R<tNotImplemented(R#tother((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyt__eq__%scC@s|j|ƒS(N(RL(R#RK((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyt__ne__/scC@s
|j|ƒS(N(t_repr_entity(R#((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyt__repr__2scC@s(djt|jƒptdƒ|jƒS(NuExchange {0}({1})u(R
RR RR!(R#((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyt__str__5scC@s|jS(N(R-(R#((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pytcan_cache_declaration:sN(unameN(utypeN(u	argumentsN(!t__name__t
__module__t__doc__tTRANSIENT_DELIVERY_MODEtPERSISTENT_DELIVERY_MODER R!tTrueR,tFalseR-R0R1R<R(tbooltattrsRR'R*R3R8R:R?RDRGRHRLRMRORPtpropertyRQ(((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyR(sH\					#
	
			RHcB@sqeZdZd
dddfZddddd„Zed„Zedd„Zedd	„Z	d
„Z
d„ZRS(u#Represents a queue or exchange binding.

    Arguments:
        exchange (Exchange): Exchange to bind to.
        routing_key (str): Routing key used as binding key.
        arguments (Dict): Arguments for bind operation.
        unbind_arguments (Dict): Arguments for unbind operation.
    uexchangeurouting_keyu	argumentsuunbind_argumentsucC@s(||_||_||_||_dS(N(R+R6R.RI(R#R+R6R.RI((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyRQs			cC@s5|jr1|jjr1|jjd|d|ƒndS(uDeclare destination exchange.R$R/N(R+R R3(R#R$R/((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyR3XscC@s5|jd|jd|jd|jd|d|ƒdS(uBind entity to this binding.R+R6R.R/R$N(R8R+R6R.(R#tentityR/R$((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pytbind]s
		c
C@s2|j|jd|jd|jd|d|ƒdS(u Unbind entity from this binding.R6R.R/R$N(R:R+R6RI(R#R\R/R$((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pytunbindes
		cC@s
dj|ƒS(Nu<binding: {0}>(R
(R#((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyROmscC@s%djt|jjƒt|jƒƒS(Nu{0}->{1}(R
RR+R R6(R#((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyRPpsN(uexchangeN(urouting_keyN(u	argumentsN(uunbind_argumentsN(RRRSRTR1RZRRXR3R]R^RORP(((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyRH?s			tQueuecB@s!eZdZeZdZedƒZdZeZ	e
Ze
Ze
Z
d-d.d/d0d1d2defd	efd
efd3d4d
efdefdefdefdefdefdeffZdd,dd,d,d,d„Zd„Zd„Zd„Ze
d,d„Ze
d,d„Ze
d,d„Ze
d,d„Ze
e
d,d„Ze
d,d„Zddd,e
d,d„Zd,d,d„Ze
d „Z dd,d,e
d!„Z!d"„Z"e
e
e
d#„Z#d,e
d,d$„Z$ddd,e
d,d%„Z%d&„Z&d'„Z'd(„Z(e)d)„ƒZ*e+d*„ƒZ,e
d+„Z-RS(5u«A Queue declaration.

    Arguments:
        name (str): See :attr:`name`.
        exchange (Exchange, str): See :attr:`exchange`.
        routing_key (str): See :attr:`routing_key`.
        channel (kombu.Connection, ChannelT): See :attr:`channel`.
        durable (bool): See :attr:`durable`.
        exclusive (bool): See :attr:`exclusive`.
        auto_delete (bool): See :attr:`auto_delete`.
        queue_arguments (Dict): See :attr:`queue_arguments`.
        binding_arguments (Dict): See :attr:`binding_arguments`.
        consumer_arguments (Dict): See :attr:`consumer_arguments`.
        no_declare (bool): See :attr:`no_declare`.
        on_declared (Callable): See :attr:`on_declared`.
        expires (float): See :attr:`expires`.
        message_ttl (float): See :attr:`message_ttl`.
        max_length (int): See :attr:`max_length`.
        max_length_bytes (int): See :attr:`max_length_bytes`.
        max_priority (int): See :attr:`max_priority`.

    Attributes:
        name (str): Name of the queue.
            Default is no name (default queue destination).

        exchange (Exchange): The :class:`Exchange` the queue binds to.

        routing_key (str): The routing key (if any), also called *binding key*.

            The interpretation of the routing key depends on
            the :attr:`Exchange.type`.

            * direct exchange

                Matches if the routing key property of the message and
                the :attr:`routing_key` attribute are identical.

            * fanout exchange

                Always matches, even if the binding does not have a key.

            * topic exchange

                Matches the routing key property of the message by a primitive
                pattern matching scheme. The message routing key then consists
                of words separated by dots (`"."`, like domain names), and
                two special characters are available; star (`"*"`) and hash
                (`"#"`). The star matches any word, and the hash matches
                zero or more words. For example `"*.stock.#"` matches the
                routing keys `"usd.stock"` and `"eur.stock.db"` but not
                `"stock.nasdaq"`.

        channel (ChannelT): The channel the Queue is bound to (if bound).

        durable (bool): Durable queues remain active when a server restarts.
            Non-durable queues (transient queues) are purged if/when
            a server restarts.
            Note that durable queues do not necessarily hold persistent
            messages, although it does not make sense to send
            persistent messages to a transient queue.

            Default is :const:`True`.

        exclusive (bool): Exclusive queues may only be consumed from by the
            current connection. Setting the 'exclusive' flag
            always implies 'auto-delete'.

            Default is :const:`False`.

        auto_delete (bool): If set, the queue is deleted when all consumers
            have finished using it. Last consumer can be canceled
            either explicitly or because its channel is closed. If
            there was no consumer ever on the queue, it won't be
            deleted.

        expires (float): Set the expiry time (in seconds) for when this
            queue should expire.

            The expiry time decides how long the queue can stay unused
            before it's automatically deleted.
            *Unused* means the queue has no consumers, the queue has not been
            redeclared, and ``Queue.get`` has not been invoked for a duration
            of at least the expiration period.

            See https://www.rabbitmq.com/ttl.html#queue-ttl

            **RabbitMQ extension**: Only available when using RabbitMQ.

        message_ttl (float): Message time to live in seconds.

            This setting controls how long messages can stay in the queue
            unconsumed. If the expiry time passes before a message consumer
            has received the message, the message is deleted and no consumer
            will see the message.

            See https://www.rabbitmq.com/ttl.html#per-queue-message-ttl

            **RabbitMQ extension**: Only available when using RabbitMQ.

        max_length (int): Set the maximum number of messages that the
            queue can hold.

            If the number of messages in the queue size exceeds this limit,
            new messages will be dropped (or dead-lettered if a dead letter
            exchange is active).

            See https://www.rabbitmq.com/maxlength.html

            **RabbitMQ extension**: Only available when using RabbitMQ.

        max_length_bytes (int): Set the max size (in bytes) for the total
            of messages in the queue.

            If the total size of all the messages in the queue exceeds this
            limit, new messages will be dropped (or dead-lettered if a dead
            letter exchange is active).

            **RabbitMQ extension**: Only available when using RabbitMQ.

        max_priority (int): Set the highest priority number for this queue.

            For example if the value is 10, then messages can delivered to
            this queue can have a ``priority`` value between 0 and 10,
            where 10 is the highest priority.

            RabbitMQ queues without a max priority set will ignore
            the priority field in the message, so if you want priorities
            you need to set the max priority field to declare the queue
            as a priority queue.

            **RabbitMQ extension**: Only available when using RabbitMQ.

        queue_arguments (Dict): Additional arguments used when declaring
            the queue.  Can be used to to set the arguments value
            for RabbitMQ/AMQP's ``queue.declare``.

        binding_arguments (Dict): Additional arguments used when binding
            the queue.  Can be used to to set the arguments value
            for RabbitMQ/AMQP's ``queue.declare``.

        consumer_arguments (Dict): Additional arguments used when consuming
            from this queue.  Can be used to to set the arguments value
            for RabbitMQ/AMQP's ``basic.consume``.

        alias (str): Unused in Kombu, but applications can take advantage
            of this,  for example to give alternate names to queues with
            utomatically generated queue names.

        on_declared (Callable): Optional callback to be applied when the
            queue has been declared (the ``queue_declare`` operation is
            complete).  This must be a function with a signature that
            accepts at least 3 positional arguments:
            ``(name, messages, consumers)``.

        no_declare (bool): Never declare this queue, nor related
            entities (:meth:`declare` does nothing).
    uunameuexchangeurouting_keyuqueue_argumentsubinding_argumentsuconsumer_argumentsudurableu	exclusiveuauto_deleteuno_ackualiasubindingsu
no_declareuexpiresumessage_ttlu
max_lengthumax_length_bytesumax_priorityc	K@sÕtt|ƒj||p"|j|_|p4|j|_|pF|j|_t|pXgƒ|_||_t	|t
ttfƒrš|jt|ƒO_n|jr¯d|_n|j
rÄt|_n|j|ƒdS(N(RR_RR R+R6tsetRton_declaredR	tlistttupleR1t	exclusiveRWR-R"(R#R R+R6R$RRaR%((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyR6s			cC@s.|j}tt|ƒj|ƒ}||_|S(N(RaRR_R](R#R$Ratbound((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyR]Ks		cC@std|jfƒS(NuQ|%s(R&R (R#((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyR'QscC@s%|jr!|j|jƒ|_ndS(N(R+R$(R#((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyt
when_boundTs	cC@sU|jsN|jd|d|ƒ|jd|d|ƒ|jd|d|ƒn|jS(u8Declare queue and exchange then binds queue to exchange.R/R$(R(t_create_exchanget
_create_queuet_create_bindingsR (R#R/R$((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyR3Xs
	cC@s)|jr%|jjd|d|ƒndS(NR/R$(R+R3(R#R/R$((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyRgas	cC@sN|jd|dtd|ƒ|jrJ|jjrJ|jd|d|ƒndS(NR/R0R$(t
queue_declareRXR+R t
queue_bind(R#R/R$((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyRhescC@sMxF|jD];}|p|j}|j|ƒ|j|d|d|ƒq
WdS(NR/R$(RR$R3R](R#R/R$tB((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyRijs
cC@sÌ|p|j}|j|jp!id|jd|jd|jd|jd|jƒ}|jd|j	d|d|j
d	|jd
|jd|d|ƒ}|j	s¯|d
|_	n|j
rÈ|j
|Œn|S(u3Declare queue on the server.

        Arguments:
            nowait (bool): Do not wait for a reply.
            passive (bool): If set, the server will not create the queue.
                The client can use this to check whether a queue exists
                without modifying the server state.
        texpirestmessage_ttlt
max_lengthtmax_length_bytestmax_prioritytqueueR0R,RdR-R.R/i(R$tprepare_queue_argumentstqueue_argumentsRmRnRoRpRqRjR R,RdR-Ra(R#R/R0R$Rttret((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyRjps*													cC@s(|j|j|j|jd|d|ƒS(u'Create the queue binding on the server.R$R/(R8R+R6tbinding_arguments(R#R/R$((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyRk‘s	cC@sOt|tƒr|j}n|p'|jjd|jd|d|d|d|ƒS(NRrR+R6R.R/(R	RR R$Rk(R#R+R6R.R/R$((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyR8—s	cC@s›|dkr|jn|}|jjd|jd|ƒ}|dk	r—t|jddƒ}|ro||ƒ}n|jr…|jƒnt|ƒ|_	n|S(uJPoll the server for a new message.

        This method provides direct access to the messages in a
        queue using a synchronous dialogue, designed for
        specific types of applications where synchronous functionality
        is more important than performance.

        Returns:
            ~kombu.Message: if a message was available,
                or :const:`None` otherwise.

        Arguments:
            no_ack (bool): If enabled the broker will
                automatically ack messages.
            accept (Set[str]): Custom list of accepted content types.
        Rrtno_ackumessage_to_pythonN(
R1RwR$t	basic_getR tgetattrterrorst_reraise_errorRtaccept(R#RwR|RCtm2p((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyR¤s	
cC@s"|jjd|jd|ƒp!dS(u)Remove all ready messages from the queue.RrR/i(R$tqueue_purgeR (R#R/((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pytpurgeÀscC@sU|dkr|j}n|jjd|jd|d|p<dd|d|d|jƒS(	u•Start a queue consumer.

        Consumers last as long as the channel they were created on, or
        until the client cancels them.

        Arguments:
            consumer_tag (str): Unique identifier for the consumer.
                The consumer tag is local to a connection, so two clients
                can use the same consumer tags. If this field is empty
                the server will generate a unique tag.

            no_ack (bool): If enabled the broker will automatically
                ack messages.

            nowait (bool): Do not wait for a reply.

            callback (Callable): callback called for each delivered message.
        RrRwtconsumer_tagutcallbackR/R.N(R1RwR$t
basic_consumeR tconsumer_arguments(R#R€RRwR/((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pytconsumeÅs	cC@s|jj|ƒS(u"Cancel a consumer by consumer tag.(R$tbasic_cancel(R#R€((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pytcancelãsc	C@s(|jjd|jd|d|d|ƒS(uÁDelete the queue.

        Arguments:
            if_unused (bool): If set, the server will only delete the queue
                if it has no consumers. A channel error will be raised
                if the queue has consumers.

            if_empty (bool): If set, the server will only delete the queue if
                it is empty. If it is not empty a channel error will be raised.

            nowait (bool): Do not wait for a reply.
        RrREtif_emptyR/(R$tqueue_deleteR (R#RER‡R/((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyRGçs
cC@s|j|j|j|||ƒS(N(R:R+R6(R#R.R/R$((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pytqueue_unbindùscC@s7|p|jjd|jd|jd|d|d|ƒS(u5Unbind queue by deleting the binding from the server.RrR+R6R.R/(R$R‰R (R#R+R6R.R/R$((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyR:ýs		c
C@s³t|tƒr¯|j|jko®|j|jko®|j|jko®|j|jko®|j|jko®|j|jko®|j|jko®|j	|j	ko®|j
|j
kStS(N(R	R_R R+R6RtRvRƒR,RdR-RJ(R#RK((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyRLscC@s|j|ƒS(N(RL(R#RK((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyRMscC@sn|jr:|jdjdt|jƒdt|jƒƒƒS|jdj|dt|jƒdt|jƒƒƒS(NuQueue {name} -> {bindings}R Ru/Queue {name} -> {0.exchange!r} -> {routing_key}R6(RRNR
RR RR6(R#((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyROs	cC@s|jS(N(R-(R#((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyRQ%scK@sÉ|jdƒp|jdƒ}|jdƒ}|dkrK|jdƒ}n|jdƒ}|dkrx|jdƒ}n|jdƒ}|dkr¥|jdƒ}n|jdƒ}|dkrÒ|jdƒ}n|jd	ƒ}|jd
ƒ}	|jdƒ}
|jdƒ}|jd
ƒ}t|jdƒd|jdƒd|jdƒd|jdƒd|d|d|ƒ}
t|d|
d|d|d|jdƒd|d|jdƒd|	d|
d|d|ƒ
S( Nubinding_keyurouting_keyuexchange_durableudurableuexchange_auto_deleteuauto_deleteu
queue_durableuqueue_auto_deleteuexchange_argumentsuqueue_argumentsubinding_argumentsuconsumer_argumentsubindingsuexchangeR!u
exchange_typeR<u
delivery_modeR6R,R-R.R+Rdu	exclusiveRwuno_ackRtRvRƒR(RR1RR_(tclsRrtoptionstbinding_keyt	e_durablet
e_auto_deletet	q_durablet
q_auto_deletete_argumentstq_argumentstb_argumentstc_argumentsRR+((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyt	from_dict)sH		cC@sgtt|ƒj|ƒ}|s"|S|jdƒ}|rcg|D]}|jdtƒ^q>|d<n|S(Nubindingstrecurse(RR_tas_dictRRW(R#R–tresRtb((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyR—Vs,N(unameN(uexchangeN(urouting_keyN(uqueue_argumentsN(ubinding_argumentsN(uconsumer_argumentsN(uno_ackN(ualiasN(.RRRSRTRR RR+R6RWR,RXRdR-RwR1RYRbtfloattintRZRR]R'RfR3RgRhRiRjRkR8RRR„R†RGR‰R:RLRMROR[RQtclassmethodR•R—(((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyR_vsnž														!	
	
		
-(RTt
__future__RRRtabstractRRt
exceptionsRtfiveRRt
serializationRRURVRt__all__R)RRRRRHR_(((sA/home/tvault/.virtenv/lib/python2.7/site-packages/kombu/entity.pyt<module>s,

			ÿ6

Products

About

Resources

Contact Gemfury