Index

_

__len__() (kombu.simple.SimpleBuffer method) (kombu.simple.SimpleQueue method)

_close() (kombu.Connection method)

A

abcast() (kombu.pidbox.Mailbox method) AbstractChannel (class in kombu.transport.virtual) accept (kombu.asynchronous.aws.sqs.message.AsyncMessage attribute) (kombu.asynchronous.aws.sqs.message.AsyncRawMessage attribute) (kombu.asynchronous.aws.sqs.message.BaseAsyncMessage attribute) (kombu.compat.Consumer attribute) (kombu.compat.ConsumerSet attribute) (kombu.message.Message attribute) (kombu.transport.pyamqp.Channel.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.pyamqp.Message attribute) (kombu.transport.pyamqp.Transport.Connection.Channel.Message attribute) (kombu.transport.qpid.Channel.Message attribute) (kombu.transport.qpid.Connection.Channel.Message attribute) (kombu.transport.qpid.Message attribute) (kombu.transport.qpid.Transport.Connection.Channel.Message attribute) (kombu.transport.virtual.Message attribute) ack() (kombu.message.Message method) (kombu.transport.base.Message method) (kombu.transport.pyamqp.Connection.Channel.Message method) (kombu.transport.qpid.Channel.QoS method) (kombu.transport.qpid.Connection.Channel.QoS method) (kombu.transport.qpid.Transport.Connection.Channel.QoS method) (kombu.transport.redis.Channel.QoS method) (kombu.transport.redis.Transport.Channel.QoS method) (kombu.transport.virtual.Message method) (kombu.transport.virtual.QoS method) ack_emulation (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) ack_log_error() (kombu.message.Message method) (kombu.transport.pyamqp.Connection.Channel.Message method) (kombu.transport.virtual.Message method) acknowledged (kombu.message.Message property) (kombu.transport.base.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message property) (kombu.transport.virtual.Message property) acquire() (kombu.asynchronous.semaphore.LaxBoundedSemaphore method) (kombu.connection.ChannelPool method) (kombu.connection.ConnectionPool method) (kombu.resource.Resource method) active_queues (kombu.transport.redis.Channel property) (kombu.transport.redis.Transport.Channel property) add() (kombu.asynchronous.Hub method) (kombu.asynchronous.hub.Hub method) (kombu.utils.limits.TokenBucket method) add_consumer() (kombu.compat.ConsumerSet method) add_consumer_from_dict() (kombu.compat.ConsumerSet method) add_permission() (kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection method) (kombu.asynchronous.aws.sqs.queue.AsyncQueue method) add_queue() (kombu.compat.Consumer method) (kombu.compat.ConsumerSet method) (kombu.Consumer method) add_reader() (kombu.asynchronous.Hub method) (kombu.asynchronous.hub.Hub method) add_request() (kombu.asynchronous.http.curl.CurlClient method) add_writer() (kombu.asynchronous.Hub method) (kombu.asynchronous.hub.Hub method) adjust() (kombu.clocks.LamportClock method) after_reply_message_received() (kombu.transport.memory.Channel method) (kombu.transport.memory.Transport.Channel method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.pyro.Channel method) (kombu.transport.pyro.Transport.Channel method) alias (kombu.Queue attribute)

annotate() (kombu.log.LogMixin method) append() (kombu.transport.qpid.Channel.QoS method) (kombu.transport.qpid.Connection.Channel.QoS method) (kombu.transport.qpid.Transport.Connection.Channel.QoS method) (kombu.transport.redis.Channel.QoS method) (kombu.transport.redis.Transport.Channel.QoS method) (kombu.transport.virtual.QoS method) apply_backoff_policy() (kombu.transport.SQS.Channel.QoS method) (kombu.transport.SQS.Transport.Channel.QoS method) apply_entry() (kombu.asynchronous.timer.Timer method) args (kombu.asynchronous.timer.Entry attribute) (kombu.asynchronous.timer.Timer.Entry attribute) (kombu.compat.Consumer.ContentDisallowed attribute) (kombu.compat.ConsumerSet.ContentDisallowed attribute) (kombu.transport.pyamqp.Connection.Channel.Message.MessageStateError attribute) (kombu.transport.virtual.Message.MessageStateError attribute) as_dict() (kombu.Queue method) as_uri() (kombu.Connection method) (kombu.connection.Connection method) (kombu.transport.azureservicebus.Transport class method) (kombu.transport.azurestoragequeues.Transport class method) (kombu.transport.mongodb.Transport method) as_url() (in module kombu.utils.url) async_pool (kombu.transport.redis.Channel property) (kombu.transport.redis.Transport.Channel property) AsyncConnection (class in kombu.asynchronous.aws.connection) AsyncHTTPSConnection (class in kombu.asynchronous.aws.connection) AsyncHTTPSConnection.Request (class in kombu.asynchronous.aws.connection) AsyncMessage (class in kombu.asynchronous.aws.sqs.message) AsyncQueue (class in kombu.asynchronous.aws.sqs.queue) AsyncRawMessage (class in kombu.asynchronous.aws.sqs.message) AsyncSQSConnection (class in kombu.asynchronous.aws.sqs.connection) asynsqs() (kombu.transport.SQS.Channel method) (kombu.transport.SQS.Transport.Channel method) attrs (kombu.common.Broadcast attribute) (kombu.Exchange attribute) (kombu.Queue attribute) auth_mode (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.Request attribute) auth_password (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.Request attribute) auth_username (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.Request attribute) auto_declare (kombu.compat.Consumer attribute) (kombu.compat.ConsumerSet attribute) (kombu.compat.Publisher attribute) (kombu.Consumer attribute) (kombu.pools.ProducerPool.Producer attribute) (kombu.Producer attribute) auto_decode (kombu.transport.pyamqp.Channel attribute) (kombu.transport.pyamqp.Connection attribute) (kombu.transport.pyamqp.Connection.Channel attribute) (kombu.transport.pyamqp.Transport.Connection attribute) (kombu.transport.pyamqp.Transport.Connection.Channel attribute) auto_delete (kombu.compat.Consumer attribute) (kombu.compat.Publisher attribute) (kombu.Exchange attribute) (kombu.Queue attribute), [1] autoretry() (kombu.Connection method) (kombu.connection.Connection method) AWS_ACCESS_KEY_ID AWS_SECRET_ACCESS_KEY

B

backend (kombu.compat.Publisher property) BaseAsyncMessage (class in kombu.asynchronous.aws.sqs.message) basic_ack() (kombu.transport.azureservicebus.Channel method) (kombu.transport.azureservicebus.Transport.Channel method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.qpid.Channel method) (kombu.transport.qpid.Connection.Channel method) (kombu.transport.qpid.Transport.Connection.Channel method) (kombu.transport.SLMQ.Channel method) (kombu.transport.SLMQ.Transport.Channel method) (kombu.transport.SQS.Channel method) (kombu.transport.SQS.Transport.Channel method) (kombu.transport.virtual.Channel method) basic_cancel() (kombu.transport.azureservicebus.Channel method) (kombu.transport.azureservicebus.Transport.Channel method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.qpid.Channel method) (kombu.transport.qpid.Connection.Channel method) (kombu.transport.qpid.Transport.Connection.Channel method) (kombu.transport.redis.Channel method) (kombu.transport.redis.Transport.Channel method) (kombu.transport.SLMQ.Channel method) (kombu.transport.SLMQ.Transport.Channel method) (kombu.transport.SQS.Channel method) (kombu.transport.SQS.Transport.Channel method) (kombu.transport.virtual.Channel method) basic_consume() (kombu.transport.azureservicebus.Channel method) (kombu.transport.azureservicebus.Transport.Channel method) (kombu.transport.azurestoragequeues.Channel method) (kombu.transport.azurestoragequeues.Transport.Channel method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.qpid.Channel method) (kombu.transport.qpid.Connection.Channel method) (kombu.transport.qpid.Transport.Connection.Channel method) (kombu.transport.redis.Channel method) (kombu.transport.redis.Transport.Channel method) (kombu.transport.SLMQ.Channel method) (kombu.transport.SLMQ.Transport.Channel method) (kombu.transport.SQS.Channel method) (kombu.transport.SQS.Transport.Channel method) (kombu.transport.virtual.Channel method) basic_get() (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.qpid.Channel method) (kombu.transport.qpid.Connection.Channel method) (kombu.transport.qpid.Transport.Connection.Channel method) (kombu.transport.virtual.Channel method) basic_publish() (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.qpid.Channel method) (kombu.transport.qpid.Connection.Channel method) (kombu.transport.qpid.Transport.Connection.Channel method) (kombu.transport.virtual.Channel method) basic_publish_confirm() (kombu.transport.pyamqp.Connection.Channel method) basic_qos() (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.qpid.Channel method) (kombu.transport.qpid.Connection.Channel method) (kombu.transport.qpid.Transport.Connection.Channel method) (kombu.transport.virtual.Channel method)

basic_recover() (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.virtual.Channel method) basic_recover_async() (kombu.transport.pyamqp.Connection.Channel method) basic_reject() (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.qpid.Channel method) (kombu.transport.qpid.Connection.Channel method) (kombu.transport.qpid.Transport.Connection.Channel method) (kombu.transport.virtual.Channel method) bind() (kombu.abstract.MaybeChannelBound method) (kombu.Queue method) bind_to() (kombu.Exchange method) (kombu.Queue method) binding() (kombu.Exchange method) binding_arguments (kombu.Queue attribute) binding_declare() (kombu.transport.virtual.BrokerState method) binding_delete() (kombu.transport.virtual.BrokerState method) bindings (kombu.transport.virtual.BrokerState attribute) blocking_read() (kombu.transport.pyamqp.Connection method) body (kombu.asynchronous.aws.connection.AsyncHTTPSConnection attribute) (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.aws.sqs.message.AsyncMessage attribute) (kombu.asynchronous.aws.sqs.message.AsyncRawMessage attribute) (kombu.asynchronous.aws.sqs.message.BaseAsyncMessage attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.base.Response property) (kombu.asynchronous.http.Request attribute) (kombu.asynchronous.http.Response property) (kombu.message.Message attribute) (kombu.transport.base.Message attribute) (kombu.transport.pyamqp.Channel.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.pyamqp.Message attribute) (kombu.transport.pyamqp.Transport.Connection.Channel.Message attribute) (kombu.transport.qpid.Channel.Message attribute) (kombu.transport.qpid.Connection.Channel.Message attribute) (kombu.transport.qpid.Message attribute) (kombu.transport.qpid.Transport.Connection.Channel.Message attribute) (kombu.transport.virtual.Message attribute) body_encoding (kombu.transport.qpid.Channel attribute) (kombu.transport.qpid.Connection.Channel attribute) (kombu.transport.qpid.Transport.Connection.Channel attribute) Broadcast (class in kombu.common) broadcast (kombu.transport.mongodb.Channel property) (kombu.transport.mongodb.Transport.Channel property) broadcast_collection (kombu.transport.mongodb.Channel attribute) (kombu.transport.mongodb.Transport.Channel attribute) BrokerState (class in kombu.transport.virtual) buffer (kombu.asynchronous.http.base.Response attribute), [1] (kombu.asynchronous.http.Response attribute), [1] bytes_recv (kombu.transport.pyamqp.Connection attribute) bytes_sent (kombu.transport.pyamqp.Connection attribute) bytes_to_str() (in module kombu.utils.encoding)

C

ca_certs (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.Request attribute) cached_property (class in kombu.utils.objects) calc_queue_size (kombu.transport.mongodb.Channel attribute) (kombu.transport.mongodb.Transport.Channel attribute) call() (kombu.pidbox.Mailbox method) call_after() (kombu.asynchronous.timer.Timer method) call_at() (kombu.asynchronous.Hub method) (kombu.asynchronous.hub.Hub method) (kombu.asynchronous.timer.Timer method) call_later() (kombu.asynchronous.Hub method) (kombu.asynchronous.hub.Hub method) call_repeatedly() (kombu.asynchronous.Hub method) (kombu.asynchronous.hub.Hub method) (kombu.asynchronous.timer.Timer method) call_soon() (kombu.asynchronous.Hub method) (kombu.asynchronous.hub.Hub method) callback_for() (in module kombu.asynchronous.debug) callbacks (kombu.compat.Consumer attribute) (kombu.compat.ConsumerSet attribute) (kombu.Consumer attribute) can_cache_declaration (kombu.abstract.MaybeChannelBound attribute) (kombu.Exchange property) (kombu.Queue property) can_consume() (kombu.transport.qpid.Channel.QoS method) (kombu.transport.qpid.Connection.Channel.QoS method) (kombu.transport.qpid.Transport.Connection.Channel.QoS method) (kombu.transport.virtual.QoS method) (kombu.utils.limits.TokenBucket method) can_consume_max_estimate() (kombu.transport.qpid.Channel.QoS method) (kombu.transport.qpid.Connection.Channel.QoS method) (kombu.transport.qpid.Transport.Connection.Channel.QoS method) (kombu.transport.virtual.QoS method) can_parse_url (kombu.transport.azureservicebus.Transport attribute) (kombu.transport.azurestoragequeues.Transport attribute) (kombu.transport.mongodb.Transport attribute) (kombu.transport.sqlalchemy.Transport attribute) cancel() (kombu.asynchronous.timer.Entry method) (kombu.asynchronous.timer.Timer method) (kombu.asynchronous.timer.Timer.Entry method) (kombu.compat.Consumer method) (kombu.compat.ConsumerSet method) (kombu.Consumer method) (kombu.Queue method) cancel_by_queue() (kombu.compat.Consumer method) (kombu.compat.ConsumerSet method) (kombu.Consumer method) canceled (kombu.asynchronous.timer.Entry attribute) (kombu.asynchronous.timer.Timer.Entry attribute) cancelled (kombu.asynchronous.timer.Entry property) (kombu.asynchronous.timer.Timer.Entry property) canonical_queue_name() (kombu.transport.SQS.Channel method) (kombu.transport.SQS.Transport.Channel method) capacity (kombu.utils.limits.TokenBucket attribute) capped_queue_size (kombu.transport.mongodb.Channel attribute) (kombu.transport.mongodb.Transport.Channel attribute) cast() (kombu.pidbox.Mailbox method) change_message_visibility() (kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection method) change_message_visibility_batch() (kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection method) (kombu.asynchronous.aws.sqs.queue.AsyncQueue method) Channel (class in kombu.transport.azureservicebus) (class in kombu.transport.azurestoragequeues) (class in kombu.transport.consul) (class in kombu.transport.etcd) (class in kombu.transport.filesystem) (class in kombu.transport.memory) (class in kombu.transport.mongodb) (class in kombu.transport.pyamqp) (class in kombu.transport.pyro) (class in kombu.transport.qpid) (class in kombu.transport.redis) (class in kombu.transport.SLMQ) (class in kombu.transport.sqlalchemy) (class in kombu.transport.SQS) (class in kombu.transport.virtual) (class in kombu.transport.zookeeper) channel (kombu.abstract.MaybeChannelBound property) (kombu.asynchronous.aws.sqs.message.AsyncMessage attribute) (kombu.asynchronous.aws.sqs.message.AsyncRawMessage attribute) (kombu.asynchronous.aws.sqs.message.BaseAsyncMessage attribute) (kombu.compat.Consumer attribute) (kombu.compat.ConsumerSet attribute) (kombu.compat.Publisher property) (kombu.Consumer attribute) (kombu.message.Message attribute) (kombu.pidbox.Node attribute) (kombu.pools.ProducerPool.Producer property) (kombu.Producer attribute) (kombu.Queue attribute) (kombu.simple.SimpleBuffer attribute) (kombu.simple.SimpleQueue attribute) (kombu.transport.base.Message attribute) (kombu.transport.pyamqp.Channel.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.pyamqp.Message attribute) (kombu.transport.pyamqp.Transport.Connection.Channel.Message attribute) (kombu.transport.qpid.Channel.Message attribute) (kombu.transport.qpid.Connection.Channel.Message attribute) (kombu.transport.qpid.Message attribute) (kombu.transport.qpid.Transport.Connection.Channel.Message attribute) (kombu.transport.virtual.Message attribute) Channel (kombu.transport.virtual.Transport attribute) channel() (kombu.Connection method) (kombu.connection.Connection method) (kombu.transport.pyamqp.Connection method) Channel.Message (class in kombu.transport.pyamqp) (class in kombu.transport.qpid) Channel.QoS (class in kombu.transport.qpid) (class in kombu.transport.redis) (class in kombu.transport.SQS) channel_errors (kombu.Connection attribute) (kombu.connection.Connection property) (kombu.mixins.ConsumerMixin property) (kombu.transport.base.Transport attribute) (kombu.transport.mongodb.Transport attribute) (kombu.transport.pyamqp.Connection attribute) (kombu.transport.pyamqp.Transport attribute) (kombu.transport.qpid.Transport attribute) (kombu.transport.redis.Transport attribute) (kombu.transport.SQS.Transport attribute) (kombu.transport.zookeeper.Transport attribute) channel_id (kombu.transport.pyamqp.Channel attribute) (kombu.transport.pyamqp.Connection attribute) (kombu.transport.pyamqp.Connection.Channel attribute) (kombu.transport.pyamqp.Transport.Connection attribute) (kombu.transport.pyamqp.Transport.Connection.Channel attribute) ChannelLimitExceeded ChannelPool (class in kombu.connection) ChannelPool() (kombu.Connection method) (kombu.connection.Connection method) clear() (kombu.asynchronous.aws.sqs.queue.AsyncQueue method) (kombu.asynchronous.semaphore.LaxBoundedSemaphore method) (kombu.asynchronous.timer.Timer method) (kombu.simple.SimpleBuffer method) (kombu.simple.SimpleQueue method) (kombu.transport.virtual.BrokerState method) clear_pending() (kombu.utils.limits.TokenBucket method) client (kombu.transport.base.Transport attribute) (kombu.transport.mongodb.Channel property) (kombu.transport.mongodb.Transport.Channel property) (kombu.transport.redis.Channel property) (kombu.transport.redis.Transport.Channel property) (kombu.transport.zookeeper.Channel property) (kombu.transport.zookeeper.Transport.Channel property) Client() (in module kombu.asynchronous.http) client_cert (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.Request attribute) client_heartbeat (kombu.transport.pyamqp.Connection attribute) client_key (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.Request attribute) clock (kombu.clocks.timetuple property) clone() (kombu.Connection method) (kombu.connection.Connection method) close() (kombu.asynchronous.aws.connection.AsyncHTTPSConnection method) (kombu.asynchronous.http.curl.CurlClient method) (kombu.asynchronous.Hub method) (kombu.asynchronous.hub.Hub method) (kombu.compat.Consumer method) (kombu.compat.ConsumerSet method) (kombu.compat.Publisher method) (kombu.Connection method) (kombu.connection.Connection method) (kombu.pools.ProducerPool.Producer method) (kombu.simple.SimpleBuffer method) (kombu.simple.SimpleQueue method) (kombu.transport.azureservicebus.Channel method) (kombu.transport.azureservicebus.Transport.Channel method) (kombu.transport.memory.Channel method) (kombu.transport.memory.Transport.Channel method) (kombu.transport.pyamqp.Connection method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.pyro.Channel method) (kombu.transport.pyro.Transport.Channel method) (kombu.transport.qpid.Channel method) (kombu.transport.qpid.Connection method) (kombu.transport.qpid.Connection.Channel method) (kombu.transport.qpid.Transport.Connection method) (kombu.transport.qpid.Transport.Connection.Channel method) (kombu.transport.redis.Channel method) (kombu.transport.redis.Transport.Channel method) (kombu.transport.SQS.Channel method) (kombu.transport.SQS.Transport.Channel method) (kombu.transport.virtual.Channel method) (kombu.utils.scheduling.FairCycle method)

close_after_fork (kombu.pools.ProducerPool attribute) (kombu.resource.Resource attribute) close_channel() (kombu.transport.base.Transport method) (kombu.transport.qpid.Connection method) (kombu.transport.qpid.Transport.Connection method) (kombu.transport.virtual.Transport method) close_connection() (kombu.transport.base.Transport method) (kombu.transport.pyamqp.Transport method) (kombu.transport.qpid.Transport method) (kombu.transport.virtual.Transport method) close_resource() (kombu.pools.ProducerPool method) (kombu.resource.Resource method) code (kombu.asynchronous.http.base.Response attribute), [1] (kombu.asynchronous.http.Response attribute), [1] codecs (kombu.transport.qpid.Channel attribute) (kombu.transport.qpid.Connection.Channel attribute) (kombu.transport.qpid.Transport.Connection.Channel attribute) collect() (kombu.connection.Connection method) (kombu.transport.pyamqp.Connection method) (kombu.transport.pyamqp.Connection.Channel method) collect_replies() (in module kombu.common) collect_resource() (kombu.resource.Resource method) complete (kombu.asynchronous.http.base.Headers attribute) (kombu.asynchronous.http.Headers attribute) completes_cycle() (kombu.Connection method) (kombu.connection.Connection method) compress() (in module kombu.compression) compression (kombu.compat.Publisher attribute) (kombu.pools.ProducerPool.Producer attribute) (kombu.Producer attribute) confirm_select() (kombu.transport.pyamqp.Connection.Channel method) conn_or_acquire() (kombu.transport.redis.Channel method) (kombu.transport.redis.Transport.Channel method) connect() (kombu.asynchronous.aws.connection.AsyncHTTPSConnection method) (kombu.Connection method) (kombu.connection.Connection method) (kombu.transport.pyamqp.Connection method) connect_max_retries (kombu.mixins.ConsumerMixin attribute) connect_sqs() (in module kombu.asynchronous.aws) connect_timeout (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.Request attribute) (kombu.Connection attribute) (kombu.connection.Connection attribute) (kombu.transport.mongodb.Channel attribute) (kombu.transport.mongodb.Transport.Channel attribute) connected (kombu.Connection attribute) (kombu.connection.Connection property) (kombu.transport.pyamqp.Connection property) Connection (class in kombu) (class in kombu.connection) (class in kombu.transport.pyamqp) (class in kombu.transport.qpid) connection (kombu.compat.Consumer property) (kombu.compat.ConsumerSet property) (kombu.compat.Publisher property) (kombu.Connection attribute) (kombu.connection.Connection property) (kombu.Consumer attribute) (kombu.pidbox.Mailbox attribute) (kombu.pools.ProducerPool.Producer property) (kombu.Producer attribute) (kombu.transport.pyamqp.Channel attribute) (kombu.transport.pyamqp.Connection attribute) (kombu.transport.pyamqp.Connection.Channel attribute) (kombu.transport.pyamqp.Transport.Connection attribute) (kombu.transport.pyamqp.Transport.Connection.Channel attribute) Connection.Channel (class in kombu.transport.pyamqp) (class in kombu.transport.qpid) Connection.Channel.Message (class in kombu.transport.pyamqp) (class in kombu.transport.qpid) Connection.Channel.Message.MessageStateError Connection.Channel.QoS (class in kombu.transport.qpid) connection_class (kombu.transport.redis.Channel attribute) (kombu.transport.redis.SentinelChannel attribute) (kombu.transport.redis.Transport.Channel attribute) connection_class_ssl (kombu.transport.redis.Channel attribute) (kombu.transport.redis.SentinelChannel attribute) (kombu.transport.redis.Transport.Channel attribute) connection_errors (kombu.Connection attribute) (kombu.connection.Connection property) (kombu.mixins.ConsumerMixin property) (kombu.transport.base.Transport attribute) (kombu.transport.mongodb.Transport attribute) (kombu.transport.pyamqp.Connection attribute) (kombu.transport.pyamqp.Transport attribute) (kombu.transport.qpid.Transport attribute) (kombu.transport.redis.Transport attribute) (kombu.transport.SLMQ.Transport attribute) (kombu.transport.sqlalchemy.Transport attribute) (kombu.transport.SQS.Transport attribute) (kombu.transport.zookeeper.Transport attribute) ConnectionLimitExceeded ConnectionPool (class in kombu.connection) conninfo (kombu.transport.azureservicebus.Channel property) (kombu.transport.azureservicebus.Transport.Channel property) (kombu.transport.azurestoragequeues.Channel property) (kombu.transport.azurestoragequeues.Transport.Channel property) (kombu.transport.SLMQ.Channel property) (kombu.transport.SLMQ.Transport.Channel property) (kombu.transport.SQS.Channel property) (kombu.transport.SQS.Transport.Channel property) consume() (kombu.compat.Consumer method) (kombu.compat.ConsumerSet method) (kombu.Consumer method) (kombu.mixins.ConsumerMixin method) (kombu.Queue method) (kombu.utils.scheduling.round_robin_cycle method) (kombu.utils.scheduling.sorted_cycle method) Consumer (class in kombu) (class in kombu.compat) consumer (kombu.simple.SimpleBuffer attribute) (kombu.simple.SimpleQueue attribute) Consumer() (kombu.Connection method) (kombu.connection.Connection method) (kombu.mixins.ConsumerMixin method) (kombu.pidbox.Node method) (kombu.transport.pyamqp.Connection.Channel method) Consumer.ContentDisallowed consumer_arguments (kombu.Queue attribute) consumer_context() (kombu.mixins.ConsumerMixin method) ConsumerMixin (class in kombu.mixins) ConsumerProducerMixin (class in kombu.mixins) ConsumerSet (class in kombu.compat) ConsumerSet.ContentDisallowed consuming_from() (kombu.compat.Consumer method) (kombu.compat.ConsumerSet method) (kombu.Consumer method) content (kombu.asynchronous.http.base.Response property) (kombu.asynchronous.http.Response property) content_encoding (kombu.asynchronous.aws.sqs.message.AsyncMessage attribute) (kombu.asynchronous.aws.sqs.message.AsyncRawMessage attribute) (kombu.asynchronous.aws.sqs.message.BaseAsyncMessage attribute) (kombu.message.Message attribute) (kombu.transport.base.Message attribute) (kombu.transport.pyamqp.Channel.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.pyamqp.Message attribute) (kombu.transport.pyamqp.Transport.Connection.Channel.Message attribute) (kombu.transport.qpid.Channel.Message attribute) (kombu.transport.qpid.Connection.Channel.Message attribute) (kombu.transport.qpid.Message attribute) (kombu.transport.qpid.Transport.Connection.Channel.Message attribute) (kombu.transport.virtual.Message attribute) content_type (kombu.asynchronous.aws.sqs.message.AsyncMessage attribute) (kombu.asynchronous.aws.sqs.message.AsyncRawMessage attribute) (kombu.asynchronous.aws.sqs.message.BaseAsyncMessage attribute) (kombu.message.Message attribute) (kombu.transport.base.Message attribute) (kombu.transport.pyamqp.Channel.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.pyamqp.Message attribute) (kombu.transport.pyamqp.Transport.Connection.Channel.Message attribute) (kombu.transport.qpid.Channel.Message attribute) (kombu.transport.qpid.Connection.Channel.Message attribute) (kombu.transport.qpid.Message attribute) (kombu.transport.qpid.Transport.Connection.Channel.Message attribute) (kombu.transport.virtual.Message attribute) control_folder (kombu.transport.filesystem.Channel property) (kombu.transport.filesystem.Transport.Channel property) coro() (in module kombu.utils.compat) count() (kombu.asynchronous.aws.sqs.queue.AsyncQueue method) count_slow() (kombu.asynchronous.aws.sqs.queue.AsyncQueue method) create() (kombu.pools.PoolGroup method) create_channel() (kombu.transport.base.Transport method) (kombu.transport.pyamqp.Transport method) (kombu.transport.qpid.Transport method) (kombu.transport.virtual.Transport method) create_connection() (kombu.mixins.ConsumerMixin method) create_loop() (kombu.asynchronous.Hub method) (kombu.asynchronous.hub.Hub method) create_producer() (kombu.pools.ProducerPool method) create_queue() (kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection method) create_transport() (kombu.Connection method) (kombu.connection.Connection method) critical() (kombu.log.LogMixin method) Curl (kombu.asynchronous.http.curl.CurlClient attribute) CurlClient (class in kombu.asynchronous.http.curl) cycle (kombu.Connection attribute) (kombu.connection.Connection attribute) Cycle (kombu.transport.virtual.Transport attribute) cycle (kombu.transport.virtual.Transport attribute)

D

data_folder_in (kombu.transport.filesystem.Channel property) (kombu.transport.filesystem.Transport.Channel property) data_folder_out (kombu.transport.filesystem.Channel property) (kombu.transport.filesystem.Transport.Channel property) debug() (kombu.log.LogMixin method) declare() (kombu.compat.Consumer method) (kombu.compat.ConsumerSet method) (kombu.compat.Publisher method) (kombu.Consumer method) (kombu.Exchange method) (kombu.pools.ProducerPool.Producer method) (kombu.Producer method) (kombu.Queue method) declared_entities (kombu.Connection attribute) (kombu.connection.Connection attribute) decode() (kombu.message.Message method) (kombu.transport.base.Message method) (kombu.transport.pyamqp.Connection.Channel.Message method) (kombu.transport.virtual.Message method) decode_body() (kombu.transport.qpid.Channel method) (kombu.transport.qpid.Connection.Channel method) (kombu.transport.qpid.Transport.Connection.Channel method) decompress() (in module kombu.compression) default() (kombu.utils.json.JSONEncoder method) default_channel (kombu.Connection attribute) (kombu.connection.Connection property) default_connection_params (kombu.transport.pyamqp.Transport property) (kombu.transport.qpid.Transport property) (kombu.transport.SQS.Transport property) default_database (kombu.transport.mongodb.Channel attribute) (kombu.transport.mongodb.Transport.Channel attribute) default_encode() (in module kombu.utils.encoding) default_encoding() (in module kombu.utils.encoding) default_encoding_file (in module kombu.utils.encoding) default_hostname (kombu.transport.mongodb.Channel attribute) (kombu.transport.mongodb.Transport.Channel attribute) default_peek_lock_seconds (kombu.transport.azureservicebus.Channel attribute) (kombu.transport.azureservicebus.Transport.Channel attribute) default_port (kombu.transport.azureservicebus.Transport attribute) (kombu.transport.azurestoragequeues.Transport attribute) (kombu.transport.base.Transport attribute) (kombu.transport.consul.Transport attribute) (kombu.transport.etcd.Transport attribute) (kombu.transport.filesystem.Transport attribute) (kombu.transport.mongodb.Channel attribute) (kombu.transport.mongodb.Transport attribute) (kombu.transport.mongodb.Transport.Channel attribute) (kombu.transport.pyamqp.Transport attribute) (kombu.transport.pyro.Transport attribute) (kombu.transport.redis.Transport attribute) (kombu.transport.SLMQ.Transport attribute) (kombu.transport.sqlalchemy.Transport attribute) (kombu.transport.SQS.Transport attribute) (kombu.transport.virtual.Transport attribute) (kombu.transport.zookeeper.Transport attribute) default_ports (kombu.asynchronous.aws.connection.AsyncHTTPSConnection attribute) default_region (kombu.transport.SQS.Channel attribute) (kombu.transport.SQS.Transport.Channel attribute) default_retry_backoff_factor (kombu.transport.azureservicebus.Channel attribute) (kombu.transport.azureservicebus.Transport.Channel attribute) default_retry_backoff_max (kombu.transport.azureservicebus.Channel attribute) (kombu.transport.azureservicebus.Transport.Channel attribute) default_retry_total (kombu.transport.azureservicebus.Channel attribute) (kombu.transport.azureservicebus.Transport.Channel attribute) default_ssl_port (kombu.transport.pyamqp.Transport attribute) DEFAULT_TRANSPORT (in module kombu.transport) default_uamqp_keep_alive_interval (kombu.transport.azureservicebus.Channel attribute) (kombu.transport.azureservicebus.Transport.Channel attribute) default_visibility_timeout (kombu.transport.SLMQ.Channel attribute) (kombu.transport.SLMQ.Transport.Channel attribute) (kombu.transport.SQS.Channel attribute) (kombu.transport.SQS.Transport.Channel attribute) default_wait_time_seconds (kombu.transport.azureservicebus.Channel attribute) (kombu.transport.azureservicebus.Transport.Channel attribute) (kombu.transport.SQS.Channel attribute) (kombu.transport.SQS.Transport.Channel attribute) delete() (kombu.asynchronous.aws.sqs.queue.AsyncQueue method) (kombu.Exchange method) (kombu.Queue method) delete_message() (kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection method) (kombu.asynchronous.aws.sqs.queue.AsyncQueue method) (kombu.transport.SLMQ.Channel method) (kombu.transport.SLMQ.Transport.Channel method) delete_message_batch() (kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection method) (kombu.asynchronous.aws.sqs.queue.AsyncQueue method) delete_message_from_handle() (kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection method) delete_queue() (kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection method) deleter() (kombu.utils.objects.cached_property method) deliver() (kombu.transport.virtual.exchange.DirectExchange method) (kombu.transport.virtual.exchange.FanoutExchange method) (kombu.transport.virtual.exchange.TopicExchange method) delivery_info (kombu.asynchronous.aws.sqs.message.AsyncMessage attribute) (kombu.asynchronous.aws.sqs.message.AsyncRawMessage attribute) (kombu.asynchronous.aws.sqs.message.BaseAsyncMessage attribute) (kombu.message.Message attribute) (kombu.transport.base.Message attribute) (kombu.transport.pyamqp.Channel.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.pyamqp.Message attribute) (kombu.transport.pyamqp.Transport.Connection.Channel.Message attribute) (kombu.transport.qpid.Channel.Message attribute) (kombu.transport.qpid.Connection.Channel.Message attribute) (kombu.transport.qpid.Message attribute) (kombu.transport.qpid.Transport.Connection.Channel.Message attribute) (kombu.transport.virtual.Message attribute)

delivery_mode (kombu.Exchange attribute) delivery_tag (kombu.asynchronous.aws.sqs.message.AsyncMessage attribute) (kombu.asynchronous.aws.sqs.message.AsyncRawMessage attribute) (kombu.asynchronous.aws.sqs.message.BaseAsyncMessage attribute) (kombu.message.Message attribute) (kombu.transport.base.Message attribute) (kombu.transport.pyamqp.Channel.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.pyamqp.Message attribute) (kombu.transport.pyamqp.Transport.Connection.Channel.Message attribute) (kombu.transport.qpid.Channel.Message attribute) (kombu.transport.qpid.Connection.Channel.Message attribute) (kombu.transport.qpid.Message attribute) (kombu.transport.qpid.Transport.Connection.Channel.Message attribute) (kombu.transport.virtual.Message attribute) detect_environment() (in module kombu.utils.compat) dictfilter() (in module kombu.utils.functional) DirectExchange (class in kombu.transport.virtual.exchange) disable_insecure_serializers() (in module kombu) discard_all() (kombu.compat.Consumer method) (kombu.compat.ConsumerSet method) dispatch() (kombu.pidbox.Node method) dispatch_from_message() (kombu.pidbox.Node method) dispatch_method() (kombu.transport.pyamqp.Connection method) (kombu.transport.pyamqp.Connection.Channel method) do_restore (kombu.transport.memory.Channel attribute) (kombu.transport.memory.Transport.Channel attribute) (kombu.transport.virtual.Channel attribute) domain_format (kombu.transport.azureservicebus.Channel attribute) (kombu.transport.azureservicebus.Transport.Channel attribute) (kombu.transport.azurestoragequeues.Channel attribute) (kombu.transport.azurestoragequeues.Transport.Channel attribute) (kombu.transport.SLMQ.Channel attribute) (kombu.transport.SLMQ.Transport.Channel attribute) (kombu.transport.SQS.Channel attribute) (kombu.transport.SQS.Transport.Channel attribute) drain_consumer() (in module kombu.common) drain_events() (kombu.Connection method) (kombu.connection.Connection method) (kombu.transport.base.Transport method) (kombu.transport.pyamqp.Connection method) (kombu.transport.pyamqp.Transport method) (kombu.transport.qpid.Transport method) (kombu.transport.SQS.Channel method) (kombu.transport.SQS.Transport.Channel method) (kombu.transport.virtual.Channel method) (kombu.transport.virtual.Transport method) driver_name (kombu.transport.consul.Transport attribute) (kombu.transport.etcd.Transport attribute) (kombu.transport.filesystem.Transport attribute) (kombu.transport.memory.Transport attribute) (kombu.transport.mongodb.Transport attribute) (kombu.transport.pyamqp.Transport attribute) (kombu.transport.pyro.Transport attribute) (kombu.transport.qpid.Transport attribute) (kombu.transport.redis.Transport attribute) (kombu.transport.sqlalchemy.Transport attribute) (kombu.transport.SQS.Transport attribute) (kombu.transport.zookeeper.Transport attribute) driver_type (kombu.transport.consul.Transport attribute) (kombu.transport.etcd.Transport attribute) (kombu.transport.filesystem.Transport attribute) (kombu.transport.memory.Transport attribute) (kombu.transport.mongodb.Transport attribute) (kombu.transport.pyamqp.Transport attribute) (kombu.transport.pyro.Transport attribute) (kombu.transport.qpid.Transport attribute) (kombu.transport.redis.Transport attribute) (kombu.transport.sqlalchemy.Transport attribute) (kombu.transport.SQS.Transport attribute) (kombu.transport.zookeeper.Transport attribute) driver_version() (kombu.transport.consul.Transport method) (kombu.transport.etcd.Transport method) (kombu.transport.filesystem.Transport method) (kombu.transport.memory.Transport method) (kombu.transport.mongodb.Transport method) (kombu.transport.pyamqp.Transport method) (kombu.transport.pyro.Transport method) (kombu.transport.redis.Transport method) (kombu.transport.sqlalchemy.Transport method) (kombu.transport.zookeeper.Transport method) DummyLock (class in kombu.asynchronous.semaphore) dump() (kombu.asynchronous.aws.sqs.queue.AsyncQueue method) dumps() (in module kombu.serialization) (in module kombu.utils.json) durable (kombu.compat.Consumer attribute) (kombu.compat.Publisher attribute) (kombu.Exchange attribute) (kombu.Queue attribute), [1]

E

effective_url (kombu.asynchronous.http.base.Response attribute), [1] (kombu.asynchronous.http.Response attribute), [1] emergency_dump_state() (in module kombu.utils.div) enable_insecure_serializers() (in module kombu) encode() (kombu.asynchronous.aws.sqs.message.AsyncMessage method) encode_body() (kombu.transport.qpid.Channel method) (kombu.transport.qpid.Connection.Channel method) (kombu.transport.qpid.Transport.Connection.Channel method) encoders() (in module kombu.compression) endheaders() (kombu.asynchronous.aws.connection.AsyncHTTPSConnection method) endpoint_url (kombu.transport.SQS.Channel property) (kombu.transport.SQS.Transport.Channel property) ensure() (kombu.Connection method) (kombu.connection.Connection method) ensure_bytes() (in module kombu.utils.encoding) ensure_connection() (kombu.Connection method) (kombu.connection.Connection method) enter_after() (kombu.asynchronous.timer.Timer method) enter_at() (kombu.asynchronous.timer.Timer method) entity_name() (kombu.transport.azureservicebus.Channel method) (kombu.transport.azureservicebus.Transport.Channel method) (kombu.transport.azurestoragequeues.Channel method) (kombu.transport.azurestoragequeues.Transport.Channel method) (kombu.transport.SLMQ.Channel method) (kombu.transport.SLMQ.Transport.Channel method) (kombu.transport.SQS.Channel method) (kombu.transport.SQS.Transport.Channel method) Entry (class in kombu.asynchronous.timer) entrypoints() (in module kombu.utils.compat) environment variable AWS_ACCESS_KEY_ID AWS_SECRET_ACCESS_KEY KOMBU_LOG_CHANNEL KOMBU_LOG_CONNECTION, [1] KOMBU_LOG_DEBUG, [1], [2] PICKLE_PROTOCOL, [1] URL VHOST eqhash() (in module kombu.utils.collections) EqualityDict (class in kombu.utils.collections) equivalent() (kombu.transport.virtual.exchange.ExchangeType method) ERR (kombu.asynchronous.Hub attribute) (kombu.asynchronous.hub.Hub attribute) error (kombu.asynchronous.http.base.Response attribute), [1] (kombu.asynchronous.http.Response attribute), [1] error() (kombu.log.LogMixin method)

errors (kombu.message.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.virtual.Message attribute) escape_regex() (in module kombu.utils.text) establish_connection() (kombu.mixins.ConsumerMixin method) (kombu.transport.base.Transport method) (kombu.transport.pyamqp.Transport method) (kombu.transport.qpid.Transport method) (kombu.transport.virtual.Transport method) evaluate() (kombu.utils.functional.lazy method) eventloop() (in module kombu.common) events (kombu.transport.memory.Channel attribute) (kombu.transport.memory.Transport.Channel attribute) Exchange (class in kombu) exchange (kombu.compat.Consumer attribute) (kombu.compat.Publisher attribute) (kombu.pidbox.Mailbox attribute) (kombu.pools.ProducerPool.Producer attribute) (kombu.Producer attribute) (kombu.Queue attribute), [1] exchange_bind() (kombu.transport.pyamqp.Connection.Channel method) exchange_declare() (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.qpid.Channel method) (kombu.transport.qpid.Connection.Channel method) (kombu.transport.qpid.Transport.Connection.Channel method) (kombu.transport.virtual.Channel method) exchange_delete() (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.qpid.Channel method) (kombu.transport.qpid.Connection.Channel method) (kombu.transport.qpid.Transport.Connection.Channel method) (kombu.transport.virtual.Channel method) exchange_opts (kombu.simple.SimpleBuffer attribute) (kombu.simple.SimpleQueue attribute) exchange_type (kombu.compat.Consumer attribute) (kombu.compat.Publisher attribute) exchange_types (kombu.transport.virtual.Channel attribute) exchange_unbind() (kombu.transport.pyamqp.Connection.Channel method) exchanges (kombu.transport.virtual.BrokerState attribute) ExchangeType (class in kombu.transport.virtual.exchange) exclusive (kombu.compat.Consumer attribute) (kombu.Queue attribute), [1] expected_time() (kombu.utils.limits.TokenBucket method) expires (kombu.Queue attribute) extra_context() (kombu.mixins.ConsumerMixin method) extract_task_name_and_number_of_retries() (kombu.transport.SQS.Channel.QoS method) (kombu.transport.SQS.Transport.Channel.QoS method)

F

failover_strategies (kombu.connection.Connection attribute) failover_strategy (kombu.Connection attribute) (kombu.connection.Connection attribute) FairCycle (class in kombu.utils.scheduling) fanout_patterns (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) fanout_prefix (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) FanoutExchange (class in kombu.transport.virtual.exchange) fetch() (kombu.compat.Consumer method) fileno() (in module kombu.utils.compat) fill_rate (kombu.utils.limits.TokenBucket attribute) fire_timers() (kombu.asynchronous.Hub method) (kombu.asynchronous.hub.Hub method) flow() (kombu.compat.Consumer method) (kombu.compat.ConsumerSet method) (kombu.Consumer method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.virtual.Channel method)

fmatch_best() (in module kombu.utils.text) fmatch_iter() (in module kombu.utils.text) follow_redirects (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.Request attribute) force_close_all() (kombu.connection.ChannelPool method) (kombu.connection.ConnectionPool method) (kombu.resource.Resource method) forward() (kombu.clocks.LamportClock method) frame_writer (kombu.transport.pyamqp.Connection property) from_dict() (kombu.Queue class method) from_transport_options (kombu.transport.mongodb.Channel attribute) (kombu.transport.mongodb.Transport.Channel attribute) (kombu.transport.redis.Channel attribute) (kombu.transport.redis.SentinelChannel attribute) (kombu.transport.redis.Transport.Channel attribute) from_utf8() (in module kombu.utils.encoding) fun (kombu.asynchronous.timer.Entry attribute) (kombu.asynchronous.timer.Timer.Entry attribute)

G

generate_sts_session_token() (kombu.transport.SQS.Channel method) (kombu.transport.SQS.Transport.Channel method) get() (kombu.Queue method) (kombu.simple.SimpleBuffer method) (kombu.simple.SimpleQueue method) (kombu.transport.qpid.Channel.QoS method) (kombu.transport.qpid.Connection.Channel.QoS method) (kombu.transport.qpid.Transport.Connection.Channel.QoS method) (kombu.transport.virtual.QoS method) (kombu.utils.scheduling.FairCycle method) get_all_queues() (kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection method) get_attributes() (kombu.asynchronous.aws.sqs.queue.AsyncQueue method) get_bindings() (kombu.transport.pyamqp.Connection.Channel method) get_consumers() (kombu.mixins.ConsumerMixin method) get_dead_letter_source_queues() (kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection method) get_decoder() (in module kombu.compression) get_default_encoding_file() (in module kombu.utils.encoding) get_encoder() (in module kombu.compression) get_event_loop() (in module kombu.asynchronous) (in module kombu.asynchronous.hub) get_heartbeat_interval() (kombu.connection.Connection method) (kombu.transport.pyamqp.Transport method) get_http_connection() (kombu.asynchronous.aws.connection.AsyncConnection method) get_limit() (in module kombu.pools) get_logger() (kombu.log.LogMixin method) get_loglevel() (in module kombu.log) (kombu.log.LogMixin method) get_manager() (in module kombu.utils.amq_manager) (kombu.Connection method) (kombu.connection.Connection method) (kombu.transport.pyamqp.Transport method)

get_messages() (kombu.asynchronous.aws.sqs.queue.AsyncQueue method) get_now() (kombu.transport.mongodb.Channel method) (kombu.transport.mongodb.Transport.Channel method) get_nowait() (kombu.simple.SimpleBuffer method) (kombu.simple.SimpleQueue method) get_qpid_connection() (kombu.transport.qpid.Connection method) (kombu.transport.qpid.Transport.Connection method) get_queue() (kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection method) (kombu.pidbox.Mailbox method) get_queue_attributes() (kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection method) get_queue_url() (kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection method) get_reply_queue() (kombu.pidbox.Mailbox method) get_table() (kombu.transport.filesystem.Channel method) (kombu.transport.filesystem.Transport.Channel method) (kombu.transport.mongodb.Channel method) (kombu.transport.mongodb.Transport.Channel method) (kombu.transport.redis.Channel method) (kombu.transport.redis.Transport.Channel method) (kombu.transport.virtual.Channel method) get_timeout() (kombu.asynchronous.aws.sqs.queue.AsyncQueue method) get_transport_cls() (in module kombu.transport) (kombu.Connection method) (kombu.connection.Connection method) getrequest() (kombu.asynchronous.aws.connection.AsyncHTTPSConnection method) getresponse() (kombu.asynchronous.aws.connection.AsyncHTTPSConnection method) global_keyprefix (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) global_state (kombu.transport.filesystem.Transport attribute) (kombu.transport.memory.Transport attribute) (kombu.transport.pyro.Transport attribute) grow() (kombu.asynchronous.semaphore.LaxBoundedSemaphore method)

H

handle() (kombu.pidbox.Node method) handle_call() (kombu.pidbox.Node method) handle_cast() (kombu.pidbox.Node method) handle_error() (kombu.asynchronous.timer.Timer method) handle_message() (kombu.pidbox.Node method) handler() (kombu.pidbox.Node method) handlers (kombu.pidbox.Node attribute) has_binding() (kombu.transport.virtual.BrokerState method) HashedSeq (class in kombu.utils.collections) hashvalue (kombu.utils.collections.HashedSeq attribute) Headers (class in kombu.asynchronous.http) (class in kombu.asynchronous.http.base) headers (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.aws.sqs.message.AsyncMessage attribute) (kombu.asynchronous.aws.sqs.message.AsyncRawMessage attribute) (kombu.asynchronous.aws.sqs.message.BaseAsyncMessage attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.base.Response attribute), [1] (kombu.asynchronous.http.Request attribute) (kombu.asynchronous.http.Response attribute), [1] (kombu.message.Message attribute) (kombu.transport.base.Message attribute) (kombu.transport.pyamqp.Channel.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.pyamqp.Message attribute) (kombu.transport.pyamqp.Transport.Connection.Channel.Message attribute) (kombu.transport.qpid.Channel.Message attribute) (kombu.transport.qpid.Connection.Channel.Message attribute) (kombu.transport.qpid.Message attribute) (kombu.transport.qpid.Transport.Connection.Channel.Message attribute) (kombu.transport.virtual.Message attribute)

health_check_interval (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) heartbeat (kombu.Connection attribute) (kombu.connection.Connection attribute) (kombu.transport.pyamqp.Connection attribute) heartbeat_check() (kombu.Connection method) (kombu.connection.Connection method) (kombu.transport.pyamqp.Transport method) heartbeat_tick() (kombu.transport.pyamqp.Connection method) host (kombu.Connection attribute) (kombu.connection.Connection property) hostname (kombu.Connection attribute) (kombu.connection.Connection attribute) (kombu.pidbox.Node attribute) (kombu.utils.url.urlparts attribute) Hub (class in kombu.asynchronous) (class in kombu.asynchronous.hub)

I

id (kombu.clocks.timetuple property) (kombu.transport.sqlalchemy.models.Message attribute) (kombu.transport.sqlalchemy.models.Queue attribute) implements (kombu.transport.etcd.Transport attribute) (kombu.transport.filesystem.Transport attribute) (kombu.transport.memory.Transport attribute) (kombu.transport.mongodb.Transport attribute) (kombu.transport.pyamqp.Transport attribute) (kombu.transport.qpid.Transport attribute) (kombu.transport.redis.Transport attribute) (kombu.transport.SQS.Transport attribute) incr() (kombu.utils.functional.LRUCache method) index (kombu.transport.consul.Channel attribute) (kombu.transport.consul.Transport.Channel attribute) (kombu.transport.etcd.Channel attribute) (kombu.transport.etcd.Transport.Channel attribute) info() (kombu.Connection method) (kombu.connection.Connection method) (kombu.log.LogMixin method) insured() (in module kombu.common)

is_alive() (kombu.transport.pyamqp.Connection method) is_bound (kombu.abstract.MaybeChannelBound property) is_closing (kombu.transport.pyamqp.Channel attribute) (kombu.transport.pyamqp.Connection attribute) (kombu.transport.pyamqp.Connection.Channel attribute) (kombu.transport.pyamqp.Transport.Connection attribute) (kombu.transport.pyamqp.Transport.Connection.Channel attribute) is_enabled_for() (kombu.log.LogMixin method) is_evented (kombu.Connection attribute) (kombu.connection.Connection property) is_list() (in module kombu.utils.functional) is_secure (kombu.transport.SQS.Channel property) (kombu.transport.SQS.Transport.Channel property) items() (kombu.utils.functional.LRUCache method) iterconsume() (kombu.compat.Consumer method) (kombu.compat.ConsumerSet method) iteritems() (kombu.utils.functional.LRUCache method) iterkeys() (kombu.utils.functional.LRUCache method) itermessages() (in module kombu.common) iterqueue() (kombu.compat.Consumer method) itervalues() (kombu.utils.functional.LRUCache method)

J

JSONEncoder (class in kombu.utils.json)

K

key_to_pattern() (kombu.transport.virtual.exchange.TopicExchange method) keyprefix_fanout (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) keyprefix_queue (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) keys() (kombu.utils.functional.LRUCache method) kombu module kombu.abstract module kombu.asynchronous module kombu.asynchronous.aws module kombu.asynchronous.aws.connection module kombu.asynchronous.aws.sqs module kombu.asynchronous.aws.sqs.connection module kombu.asynchronous.aws.sqs.message module kombu.asynchronous.aws.sqs.queue module kombu.asynchronous.debug module kombu.asynchronous.http module kombu.asynchronous.http.base module kombu.asynchronous.http.curl module kombu.asynchronous.hub module kombu.asynchronous.semaphore module kombu.asynchronous.timer module kombu.clocks module kombu.common module kombu.compat module kombu.compression module kombu.connection module kombu.exceptions module kombu.log module kombu.matcher module kombu.message module kombu.mixins module kombu.pidbox module kombu.pools module kombu.resource module kombu.serialization module kombu.simple module kombu.transport module kombu.transport.azureservicebus module kombu.transport.azurestoragequeues module

kombu.transport.base module kombu.transport.consul module kombu.transport.etcd module kombu.transport.filesystem module kombu.transport.memory module kombu.transport.mongodb module kombu.transport.pyamqp module kombu.transport.pyro module kombu.transport.qpid module kombu.transport.redis module kombu.transport.SLMQ module kombu.transport.sqlalchemy module kombu.transport.sqlalchemy.models module kombu.transport.SQS module kombu.transport.virtual module kombu.transport.virtual.exchange module kombu.transport.zookeeper module kombu.utils.amq_manager module kombu.utils.collections module kombu.utils.compat module kombu.utils.debug module kombu.utils.div module kombu.utils.encoding module kombu.utils.eventio module kombu.utils.functional module kombu.utils.imports module kombu.utils.json module kombu.utils.limits module kombu.utils.objects module kombu.utils.scheduling module kombu.utils.text module kombu.utils.time module kombu.utils.url module kombu.utils.uuid module KOMBU_LOG_CHANNEL KOMBU_LOG_CONNECTION, [1] KOMBU_LOG_DEBUG, [1], [2] kwargs (kombu.asynchronous.timer.Entry attribute) (kombu.asynchronous.timer.Timer.Entry attribute)

L

LamportClock (class in kombu.clocks) last_heartbeat_received (kombu.transport.pyamqp.Connection attribute) last_heartbeat_sent (kombu.transport.pyamqp.Connection attribute) LaxBoundedSemaphore (class in kombu.asynchronous.semaphore) lazy (class in kombu.utils.functional) library_properties (kombu.transport.pyamqp.Connection attribute) LifoQueue (class in kombu.resource) limit (kombu.resource.Resource property) LimitExceeded (kombu.connection.ChannelPool attribute) (kombu.connection.ConnectionPool attribute) list_first() (in module kombu.asynchronous.aws.sqs.queue) listen() (kombu.pidbox.Node method) load() (kombu.asynchronous.aws.sqs.queue.AsyncQueue method) load_from_file() (kombu.asynchronous.aws.sqs.queue.AsyncQueue method) load_from_filename() (kombu.asynchronous.aws.sqs.queue.AsyncQueue method) load_from_s3() (kombu.asynchronous.aws.sqs.queue.AsyncQueue method) loads() (in module kombu.serialization) (in module kombu.utils.json) lock_name (kombu.transport.consul.Channel property) (kombu.transport.consul.Transport.Channel property)

lock_ttl (kombu.transport.etcd.Channel attribute) (kombu.transport.etcd.Transport.Channel attribute) lock_value (kombu.transport.etcd.Channel property) (kombu.transport.etcd.Transport.Channel property) log() (kombu.log.LogMixin method) logger (kombu.log.LogMixin property) logger_name (kombu.log.LogMixin property) login_method (kombu.Connection attribute) (kombu.connection.Connection attribute) LogMixin (class in kombu.log) Logwrapped (class in kombu.utils.debug) lookup() (kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection method) (kombu.transport.virtual.exchange.DirectExchange method) (kombu.transport.virtual.exchange.ExchangeType method) (kombu.transport.virtual.exchange.FanoutExchange method) (kombu.transport.virtual.exchange.TopicExchange method) loop (kombu.asynchronous.Hub property) (kombu.asynchronous.hub.Hub property) LRUCache (class in kombu.utils.functional)

M

Mailbox (class in kombu.pidbox) mailbox (kombu.pidbox.Node attribute) make_request() (kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection method) manager (kombu.Connection attribute) (kombu.connection.Connection property) match() (in module kombu.matcher) (kombu.matcher.MatcherRegistry method) matcher_pattern_first (kombu.matcher.MatcherRegistry attribute) MatcherNotInstalled MatcherRegistry (class in kombu.matcher) MatcherRegistry.MatcherNotInstalled max_connections (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) max_length (kombu.Queue attribute) max_length_bytes (kombu.Queue attribute) max_priority (kombu.Queue attribute) max_redirects (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.Request attribute) maybe_bind() (kombu.abstract.MaybeChannelBound method) (kombu.Exchange method) (kombu.Queue method) maybe_close_channel() (kombu.Connection method) (kombu.connection.Connection method) maybe_conn_error() (kombu.mixins.ConsumerMixin method) maybe_declare() (in module kombu.common) (kombu.compat.Publisher method) (kombu.pools.ProducerPool.Producer method) (kombu.Producer method) maybe_evaluate() (in module kombu.utils.functional) maybe_fileno() (in module kombu.utils.compat) maybe_list() (in module kombu.utils.functional) maybe_s_to_ms() (in module kombu.utils.time) maybe_sanitize_url() (in module kombu.utils.url) maybe_switch_next() (kombu.Connection method) (kombu.connection.Connection method) MaybeChannelBound (class in kombu.abstract) memoize() (in module kombu.utils.functional) Message (class in kombu.message) (class in kombu.transport.base) (class in kombu.transport.pyamqp) (class in kombu.transport.qpid) (class in kombu.transport.sqlalchemy.models) (class in kombu.transport.virtual) (kombu.transport.virtual.Channel attribute) Message() (kombu.Exchange method) Message.MessageStateError, [1] message_cls (kombu.transport.sqlalchemy.Channel property) (kombu.transport.sqlalchemy.Transport.Channel property) message_to_python() (kombu.transport.pyamqp.Channel method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.pyamqp.Transport.Connection.Channel method) (kombu.transport.virtual.Channel method) message_ttl (kombu.Queue attribute) messages (kombu.transport.mongodb.Channel property) (kombu.transport.mongodb.Transport.Channel property) messages_collection (kombu.transport.mongodb.Channel attribute) (kombu.transport.mongodb.Transport.Channel attribute) MessageStateError method (kombu.asynchronous.aws.connection.AsyncHTTPSConnection attribute) (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.Request attribute) method_queue (kombu.transport.pyamqp.Channel attribute) (kombu.transport.pyamqp.Connection attribute) (kombu.transport.pyamqp.Connection.Channel attribute) (kombu.transport.pyamqp.Transport.Connection attribute) (kombu.transport.pyamqp.Transport.Connection.Channel attribute) module kombu kombu.abstract kombu.asynchronous kombu.asynchronous.aws kombu.asynchronous.aws.connection kombu.asynchronous.aws.sqs kombu.asynchronous.aws.sqs.connection kombu.asynchronous.aws.sqs.message kombu.asynchronous.aws.sqs.queue kombu.asynchronous.debug kombu.asynchronous.http kombu.asynchronous.http.base kombu.asynchronous.http.curl kombu.asynchronous.hub kombu.asynchronous.semaphore kombu.asynchronous.timer kombu.clocks kombu.common kombu.compat kombu.compression kombu.connection kombu.exceptions kombu.log kombu.matcher kombu.message kombu.mixins kombu.pidbox kombu.pools kombu.resource kombu.serialization kombu.simple kombu.transport kombu.transport.azureservicebus kombu.transport.azurestoragequeues kombu.transport.base kombu.transport.consul kombu.transport.etcd kombu.transport.filesystem kombu.transport.memory kombu.transport.mongodb kombu.transport.pyamqp kombu.transport.pyro kombu.transport.qpid kombu.transport.redis kombu.transport.SLMQ kombu.transport.sqlalchemy kombu.transport.sqlalchemy.models kombu.transport.SQS kombu.transport.virtual kombu.transport.virtual.exchange kombu.transport.zookeeper kombu.utils.amq_manager kombu.utils.collections kombu.utils.compat kombu.utils.debug kombu.utils.div kombu.utils.encoding kombu.utils.eventio kombu.utils.functional kombu.utils.imports kombu.utils.json kombu.utils.limits kombu.utils.objects kombu.utils.scheduling kombu.utils.text kombu.utils.time kombu.utils.url kombu.utils.uuid

multi_call() (kombu.pidbox.Mailbox method)

N

name (kombu.Exchange attribute), [1] (kombu.Queue attribute), [1] (kombu.transport.sqlalchemy.models.Queue attribute) namespace (kombu.pidbox.Mailbox attribute) negotiate_capabilities (kombu.transport.pyamqp.Connection attribute) nested() (in module kombu.utils.compat) network_interface (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.Request attribute) new() (kombu.pools.ProducerPool method) new_sqs_client() (kombu.transport.SQS.Channel method) (kombu.transport.SQS.Transport.Channel method) no_ack (kombu.compat.Consumer attribute) (kombu.compat.ConsumerSet attribute) (kombu.Consumer attribute) (kombu.Queue attribute) (kombu.simple.SimpleBuffer attribute) (kombu.simple.SimpleQueue attribute) (kombu.transport.azurestoragequeues.Channel attribute) (kombu.transport.azurestoragequeues.Transport.Channel attribute)

no_ack_consumers (kombu.transport.pyamqp.Connection.Channel attribute) no_declare (kombu.Exchange attribute) (kombu.Queue attribute) Node (class in kombu.pidbox) Node() (kombu.pidbox.Mailbox method) NotBoundError

O

obj (kombu.clocks.timetuple property) object_hook() (in module kombu.utils.json) on_callback_error() (kombu.asynchronous.Hub method) (kombu.asynchronous.hub.Hub method) on_close (kombu.asynchronous.Hub attribute) (kombu.asynchronous.hub.Hub attribute) on_connection_error() (kombu.mixins.ConsumerMixin method) on_connection_revived() (kombu.mixins.ConsumerMixin method) on_consume_end() (kombu.mixins.ConsumerMixin method) (kombu.mixins.ConsumerProducerMixin method) on_consume_ready() (kombu.mixins.ConsumerMixin method) on_declared (kombu.Queue attribute) on_decode_error (kombu.compat.Consumer attribute) (kombu.compat.ConsumerSet attribute) (kombu.Consumer attribute) on_decode_error() (kombu.mixins.ConsumerMixin method) on_error (kombu.asynchronous.timer.Timer attribute) on_header (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.Request attribute) on_inbound_frame (kombu.transport.pyamqp.Connection property) on_inbound_method() (kombu.transport.pyamqp.Connection method) on_iteration() (kombu.mixins.ConsumerMixin method)

on_message (kombu.compat.Consumer attribute) (kombu.compat.ConsumerSet attribute) (kombu.Consumer attribute) on_prepare (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.Request attribute) on_readable() (kombu.asynchronous.http.curl.CurlClient method) (kombu.transport.qpid.Transport method) (kombu.transport.redis.Transport method) on_ready (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.Request attribute) on_return (kombu.compat.Publisher attribute) (kombu.pools.ProducerPool.Producer attribute) (kombu.Producer attribute) on_stream (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.Request attribute) on_timeout (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.Request attribute) on_writable() (kombu.asynchronous.http.curl.CurlClient method) open() (kombu.transport.pyamqp.Connection.Channel method)

P

parse_ssl_cert_reqs() (in module kombu.utils.url) parse_uri() (kombu.transport.azureservicebus.Transport static method) (kombu.transport.azurestoragequeues.Transport static method) parse_url() (in module kombu.utils.url) passive (kombu.Exchange attribute) password (kombu.Connection attribute) (kombu.connection.Connection attribute) (kombu.utils.url.urlparts attribute) path (kombu.asynchronous.aws.connection.AsyncHTTPSConnection attribute) (kombu.utils.url.urlparts attribute) payload (kombu.message.Message property) (kombu.transport.base.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message property) (kombu.transport.sqlalchemy.models.Message attribute) (kombu.transport.virtual.Message property) peek_lock_seconds (kombu.transport.azureservicebus.Channel property) (kombu.transport.azureservicebus.Transport.Channel property) PERSISTENT_DELIVERY_MODE (kombu.Exchange attribute) PICKLE_PROTOCOL, [1] pipe_or_acquire() (kombu.transport.redis.Channel.QoS method) (kombu.transport.redis.Transport.Channel.QoS method) poll() (in module kombu.utils.eventio) poller (kombu.asynchronous.Hub property) (kombu.asynchronous.hub.Hub property) polling_interval (kombu.transport.azureservicebus.Transport attribute) (kombu.transport.azurestoragequeues.Transport attribute) (kombu.transport.etcd.Transport attribute) (kombu.transport.mongodb.Transport attribute) (kombu.transport.qpid.Transport attribute) (kombu.transport.redis.Transport attribute) (kombu.transport.SLMQ.Transport attribute) (kombu.transport.SQS.Transport attribute) (kombu.transport.virtual.Transport attribute) (kombu.transport.zookeeper.Transport attribute) pool (kombu.transport.redis.Channel property) (kombu.transport.redis.Transport.Channel property) Pool() (kombu.Connection method) (kombu.connection.Connection method) PoolGroup (class in kombu.pools) pop() (kombu.utils.limits.TokenBucket method) popitem() (kombu.utils.functional.LRUCache method) port (kombu.Connection attribute) (kombu.connection.Connection attribute) (kombu.transport.SQS.Channel property) (kombu.transport.SQS.Transport.Channel property) (kombu.utils.url.urlparts attribute) predefined_queues (kombu.transport.SQS.Channel property) (kombu.transport.SQS.Transport.Channel property) prefetch_count (kombu.compat.Consumer attribute) (kombu.compat.ConsumerSet attribute) (kombu.transport.virtual.QoS attribute) prefix (kombu.transport.consul.Channel attribute) (kombu.transport.consul.Transport.Channel attribute) (kombu.transport.etcd.Channel attribute) (kombu.transport.etcd.Transport.Channel attribute) prepare() (kombu.pools.ProducerPool method) (kombu.resource.Resource method) prepare_bind() (kombu.transport.virtual.exchange.ExchangeType method) (kombu.transport.virtual.exchange.TopicExchange method) prepare_message() (kombu.transport.pyamqp.Channel method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.pyamqp.Transport.Connection.Channel method) (kombu.transport.qpid.Channel method) (kombu.transport.qpid.Connection.Channel method) (kombu.transport.qpid.Transport.Connection.Channel method) (kombu.transport.virtual.Channel method)

prepare_queue_arguments() (kombu.transport.mongodb.Channel method) (kombu.transport.mongodb.Transport.Channel method) (kombu.transport.pyamqp.Channel method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.pyamqp.Transport.Connection.Channel method) prev_recv (kombu.transport.pyamqp.Connection attribute) prev_sent (kombu.transport.pyamqp.Connection attribute) priority() (kombu.transport.redis.Channel method) (kombu.transport.redis.Transport.Channel method) priority_cycle (class in kombu.utils.scheduling) priority_steps (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) process_next() (kombu.compat.Consumer method) processed_folder (kombu.transport.filesystem.Channel property) (kombu.transport.filesystem.Transport.Channel property) Producer (class in kombu) producer (kombu.mixins.ConsumerProducerMixin property) (kombu.simple.SimpleBuffer attribute) (kombu.simple.SimpleQueue attribute) Producer() (kombu.Connection method) (kombu.connection.Connection method) (kombu.transport.pyamqp.Connection.Channel method) producer_connection (kombu.mixins.ConsumerProducerMixin property) ProducerPool (class in kombu.pools) ProducerPool.Producer (class in kombu.pools) properties (kombu.asynchronous.aws.sqs.message.AsyncMessage attribute) (kombu.asynchronous.aws.sqs.message.AsyncRawMessage attribute) (kombu.asynchronous.aws.sqs.message.BaseAsyncMessage attribute) (kombu.message.Message attribute) (kombu.transport.base.Message attribute) (kombu.transport.pyamqp.Channel.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.pyamqp.Message attribute) (kombu.transport.pyamqp.Transport.Connection.Channel.Message attribute) (kombu.transport.qpid.Channel.Message attribute) (kombu.transport.qpid.Connection.Channel.Message attribute) (kombu.transport.qpid.Message attribute) (kombu.transport.qpid.Transport.Connection.Channel.Message attribute) (kombu.transport.virtual.Message attribute) proxy_host (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.Request attribute) proxy_password (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.Request attribute) proxy_port (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.Request attribute) proxy_username (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.Request attribute) publish() (kombu.compat.Publisher method) (kombu.Exchange method) (kombu.pools.ProducerPool.Producer method) (kombu.Producer method) Publisher (class in kombu.compat) purge() (kombu.compat.Consumer method) (kombu.compat.ConsumerSet method) (kombu.Consumer method) (kombu.Queue method) put() (kombu.simple.SimpleBuffer method) (kombu.simple.SimpleQueue method) putheader() (kombu.asynchronous.aws.connection.AsyncHTTPSConnection method) putrequest() (kombu.asynchronous.aws.connection.AsyncHTTPSConnection method)

Q

QoS (class in kombu.transport.virtual) qos (kombu.transport.qpid.Channel property) (kombu.transport.qpid.Connection.Channel property) (kombu.transport.qpid.Transport.Connection.Channel property) (kombu.transport.virtual.Channel attribute) qos() (kombu.compat.Consumer method) (kombu.compat.ConsumerSet method) (kombu.Consumer method) qos_semantics_matches_spec (kombu.connection.Connection property) qos_semantics_matches_spec() (kombu.transport.pyamqp.Transport method) qsize() (kombu.simple.SimpleBuffer method) (kombu.simple.SimpleQueue method) query (kombu.utils.url.urlparts attribute) Queue (class in kombu) (class in kombu.transport.sqlalchemy.models) queue (kombu.asynchronous.timer.Timer property) (kombu.compat.Consumer attribute) (kombu.simple.SimpleBuffer attribute) (kombu.simple.SimpleQueue attribute) Queue.ContentDisallowed queue_arguments (kombu.Queue attribute) queue_bind() (kombu.Queue method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.qpid.Channel method) (kombu.transport.qpid.Connection.Channel method) (kombu.transport.qpid.Transport.Connection.Channel method) (kombu.transport.virtual.Channel method) queue_bindings() (kombu.transport.virtual.BrokerState method) queue_bindings_delete() (kombu.transport.virtual.BrokerState method) queue_cls (kombu.transport.sqlalchemy.Channel property) (kombu.transport.sqlalchemy.Transport.Channel property) queue_declare() (kombu.Queue method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.qpid.Channel method) (kombu.transport.qpid.Connection.Channel method) (kombu.transport.qpid.Transport.Connection.Channel method) (kombu.transport.virtual.Channel method) queue_delete() (kombu.transport.mongodb.Channel method) (kombu.transport.mongodb.Transport.Channel method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.qpid.Channel method) (kombu.transport.qpid.Connection.Channel method) (kombu.transport.qpid.Transport.Connection.Channel method) (kombu.transport.virtual.Channel method)

queue_index (kombu.transport.virtual.BrokerState attribute) queue_mgmt_service (kombu.transport.azureservicebus.Channel property) (kombu.transport.azureservicebus.Transport.Channel property) queue_name_prefix (kombu.transport.azureservicebus.Channel property) (kombu.transport.azureservicebus.Transport.Channel property) (kombu.transport.azurestoragequeues.Channel property) (kombu.transport.azurestoragequeues.Transport.Channel property) (kombu.transport.SLMQ.Channel property) (kombu.transport.SLMQ.Transport.Channel property) (kombu.transport.SQS.Channel property) (kombu.transport.SQS.Transport.Channel property) queue_opts (kombu.simple.SimpleBuffer attribute) (kombu.simple.SimpleQueue attribute) queue_order_strategy (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) queue_purge() (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.qpid.Channel method) (kombu.transport.qpid.Connection.Channel method) (kombu.transport.qpid.Transport.Connection.Channel method) (kombu.transport.virtual.Channel method) queue_service (kombu.transport.azureservicebus.Channel property) (kombu.transport.azureservicebus.Transport.Channel property) (kombu.transport.azurestoragequeues.Channel property) (kombu.transport.azurestoragequeues.Transport.Channel property) queue_unbind() (kombu.Queue method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.qpid.Channel method) (kombu.transport.qpid.Connection.Channel method) (kombu.transport.qpid.Transport.Connection.Channel method) queues (kombu.compat.Consumer property) (kombu.compat.ConsumerSet property) (kombu.Consumer attribute) (kombu.transport.memory.Channel attribute) (kombu.transport.memory.Transport.Channel attribute) (kombu.transport.mongodb.Channel property) (kombu.transport.mongodb.Transport.Channel property) queues() (kombu.transport.pyro.Channel method) (kombu.transport.pyro.Transport.Channel method) queues_collection (kombu.transport.mongodb.Channel attribute) (kombu.transport.mongodb.Transport.Channel attribute)

R

raise_for_error() (kombu.asynchronous.http.base.Response method) (kombu.asynchronous.http.Response method) raw_encode() (in module kombu.serialization) READ (kombu.asynchronous.Hub attribute) (kombu.asynchronous.hub.Hub attribute) read() (kombu.asynchronous.aws.sqs.queue.AsyncQueue method) receive() (kombu.compat.Consumer method) (kombu.compat.ConsumerSet method) (kombu.Consumer method) receive_message() (kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection method) recover() (kombu.compat.Consumer method) (kombu.compat.ConsumerSet method) (kombu.Consumer method) recoverable_channel_errors (kombu.Connection attribute) (kombu.connection.Connection property) (kombu.transport.base.Transport attribute) (kombu.transport.pyamqp.Connection attribute) (kombu.transport.pyamqp.Transport attribute) (kombu.transport.qpid.Transport attribute) recoverable_connection_errors (kombu.Connection attribute) (kombu.connection.Connection property) (kombu.transport.base.Transport attribute) (kombu.transport.pyamqp.Connection attribute) (kombu.transport.pyamqp.Transport attribute) (kombu.transport.qpid.Transport attribute) region (kombu.transport.SQS.Channel property) (kombu.transport.SQS.Transport.Channel property) regioninfo (kombu.transport.SQS.Channel property) (kombu.transport.SQS.Transport.Channel property) register() (in module kombu.compression) (in module kombu.matcher) (in module kombu.serialization) (kombu.matcher.MatcherRegistry method) register_callback() (kombu.compat.Consumer method) (kombu.compat.ConsumerSet method) (kombu.Consumer method) register_glob() (in module kombu.matcher) register_group() (in module kombu.pools) register_pcre() (in module kombu.matcher) register_type() (in module kombu.utils.json) register_with_event_loop() (kombu.Connection method) (kombu.connection.Connection method) (kombu.transport.pyamqp.Transport method) (kombu.transport.qpid.Transport method) (kombu.transport.redis.Transport method) registry (in module kombu.matcher) (in module kombu.serialization) reject() (kombu.message.Message method) (kombu.transport.base.Message method) (kombu.transport.pyamqp.Connection.Channel.Message method) (kombu.transport.qpid.Channel.QoS method) (kombu.transport.qpid.Connection.Channel.QoS method) (kombu.transport.qpid.Transport.Connection.Channel.QoS method) (kombu.transport.redis.Channel.QoS method) (kombu.transport.redis.Transport.Channel.QoS method) (kombu.transport.SQS.Channel.QoS method) (kombu.transport.SQS.Transport.Channel.QoS method) (kombu.transport.virtual.Message method) (kombu.transport.virtual.QoS method) reject_log_error() (kombu.message.Message method) (kombu.transport.pyamqp.Connection.Channel.Message method) (kombu.transport.virtual.Message method) release() (kombu.asynchronous.semaphore.LaxBoundedSemaphore method) (kombu.compat.Publisher method) (kombu.Connection method) (kombu.connection.ChannelPool method) (kombu.connection.Connection method) (kombu.connection.ConnectionPool method) (kombu.pools.ProducerPool method) (kombu.pools.ProducerPool.Producer method) (kombu.resource.Resource method) release_resource() (kombu.resource.Resource method) remove() (kombu.asynchronous.Hub method) (kombu.asynchronous.hub.Hub method) remove_permission() (kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection method) (kombu.asynchronous.aws.sqs.queue.AsyncQueue method) remove_reader() (kombu.asynchronous.Hub method) (kombu.asynchronous.hub.Hub method) remove_writer() (kombu.asynchronous.Hub method) (kombu.asynchronous.hub.Hub method) replace() (kombu.resource.Resource method)

reply() (kombu.pidbox.Node method) reply_exchange (kombu.pidbox.Mailbox attribute) repr_active() (in module kombu.asynchronous.debug) (kombu.asynchronous.Hub method) (kombu.asynchronous.hub.Hub method) repr_events() (in module kombu.asynchronous.debug) (kombu.asynchronous.Hub method) (kombu.asynchronous.hub.Hub method) repr_flag() (in module kombu.asynchronous.debug) repr_readers() (in module kombu.asynchronous.debug) repr_writers() (in module kombu.asynchronous.debug) Request (class in kombu.asynchronous.http) (class in kombu.asynchronous.http.base) request (kombu.asynchronous.http.base.Response attribute), [1] (kombu.asynchronous.http.Response attribute), [1] request() (kombu.asynchronous.aws.connection.AsyncHTTPSConnection method) request_timeout (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.Request attribute) requeue() (kombu.message.Message method) (kombu.transport.base.Message method) (kombu.transport.pyamqp.Connection.Channel.Message method) (kombu.transport.virtual.Message method) reset() (in module kombu.pools) (kombu.asynchronous.Hub method) (kombu.asynchronous.hub.Hub method) resize() (kombu.resource.Resource method) resolve_aliases (kombu.connection.Connection attribute) resolve_transport() (in module kombu.transport) Resource (class in kombu.resource) Resource.LimitExceeded Response (class in kombu.asynchronous.http) (class in kombu.asynchronous.http.base) (kombu.asynchronous.aws.connection.AsyncHTTPSConnection attribute) restart_limit (kombu.mixins.ConsumerMixin property) restore_at_shutdown (kombu.transport.redis.Channel.QoS attribute) (kombu.transport.redis.Transport.Channel.QoS attribute) (kombu.transport.virtual.QoS attribute) restore_by_tag() (kombu.transport.redis.Channel.QoS method) (kombu.transport.redis.Transport.Channel.QoS method) restore_unacked() (kombu.transport.redis.Channel.QoS method) (kombu.transport.redis.Transport.Channel.QoS method) (kombu.transport.virtual.QoS method) restore_unacked_once() (kombu.transport.virtual.QoS method) restore_visible() (kombu.transport.redis.Channel.QoS method) (kombu.transport.redis.Transport.Channel.QoS method) (kombu.transport.virtual.QoS method) retry_backoff_factor (kombu.transport.azureservicebus.Channel property) (kombu.transport.azureservicebus.Transport.Channel property) retry_backoff_max (kombu.transport.azureservicebus.Channel property) (kombu.transport.azureservicebus.Transport.Channel property) retry_on_timeout (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) retry_over_time() (in module kombu.utils.functional) retry_total (kombu.transport.azureservicebus.Channel property) (kombu.transport.azureservicebus.Transport.Channel property) revive() (kombu.abstract.MaybeChannelBound method) (kombu.compat.Consumer method) (kombu.compat.ConsumerSet method) (kombu.compat.Publisher method) (kombu.Connection method) (kombu.connection.Connection method) (kombu.Consumer method) (kombu.pools.ProducerPool.Producer method) (kombu.Producer method) rotate() (kombu.utils.scheduling.priority_cycle method) (kombu.utils.scheduling.round_robin_cycle method) round_robin_cycle (class in kombu.utils.scheduling) routing (kombu.transport.mongodb.Channel property) (kombu.transport.mongodb.Transport.Channel property) routing_collection (kombu.transport.mongodb.Channel attribute) (kombu.transport.mongodb.Transport.Channel attribute) routing_key (kombu.compat.Consumer attribute) (kombu.compat.Publisher attribute) (kombu.pools.ProducerPool.Producer attribute) (kombu.Producer attribute) (kombu.Queue attribute), [1] run() (kombu.mixins.ConsumerMixin method) run_forever() (kombu.asynchronous.Hub method) (kombu.asynchronous.hub.Hub method) run_once() (kombu.asynchronous.Hub method) (kombu.asynchronous.hub.Hub method)

S

safe_repr() (in module kombu.utils.encoding) safe_str() (in module kombu.utils.encoding) sanitize_url() (in module kombu.utils.url) save() (kombu.asynchronous.aws.sqs.queue.AsyncQueue method) save_to_file() (kombu.asynchronous.aws.sqs.queue.AsyncQueue method) save_to_filename() (kombu.asynchronous.aws.sqs.queue.AsyncQueue method) save_to_s3() (kombu.asynchronous.aws.sqs.queue.AsyncQueue method) schedule (kombu.asynchronous.timer.Timer property) scheduler (kombu.asynchronous.Hub property) (kombu.asynchronous.hub.Hub property) scheme (kombu.utils.url.urlparts attribute) send() (kombu.asynchronous.aws.connection.AsyncHTTPSConnection method) (kombu.compat.Publisher method) send_heartbeat() (kombu.transport.pyamqp.Connection method) send_message() (kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection method) send_message_batch() (kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection method) send_method() (kombu.transport.pyamqp.Connection method) (kombu.transport.pyamqp.Connection.Channel method) send_reply() (in module kombu.common) sent_at (kombu.transport.sqlalchemy.models.Message attribute) SentinelChannel (class in kombu.transport.redis) sep (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) serializable() (kombu.transport.qpid.Channel.Message method) (kombu.transport.qpid.Connection.Channel.Message method) (kombu.transport.qpid.Message method) (kombu.transport.qpid.Transport.Connection.Channel.Message method) (kombu.transport.virtual.Message method) serializer (kombu.compat.Publisher attribute) (kombu.pools.ProducerPool.Producer attribute) (kombu.Producer attribute) SerializerNotInstalled server_capabilities (kombu.transport.pyamqp.Connection property) server_heartbeat (kombu.transport.pyamqp.Connection attribute) session (kombu.transport.sqlalchemy.Channel property) (kombu.transport.sqlalchemy.Transport.Channel property) session_ttl (kombu.transport.consul.Channel attribute) (kombu.transport.consul.Transport.Channel attribute) (kombu.transport.etcd.Channel attribute) (kombu.transport.etcd.Transport.Channel attribute) set_attribute() (kombu.asynchronous.aws.sqs.queue.AsyncQueue method) set_debuglevel() (kombu.asynchronous.aws.connection.AsyncHTTPSConnection method) set_default_encoding_file() (in module kombu.utils.encoding) set_event_loop() (in module kombu.asynchronous) (in module kombu.asynchronous.hub) set_limit() (in module kombu.pools) set_queue_attribute() (kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection method) set_timeout() (kombu.asynchronous.aws.sqs.queue.AsyncQueue method) setter() (kombu.utils.objects.cached_property method) setup() (kombu.pools.ProducerPool method) (kombu.resource.Resource method) setup_logging() (in module kombu.log) (in module kombu.utils.debug) shared_queues (kombu.transport.pyro.Channel property) (kombu.transport.pyro.Transport property) (kombu.transport.pyro.Transport.Channel property) should_stop (kombu.mixins.ConsumerMixin attribute) shrink() (kombu.asynchronous.semaphore.LaxBoundedSemaphore method)

SimpleBuffer (class in kombu.simple) SimpleBuffer() (kombu.Connection method) (kombu.connection.Connection method) SimpleQueue (class in kombu.simple) SimpleQueue() (kombu.Connection method) (kombu.connection.Connection method) slmq (kombu.transport.SLMQ.Channel property) (kombu.transport.SLMQ.Transport.Channel property) sock (kombu.transport.pyamqp.Connection property) socket_connect_timeout (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) socket_keepalive (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) socket_keepalive_options (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) socket_timeout (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) sort_heap() (kombu.clocks.LamportClock method) sorted_cycle (class in kombu.utils.scheduling) sqs() (kombu.transport.SQS.Channel method) (kombu.transport.SQS.Transport.Channel method) sqs_base64_encoding (kombu.transport.SQS.Channel property) (kombu.transport.SQS.Transport.Channel property) ssl (kombu.Connection attribute) (kombu.connection.Connection attribute) (kombu.transport.mongodb.Channel attribute) (kombu.transport.mongodb.Transport.Channel attribute) state (kombu.pidbox.Node attribute) (kombu.transport.virtual.Channel attribute) (kombu.transport.virtual.Transport attribute) status (kombu.asynchronous.http.base.Response attribute), [1] (kombu.asynchronous.http.Response attribute), [1] status_code (kombu.asynchronous.http.base.Response property) (kombu.asynchronous.http.Response property) stop() (kombu.asynchronous.Hub method) (kombu.asynchronous.hub.Hub method) (kombu.asynchronous.timer.Timer method) store_processed (kombu.transport.filesystem.Channel property) (kombu.transport.filesystem.Transport.Channel property) str_to_bytes() (in module kombu.utils.encoding) subclient (kombu.transport.redis.Channel property) (kombu.transport.redis.Transport.Channel property) supports_exchange_type() (kombu.connection.Connection method) supports_fanout (kombu.transport.filesystem.Channel attribute) (kombu.transport.filesystem.Transport.Channel attribute) (kombu.transport.memory.Channel attribute) (kombu.transport.memory.Transport.Channel attribute) (kombu.transport.mongodb.Channel attribute) (kombu.transport.mongodb.Transport.Channel attribute) (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) (kombu.transport.SQS.Channel property) (kombu.transport.SQS.Transport.Channel property) supports_heartbeats (kombu.Connection attribute) (kombu.connection.Connection property) switch() (kombu.Connection method) (kombu.connection.Connection method) symbol_by_name() (in module kombu.utils.imports)

T

then() (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request method) (kombu.asynchronous.http.base.Request method) (kombu.asynchronous.http.Request method) (kombu.transport.pyamqp.Connection method) (kombu.transport.pyamqp.Connection.Channel method) timeout (kombu.transport.consul.Channel attribute) (kombu.transport.consul.Transport.Channel attribute) (kombu.transport.etcd.Channel attribute) (kombu.transport.etcd.Transport.Channel attribute) TimeoutError (in module kombu.exceptions) Timer (class in kombu.asynchronous.timer) Timer.Entry (class in kombu.asynchronous.timer) timestamp (kombu.clocks.timetuple property) (kombu.utils.limits.TokenBucket attribute) timetuple (class in kombu.clocks) to_timestamp() (in module kombu.asynchronous.timer) TokenBucket (class in kombu.utils.limits) TopicExchange (class in kombu.transport.virtual.exchange) TRANSIENT_DELIVERY_MODE (kombu.Exchange attribute) Transport (class in kombu.transport.azureservicebus) (class in kombu.transport.azurestoragequeues) (class in kombu.transport.base) (class in kombu.transport.consul) (class in kombu.transport.etcd) (class in kombu.transport.filesystem) (class in kombu.transport.memory) (class in kombu.transport.mongodb) (class in kombu.transport.pyamqp) (class in kombu.transport.pyro) (class in kombu.transport.qpid) (class in kombu.transport.redis) (class in kombu.transport.SLMQ) (class in kombu.transport.sqlalchemy) (class in kombu.transport.SQS) (class in kombu.transport.virtual) (class in kombu.transport.zookeeper) transport (kombu.Connection attribute) (kombu.connection.Connection property) (kombu.transport.pyamqp.Connection property) Transport() (kombu.transport.pyamqp.Connection method) Transport.Channel (class in kombu.transport.azureservicebus) (class in kombu.transport.azurestoragequeues) (class in kombu.transport.consul) (class in kombu.transport.etcd) (class in kombu.transport.filesystem) (class in kombu.transport.memory) (class in kombu.transport.mongodb) (class in kombu.transport.pyro) (class in kombu.transport.redis) (class in kombu.transport.SLMQ) (class in kombu.transport.sqlalchemy) (class in kombu.transport.SQS) (class in kombu.transport.zookeeper)

Transport.Channel.QoS (class in kombu.transport.redis) (class in kombu.transport.SQS) Transport.Connection (class in kombu.transport.pyamqp) (class in kombu.transport.qpid) Transport.Connection.Channel (class in kombu.transport.pyamqp) (class in kombu.transport.qpid) Transport.Connection.Channel.Message (class in kombu.transport.pyamqp) (class in kombu.transport.qpid) Transport.Connection.Channel.QoS (class in kombu.transport.qpid) TRANSPORT_ALIASES (in module kombu.transport) transport_options (kombu.connection.Connection attribute) (kombu.transport.azureservicebus.Channel property) (kombu.transport.azureservicebus.Transport.Channel property) (kombu.transport.azurestoragequeues.Channel property) (kombu.transport.azurestoragequeues.Transport.Channel property) (kombu.transport.filesystem.Channel property) (kombu.transport.filesystem.Transport.Channel property) (kombu.transport.SLMQ.Channel property) (kombu.transport.SLMQ.Transport.Channel property) (kombu.transport.SQS.Channel property) (kombu.transport.SQS.Transport.Channel property) tref (kombu.asynchronous.timer.Entry attribute) (kombu.asynchronous.timer.Timer.Entry attribute) ttl (kombu.transport.mongodb.Channel attribute) (kombu.transport.mongodb.Transport.Channel attribute) tx_commit() (kombu.transport.pyamqp.Connection.Channel method) tx_rollback() (kombu.transport.pyamqp.Connection.Channel method) tx_select() (kombu.transport.pyamqp.Connection.Channel method) type (kombu.Exchange attribute), [1] (kombu.pidbox.Mailbox attribute) (kombu.transport.virtual.exchange.DirectExchange attribute) (kombu.transport.virtual.exchange.ExchangeType attribute) (kombu.transport.virtual.exchange.FanoutExchange attribute) (kombu.transport.virtual.exchange.TopicExchange attribute) typeof() (kombu.transport.qpid.Channel method) (kombu.transport.qpid.Connection.Channel method) (kombu.transport.qpid.Transport.Connection.Channel method) (kombu.transport.virtual.Channel method)

U

uamqp_keep_alive_interval (kombu.transport.azureservicebus.Channel property) (kombu.transport.azureservicebus.Transport.Channel property) unacked_index_key (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Channel.QoS property) (kombu.transport.redis.Transport.Channel attribute) (kombu.transport.redis.Transport.Channel.QoS property) unacked_key (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Channel.QoS property) (kombu.transport.redis.Transport.Channel attribute) (kombu.transport.redis.Transport.Channel.QoS property) unacked_mutex_expire (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Channel.QoS property) (kombu.transport.redis.Transport.Channel attribute) (kombu.transport.redis.Transport.Channel.QoS property) unacked_mutex_key (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Channel.QoS property) (kombu.transport.redis.Transport.Channel attribute) (kombu.transport.redis.Transport.Channel.QoS property) unacked_restore_limit (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) unbind_from() (kombu.Exchange method) (kombu.Queue method) unregister() (in module kombu.matcher) (in module kombu.serialization) (kombu.matcher.MatcherRegistry method)

update() (kombu.utils.functional.LRUCache method) (kombu.utils.scheduling.round_robin_cycle method) uri_prefix (kombu.Connection attribute) (kombu.connection.Connection attribute) URL url (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.Request attribute) url_to_parts() (in module kombu.utils.url) urlparts (class in kombu.utils.url) use_gzip (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.Request attribute) user_agent (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.Request attribute) userid (kombu.Connection attribute) (kombu.connection.Connection attribute) username (kombu.utils.url.urlparts attribute) uuid() (in module kombu.common) (in module kombu.utils.uuid)

V

validate_cert (kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request attribute) (kombu.asynchronous.http.base.Request attribute) (kombu.asynchronous.http.Request attribute) value (kombu.clocks.LamportClock attribute) values() (kombu.utils.functional.LRUCache method) verify_connection() (kombu.transport.consul.Transport method) (kombu.transport.etcd.Transport method) (kombu.transport.pyamqp.Transport method) verify_runtime_environment() (kombu.transport.qpid.Transport method) version (kombu.transport.sqlalchemy.models.Message attribute) version_string_as_tuple() (in module kombu.utils.text)

VHOST virtual_host (kombu.Connection attribute) (kombu.connection.Connection attribute) visibility_timeout (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Channel.QoS property) (kombu.transport.redis.Transport.Channel attribute) (kombu.transport.redis.Transport.Channel.QoS property) (kombu.transport.SLMQ.Channel property) (kombu.transport.SLMQ.Transport.Channel property) (kombu.transport.SQS.Channel property) (kombu.transport.SQS.Transport.Channel property) visible (kombu.transport.sqlalchemy.models.Message attribute)

W

wait() (kombu.compat.Consumer method) (kombu.transport.pyamqp.Connection method) (kombu.transport.pyamqp.Connection.Channel method) wait_time_seconds (kombu.transport.azureservicebus.Channel property) (kombu.transport.azureservicebus.Transport.Channel property) (kombu.transport.SQS.Channel property) (kombu.transport.SQS.Transport attribute) (kombu.transport.SQS.Transport.Channel property) warn() (kombu.log.LogMixin method) when_bound() (kombu.abstract.MaybeChannelBound method) (kombu.Queue method)

wildcards (kombu.transport.virtual.exchange.TopicExchange attribute) with_traceback() (kombu.compat.Consumer.ContentDisallowed method) (kombu.compat.ConsumerSet.ContentDisallowed method) (kombu.transport.pyamqp.Connection.Channel.Message.MessageStateError method) (kombu.transport.virtual.Message.MessageStateError method) WRITE (kombu.asynchronous.Hub attribute) (kombu.asynchronous.hub.Hub attribute) write() (kombu.asynchronous.aws.sqs.queue.AsyncQueue method) write_batch() (kombu.asynchronous.aws.sqs.queue.AsyncQueue method)