Module Expr Str ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias Import alias Import alias ImportFrom alias ImportFrom alias ImportFrom alias alias ImportFrom alias ImportFrom alias Import alias ImportFrom alias ImportFrom alias alias alias alias ImportFrom alias ImportFrom alias alias alias alias Assign NameStore Call NameLoad NameLoad Assign NameStore Num Assign NameStore Str ClassDef bases NameLoad body Assign NameStore NameLoad FunctionDef arguments args NameParam NameParam defaults body Return Call AttributeLoad Str attr AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Assign NameStore AttributeLoad NameLoad attr If CompareIn NameLoad Call AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Str NameLoad Assign NameStore DictComp Call AttributeLoad NameLoad attr NameLoad NameLoad comprehension TupleStore NameStore NameStore Call AttributeLoad NameLoad attr CompareIsNot NameLoad NameLoad Return NameLoad decorator_list decorator_list ClassDef bases NameLoad body Assign NameStore NameLoad FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call AttributeLoad Str attr AttributeLoad NameLoad attr If Call AttributeLoad NameLoad attr NameLoad body Return SubscriptLoad NameLoad Slice Call NameLoad NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Assign NameStore DictComp Call AttributeLoad NameLoad attr NameLoad NameLoad comprehension TupleStore NameStore NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Return Call AttributeLoad NameLoad attr NameLoad decorator_list decorator_list ClassDef bases NameLoad NameLoad body Assign NameStore NameLoad Assign NameStore NameLoad FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad NameLoad body Expr Str Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call NameLoad AttributeLoad NameLoad attr Return Call AttributeLoad SubscriptLoad NameLoad Index NameLoad attr keyword NameLoad decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call NameLoad AttributeLoad NameLoad attr Return Call AttributeLoad SubscriptLoad NameLoad Index NameLoad attr keyword NameLoad decorator_list FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr SubscriptLoad AttributeLoad AttributeLoad NameLoad attr attr Index NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr NameLoad NameLoad Assign NameStore AttributeLoad NameLoad attr Assign NameStore AttributeLoad NameLoad attr Expr Call NameLoad AttributeLoad NameLoad attr With Call AttributeLoad NameLoad attr NameStore body If CompareIsNot NameLoad NameLoad body Expr Call NameLoad NameLoad NameLoad orelse If CompareIsNot NameLoad NameLoad body Expr Call NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body FunctionDef arguments args NameParam defaults kwarg body Assign NameStore AttributeLoad NameLoad attr Assign NameStore AttributeLoad NameLoad attr Assign NameStore AttributeLoad NameLoad attr If BoolOpAnd CompareIs NameLoad NameLoad CompareIsNot NameLoad NameLoad body Assign NameStore AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr Str NameLoad Assign NameStore Call AttributeLoad NameLoad attr Str NameLoad With Call AttributeLoad NameLoad attr NameStore body Assign NameStore Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad NameLoad decorator_list Return NameLoad decorator_list decorator_list ClassDef bases NameLoad NameLoad NameLoad body Assign NameStore NameLoad Assign NameStore NameLoad FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Dict Assign AttributeStore NameLoad attr Call NameLoad Assign AttributeStore NameLoad attr ListLoad Assign AttributeStore NameLoad attr ListLoad Assign AttributeStore NameLoad attr Dict Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call NameLoad Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Assign NameStore NameLoad TryExcept body Expr Call AttributeLoad NameLoad attr handlers ExceptHandler type NameLoad name NameStore body Assign NameStore NameLoad If UnaryOpNot Call AttributeLoad AttributeLoad NameLoad attr attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr SubscriptLoad AttributeLoad AttributeLoad NameLoad attr attr Index NameLoad Assign AttributeStore NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Assign AttributeStore NameLoad attr AttributeLoad AttributeLoad NameLoad attr attr Expr Call NameLoad AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body If UnaryOpNot AttributeLoad NameLoad attr body Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Str NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr keyword NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr TryExcept body Expr Call AttributeLoad NameLoad attr Str NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr handlers ExceptHandler type NameLoad body Expr Call AttributeLoad NameLoad attr Str NameLoad ExceptHandler type NameLoad name NameStore body Expr Call AttributeLoad NameLoad attr Str NameLoad NameLoad orelse Expr Call AttributeLoad NameLoad attr Str NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str If UnaryOpNot Call AttributeLoad AttributeLoad NameLoad attr attr body Expr Call AttributeLoad NameLoad attr Str NameLoad Assign NameStore Call NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad NameLoad attr TryExcept body Expr Call AttributeLoad NameLoad attr Str NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr handlers ExceptHandler type NameLoad body Pass Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Str NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str If BoolOpAnd CompareIsNot AttributeLoad NameLoad attr NameLoad UnaryOpNot AttributeLoad AttributeLoad NameLoad attr attr body Assign AttributeStore NameLoad attr Call NameLoad Assign AttributeStore NameLoad attr Call NameLoad Assign AttributeStore NameLoad attr ListLoad Assign AttributeStore NameLoad attr ListLoad Assign AttributeStore NameLoad attr Dict Assign AttributeStore NameLoad attr NameLoad TryExcept body Expr Call AttributeLoad AttributeLoad NameLoad attr attr handlers ExceptHandler type NameLoad name NameStore body Expr Call AttributeLoad NameLoad attr Str NameLoad NameLoad Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Str NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body If UnaryOpNot Call AttributeLoad AttributeLoad NameLoad attr attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Return Assign NameStore Call NameLoad Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad NameLoad Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr Str NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr Str NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr Str NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Assign AttributeStore NameLoad attr Dict For TupleStore NameStore NameStore NameLoad body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad NameLoad attr Str NameLoad NameLoad Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore AttributeLoad NameLoad attr If NameLoad body Expr Call AttributeLoad NameLoad attr Str Call NameLoad NameLoad While NameLoad body Assign NameStore Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Assign NameStore AttributeLoad NameLoad attr If NameLoad body Expr Call AttributeLoad NameLoad attr Str Call NameLoad NameLoad While NameLoad body Assign NameStore Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Str If CompareIs AttributeLoad NameLoad attr NameLoad body Return If CompareIs AttributeLoad NameLoad attr NameLoad body Assign AttributeStore NameLoad attr Call NameLoad AttributeLoad NameLoad attr Return AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr Str NameLoad For NameStore AttributeLoad NameLoad attr body Assign NameStore ListLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign NameStore Call NameLoad keyword ListLoad AttributeLoad NameLoad attr keyword NameLoad keyword AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad NameLoad Return Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam defaults body Expr Str Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Assign NameStore Call NameLoad AttributeLoad NameLoad attr Assign NameStore Call NameLoad AttributeLoad NameLoad attr If CompareEq BinOpAdd NameLoad NameLoad Num body Expr Call AttributeLoad NameLoad attr Str Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr Call AttributeLoad Str attr AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults kwarg body Expr Str If UnaryOpNot Call AttributeLoad AttributeLoad NameLoad attr attr body Expr Call AttributeLoad NameLoad attr Str NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad For NameStore AttributeLoad NameLoad attr body TryExcept body Assign NameStore AttributeLoad NameLoad attr handlers ExceptHandler type NameLoad body Pass orelse Expr Call NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults NameLoad NameLoad Num kwarg body Expr Str Assign NameStore Num With Call AttributeLoad NameLoad attr NameLoad TupleStore NameStore NameStore NameStore body For NameStore BoolOpOr BoolOpAnd NameLoad Call NameLoad NameLoad Call NameLoad body Expr Call AttributeLoad NameLoad attr If AttributeLoad NameLoad attr body Break TryExcept body Expr Call AttributeLoad NameLoad attr keyword NameLoad handlers ExceptHandler type AttributeLoad NameLoad attr body AugAssignAdd NameStore NameLoad If BoolOpAnd NameLoad CompareGtE NameLoad NameLoad body Raise ExceptHandler type AttributeLoad NameLoad attr body If UnaryOpNot AttributeLoad NameLoad attr body Raise orelse Expr Yield Assign NameStore Num decorator_list decorator_list ClassDef bases NameLoad NameLoad body Assign NameStore Call NameLoad FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad body Expr Str Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Assign NameStore TupleLoad NameLoad Assign NameStore Dict Assign NameStore AttributeLoad AttributeLoad NameLoad attr attr Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad Assign NameStore Call NameLoad AttributeLoad NameLoad attr NameLoad TryExcept body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad NameLoad keyword NameLoad keyword NameLoad handlers ExceptHandler type NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad Return TupleLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults NameLoad NameLoad body If BoolOpAnd CompareIsNot NameLoad NameLoad AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad orelse Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list decorator_list Assign NameStore AttributeLoad NameLoad attr ClassDef bases NameLoad body Pass decorator_list
N/A N/A 
Provides core messaging decorators and dependency providers.
 __future__ absolute_import itertools count functools partial logging getLogger N/A socket N/A eventlet eventlet.event Event kombu.common maybe_declare kombu.pools producers connections kombu Connection kombu.mixins ConsumerMixin N/A six nameko.amqp verify_amqp_uri nameko.constants DEFAULT_RETRY_POLICY AMQP_URI_CONFIG_KEY SERIALIZER_CONFIG_KEY DEFAULT_SERIALIZER nameko.exceptions ContainerBeingKilled nameko.extensions DependencyProvider Entrypoint SharedExtension ProviderCollector N/A _log N/A getLogger __name__ N/A PERSISTENT 2 N/A HEADER_PREFIX nameko HeaderEncoder N/A object N/A N/A header_prefix HEADER_PREFIX _get_header_name N/A N/A self key N/A N/A N/A N/A N/A {}.{} format N/A self header_prefix key N/A get_message_headers N/A N/A self worker_ctx N/A N/A N/A data N/A worker_ctx context_data N/A N/A None N/A N/A data values N/A N/A N/A N/A _log warn Attempted to publish unserialisable header value. Headers with a value of `None` will be dropped from the payload. %s data N/A headers N/A N/A N/A self _get_header_name key value N/A N/A key value N/A N/A data items N/A value None N/A headers N/A N/A HeaderDecoder N/A object N/A N/A header_prefix HEADER_PREFIX _strip_header_name N/A N/A self key N/A N/A N/A full_prefix N/A N/A {}. format N/A self header_prefix N/A N/A N/A key startswith full_prefix N/A N/A N/A key N/A N/A len full_prefix N/A key N/A unpack_message_headers N/A N/A self worker_ctx_cls message N/A N/A N/A stripped N/A N/A N/A self _strip_header_name k v N/A N/A k v N/A N/A six iteritems N/A message headers N/A N/A N/A worker_ctx_cls get_context_data stripped N/A N/A Publisher N/A DependencyProvider HeaderEncoder N/A N/A amqp_uri None N/A serializer None __init__ N/A N/A self exchange queue N/A None None N/A N/A  Provides an AMQP message publisher method via dependency injection.

        In AMQP messages are published to *exchanges* and routed to bound
        *queues*. This dependency accepts either an `exchange` or a bound
        `queue`, and will ensure both are declared before publishing.

        :Parameters:
            exchange : :class:`kombu.Exchange`
                Destination exchange
            queue : :class:`kombu.Queue`
                Bound queue. The event will be published to this queue's
                exchange.

        If neither `queue` nor `exchange` are provided, the message will be
        published to the default exchange.

        Example::

            class Foobar(object):

                publish = Publisher(exchange=...)

                def spam(self, data):
                    self.publish('spam:' + data)
         N/A N/A self exchange exchange N/A N/A self queue queue N/A get_connection N/A N/A self N/A N/A N/A conn N/A Connection N/A self amqp_uri N/A N/A N/A N/A connections N/A conn acquire block True N/A get_producer N/A N/A self N/A N/A N/A conn N/A Connection N/A self amqp_uri N/A N/A N/A N/A producers N/A conn acquire block True N/A setup N/A N/A self N/A N/A N/A N/A self amqp_uri N/A N/A N/A self container config N/A AMQP_URI_CONFIG_KEY N/A N/A self serializer N/A N/A N/A N/A self container config get SERIALIZER_CONFIG_KEY DEFAULT_SERIALIZER N/A exchange N/A self exchange N/A queue N/A self queue N/A N/A verify_amqp_uri N/A self amqp_uri N/A N/A N/A self get_connection conn N/A N/A N/A queue None N/A N/A N/A maybe_declare queue conn N/A N/A N/A exchange None N/A N/A N/A maybe_declare exchange conn N/A get_dependency N/A N/A self worker_ctx N/A N/A publish N/A N/A msg N/A kwargs N/A N/A exchange N/A self exchange N/A queue N/A self queue N/A serializer N/A self serializer N/A N/A N/A exchange None N/A queue None N/A N/A exchange N/A queue exchange N/A retry N/A N/A kwargs pop retry True N/A retry_policy N/A N/A kwargs pop retry_policy DEFAULT_RETRY_POLICY N/A N/A N/A self get_producer producer N/A N/A headers N/A N/A self get_message_headers worker_ctx N/A N/A N/A producer publish msg exchange exchange headers headers serializer serializer retry retry retry_policy retry_policy kwargs N/A N/A publish N/A N/A QueueConsumer N/A SharedExtension ProviderCollector ConsumerMixin N/A N/A amqp_uri None N/A prefetch_count None __init__ N/A N/A self N/A N/A N/A N/A self _connection None N/A N/A self _consumers N/A N/A N/A self _pending_messages N/A set N/A N/A self _pending_ack_messages N/A N/A N/A self _pending_requeue_messages N/A N/A N/A self _pending_remove_providers N/A N/A N/A self _gt None N/A N/A self _starting False N/A N/A self _consumers_ready N/A Event N/A N/A N/A N/A super QueueConsumer self __init__ N/A _handle_thread_exited N/A N/A self gt N/A N/A N/A exc None N/A N/A N/A N/A N/A gt wait N/A N/A N/A Exception N/A e N/A N/A exc e N/A N/A N/A N/A N/A self _consumers_ready ready N/A N/A N/A N/A N/A self _consumers_ready send_exception exc N/A setup N/A N/A self N/A N/A N/A N/A self amqp_uri N/A N/A N/A self container config N/A AMQP_URI_CONFIG_KEY N/A N/A self accept N/A N/A self container accept N/A N/A self prefetch_count N/A N/A self container max_workers N/A N/A verify_amqp_uri N/A self amqp_uri N/A start N/A N/A self N/A N/A N/A N/A N/A self _starting N/A N/A N/A self _starting True N/A N/A N/A _log debug starting %s self N/A N/A self _gt N/A N/A N/A self container spawn_managed_thread N/A self run protected True N/A N/A N/A N/A self _gt link N/A self _handle_thread_exited N/A N/A N/A N/A N/A _log debug waiting for consumer ready %s self N/A N/A N/A N/A self _consumers_ready wait N/A N/A N/A QueueConsumerStopped N/A N/A N/A N/A _log debug consumer was stopped before it started %s self N/A N/A Exception N/A exc N/A N/A N/A N/A _log debug consumer failed to start %s (%s) self exc N/A N/A N/A N/A _log debug started %s self N/A stop N/A N/A self N/A N/A N/A  Stop the queue-consumer gracefully.

        Wait until the last provider has been unregistered and for
        the ConsumerMixin's greenthread to exit (i.e. until all pending
        messages have been acked or requeued and all consumers stopped).
         N/A N/A N/A N/A N/A self _consumers_ready ready N/A N/A N/A N/A _log debug stopping while consumer is starting %s self N/A stop_exc N/A QueueConsumerStopped N/A N/A N/A N/A self _gt kill stop_exc N/A N/A N/A self wait_for_providers N/A N/A N/A N/A N/A _log debug waiting for consumer death %s self N/A N/A N/A N/A self _gt wait N/A N/A N/A QueueConsumerStopped N/A N/A N/A N/A N/A N/A super QueueConsumer self stop N/A N/A N/A _log debug stopped %s self N/A kill N/A N/A self N/A N/A N/A  Kill the queue-consumer.

        Unlike `stop()` any pending message ack or requeue-requests,
        requests to remove providers, etc are lost and the consume thread is
        asked to terminate as soon as possible.
         N/A N/A N/A N/A self _gt None N/A N/A N/A self _gt dead N/A N/A N/A self _providers N/A set N/A N/A self _pending_messages N/A set N/A N/A self _pending_ack_messages N/A N/A N/A self _pending_requeue_messages N/A N/A N/A self _pending_remove_providers N/A N/A N/A self should_stop True N/A N/A N/A N/A N/A N/A self _gt wait N/A N/A N/A Exception N/A exc N/A N/A N/A N/A _log warn QueueConsumer %s raised `%s` during kill self exc N/A N/A N/A N/A super QueueConsumer self kill N/A N/A N/A _log debug killed %s self N/A unregister_provider N/A N/A self provider N/A N/A N/A N/A N/A N/A N/A self _consumers_ready ready N/A N/A N/A N/A N/A self _last_provider_unregistered send N/A N/A removed_event N/A Event N/A N/A N/A self _pending_remove_providers N/A provider removed_event N/A N/A N/A removed_event wait N/A N/A N/A N/A super QueueConsumer self unregister_provider provider N/A ack_message N/A N/A self message N/A N/A N/A N/A N/A _log debug stashing message-ack: %s message N/A N/A N/A N/A self _pending_messages remove message N/A N/A N/A N/A self _pending_ack_messages append message N/A requeue_message N/A N/A self message N/A N/A N/A N/A N/A _log debug stashing message-requeue: %s message N/A N/A N/A N/A self _pending_messages remove message N/A N/A N/A N/A self _pending_requeue_messages append message N/A _on_message N/A N/A self body message N/A N/A N/A N/A N/A _log debug received message: %s message N/A N/A N/A N/A self _pending_messages add message N/A _cancel_consumers_if_requested N/A N/A self N/A N/A N/A provider_remove_events N/A N/A N/A self _pending_remove_providers items N/A N/A self _pending_remove_providers N/A N/A N/A provider removed_event provider_remove_events N/A N/A consumer N/A N/A N/A self _consumers pop provider N/A N/A N/A _log debug cancelling consumer [%s]: %s provider consumer N/A N/A N/A consumer cancel N/A N/A N/A removed_event send N/A _process_pending_message_acks N/A N/A self N/A N/A N/A messages N/A self _pending_ack_messages N/A messages N/A N/A N/A N/A _log debug ack() %d processed messages N/A len messages N/A messages N/A N/A msg N/A N/A messages pop N/A N/A N/A msg ack N/A N/A N/A eventlet sleep N/A messages N/A self _pending_requeue_messages N/A messages N/A N/A N/A N/A _log debug requeue() %d processed messages N/A len messages N/A messages N/A N/A msg N/A N/A messages pop N/A N/A N/A msg requeue N/A N/A N/A eventlet sleep N/A connection N/A N/A self N/A N/A N/A  Kombu requirement  N/A N/A N/A self amqp_uri None N/A N/A N/A N/A N/A self _connection None N/A N/A N/A self _connection N/A Connection N/A self amqp_uri N/A N/A self _connection N/A property get_consumers N/A N/A self Consumer channel N/A N/A N/A  Kombu callback to set up consumers.

        Called after any (re)connection to the broker.
         N/A N/A N/A _log debug setting up consumers %s self N/A provider N/A self _providers N/A N/A callbacks N/A N/A self _on_message N/A provider handle_message N/A consumer N/A Consumer queues N/A N/A provider queue callbacks callbacks accept N/A self accept N/A N/A N/A consumer qos prefetch_count N/A self prefetch_count N/A N/A N/A self _consumers N/A provider consumer N/A N/A N/A N/A self _consumers values N/A on_iteration N/A N/A self N/A N/A N/A  Kombu callback for each `drain_events` loop iteration. N/A N/A N/A self _cancel_consumers_if_requested N/A N/A N/A self _process_pending_message_acks N/A num_consumers N/A len N/A self _consumers N/A num_pending_messages N/A len N/A self _pending_messages N/A N/A N/A num_consumers num_pending_messages 0 N/A N/A N/A N/A _log debug requesting stop after iteration N/A N/A self should_stop True N/A on_connection_error N/A N/A self exc interval N/A N/A N/A N/A N/A _log warn N/A N/A Error connecting to broker at {} ({}).
Retrying in {} seconds. format N/A self amqp_uri exc interval N/A on_consume_ready N/A N/A self connection channel consumers N/A kwargs N/A N/A  Kombu callback when consumers are ready to accept messages.

        Called after any (re)connection to the broker.
         N/A N/A N/A N/A N/A self _consumers_ready ready N/A N/A N/A N/A _log debug consumer started %s self N/A N/A N/A N/A self _consumers_ready send None N/A provider N/A self _providers N/A N/A N/A N/A callback N/A provider on_consume_ready N/A N/A N/A AttributeError N/A N/A N/A N/A N/A callback N/A consume N/A N/A self limit timeout safety_interval N/A None None 0.1 kwargs N/A N/A  Lifted from Kombu.

        We switch the order of the `break` and `self.on_iteration()` to
        avoid waiting on a drain_events timeout before breaking the loop.
         N/A elapsed 0 N/A N/A N/A self consumer_context kwargs N/A conn channel consumers N/A N/A i N/A N/A limit N/A range limit N/A count N/A N/A N/A N/A self on_iteration N/A N/A self should_stop N/A N/A N/A N/A N/A N/A N/A conn drain_events timeout safety_interval N/A N/A N/A N/A socket timeout N/A N/A elapsed safety_interval N/A N/A timeout N/A elapsed timeout N/A N/A N/A N/A N/A socket error N/A N/A N/A N/A self should_stop N/A N/A N/A N/A N/A N/A elapsed 0 N/A N/A Consumer N/A Entrypoint HeaderDecoder N/A N/A queue_consumer N/A QueueConsumer __init__ N/A N/A self queue requeue_on_error N/A False N/A N/A 
        Decorates a method as a message consumer.

        Messages from the queue will be deserialized depending on their content
        type and passed to the the decorated method.
        When the consumer method returns without raising any exceptions,
        the message will automatically be acknowledged.
        If any exceptions are raised during the consumption and
        `requeue_on_error` is True, the message will be requeued.

        If `requeue_on_error` is true, handlers will return the event to the
        queue if an error occurs while handling it. Defaults to false.

        Example::

            @consume(...)
            def handle_message(self, body):

                if not self.spam(body):
                    raise Exception('message will be requeued')

                self.shrub(body)

        Args:
            queue: The queue to consume from.
         N/A N/A self queue queue N/A N/A self requeue_on_error requeue_on_error N/A setup N/A N/A self N/A N/A N/A N/A N/A N/A self queue_consumer register_provider self N/A stop N/A N/A self N/A N/A N/A N/A N/A N/A self queue_consumer unregister_provider self N/A handle_message N/A N/A self body message N/A N/A N/A args N/A body N/A kwargs N/A N/A worker_ctx_cls N/A N/A self container worker_ctx_cls N/A context_data N/A N/A self unpack_message_headers worker_ctx_cls message N/A handle_result N/A partial N/A self handle_result message N/A N/A N/A N/A N/A N/A self container spawn_worker self args kwargs context_data context_data handle_result handle_result N/A N/A N/A ContainerBeingKilled N/A N/A N/A N/A N/A self queue_consumer requeue_message message N/A handle_result N/A N/A self message worker_ctx result exc_info N/A None None N/A N/A N/A N/A self handle_message_processed message result exc_info N/A N/A result exc_info N/A handle_message_processed N/A N/A self message result exc_info N/A None None N/A N/A N/A N/A exc_info None N/A self requeue_on_error N/A N/A N/A N/A N/A self queue_consumer requeue_message message N/A N/A N/A N/A N/A self queue_consumer ack_message message N/A N/A N/A consume N/A Consumer decorator QueueConsumerStopped N/A Exception N/A N/A N/A