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.compat.Consumer attribute) (kombu.compat.ConsumerSet attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.virtual.Message attribute) ack() (kombu.transport.base.Message method) (kombu.transport.pyamqp.Connection.Channel.Message 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.transport.pyamqp.Connection.Channel.Message method) (kombu.transport.virtual.Message method) acknowledged (kombu.transport.base.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.virtual.Message attribute) acquire() (kombu.connection.ChannelPool method) (kombu.connection.ConnectionPool method) active_queues (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) add_consumer() (kombu.compat.ConsumerSet method) add_consumer_from_dict() (kombu.compat.ConsumerSet method) add_queue() (kombu.compat.Consumer method) (kombu.Consumer method) (kombu.compat.ConsumerSet method) add_queue_from_dict() (kombu.compat.Consumer method) (kombu.Consumer method) (kombu.compat.ConsumerSet 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) alias (kombu.Queue attribute) annotate() (kombu.log.LogMixin method) append() (kombu.transport.redis.Channel.QoS method) (kombu.transport.redis.Transport.Channel.QoS method) (kombu.transport.virtual.QoS method) args (kombu.transport.pyamqp.Connection.Channel.Message.MessageStateError attribute) (kombu.transport.virtual.Message.MessageStateError attribute) arguments (kombu.Exchange attribute) as_uri() (kombu.Connection method) (kombu.connection.Connection method) attrs (kombu.Exchange attribute) (kombu.Queue attribute) auto_declare (kombu.compat.Consumer attribute) (kombu.Consumer attribute) (kombu.Producer attribute) (kombu.compat.ConsumerSet attribute) (kombu.compat.Publisher attribute) (kombu.pools.ProducerPool.Producer attribute) auto_delete (kombu.compat.Consumer attribute) (kombu.Exchange attribute), [1] (kombu.Queue attribute), [1] (kombu.compat.Publisher attribute) autoretry() (kombu.Connection method) (kombu.connection.Connection method) AWS_ACCESS_KEY_ID AWS_SECRET_ACCESS_KEY

B

backend (kombu.compat.Publisher attribute) basic_ack() (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.SQS.Channel method) (kombu.transport.SQS.Transport.Channel method) (kombu.transport.virtual.Channel method) basic_cancel() (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.SQS.Channel method) (kombu.transport.SQS.Transport.Channel method) (kombu.transport.redis.Channel method) (kombu.transport.redis.Transport.Channel method) (kombu.transport.virtual.Channel method) basic_consume() (kombu.transport.django.Channel method) (kombu.transport.SQS.Channel method) (kombu.transport.SQS.Transport.Channel method) (kombu.transport.django.Transport.Channel method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.redis.Channel method) (kombu.transport.redis.Transport.Channel method) (kombu.transport.virtual.Channel method) basic_get() (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.virtual.Channel method) basic_publish() (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.virtual.Channel method) basic_qos() (kombu.transport.pyamqp.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.virtual.Channel method) bind() (kombu.abstract.MaybeChannelBound method) (kombu.Queue method) bind_to() (kombu.Exchange method) (kombu.Queue method) binding_arguments (kombu.Queue attribute) bindings (kombu.transport.virtual.BrokerState attribute) body (kombu.transport.base.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.virtual.Message attribute) Broadcast (class in kombu.common) BrokerState (class in kombu.transport.virtual) bytes_to_str() (in module kombu.utils.encoding)

C

cached_property (in module kombu.utils) call() (kombu.pidbox.Mailbox method) callbacks (kombu.compat.Consumer attribute) (kombu.Consumer attribute) (kombu.compat.ConsumerSet attribute) can_cache_declaration (kombu.abstract.MaybeChannelBound attribute) (kombu.Exchange attribute) (kombu.Queue attribute) can_consume() (kombu.transport.virtual.QoS method) (kombu.utils.limits.TokenBucket method) cancel() (kombu.compat.Consumer method) (kombu.Consumer method) (kombu.Queue method) (kombu.compat.ConsumerSet method) (kombu.utils.finalize.Finalize method) cancel_by_queue() (kombu.compat.Consumer method) (kombu.Consumer method) (kombu.compat.ConsumerSet method) capacity (kombu.utils.limits.TokenBucket attribute) cast() (kombu.pidbox.Mailbox method) Channel (class in kombu.transport.django) (class in kombu.transport.SQS) (class in kombu.transport.filesystem) (class in kombu.transport.memory) (class in kombu.transport.mongodb) (class in kombu.transport.pyamqp) (class in kombu.transport.redis) (class in kombu.transport.sqlalchemy) (class in kombu.transport.virtual) (class in kombu.transport.zookeeper) channel (kombu.abstract.MaybeChannelBound attribute) (kombu.Consumer attribute) (kombu.Exchange attribute) (kombu.Producer attribute) (kombu.Queue attribute) (kombu.compat.Consumer attribute) (kombu.compat.ConsumerSet attribute) (kombu.compat.Publisher attribute) (kombu.pidbox.Node attribute) (kombu.pools.ProducerPool.Producer attribute) (kombu.simple.SimpleBuffer attribute) (kombu.simple.SimpleQueue attribute) (kombu.transport.base.Message attribute) (kombu.transport.pyamqp.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) Channel.QoS (class in kombu.transport.redis) Channel.Table (class in kombu.transport.SQS) channel_errors (kombu.Connection attribute) (kombu.connection.Connection attribute) (kombu.mixins.ConsumerMixin attribute) (kombu.transport.SQS.Transport attribute) (kombu.transport.base.Transport attribute) (kombu.transport.django.Transport attribute) (kombu.transport.filesystem.Transport attribute) (kombu.transport.mongodb.Transport attribute) (kombu.transport.pyamqp.Connection attribute) (kombu.transport.pyamqp.Transport attribute) (kombu.transport.sqlalchemy.Transport attribute) (kombu.transport.zookeeper.Transport attribute) ChannelLimitExceeded ChannelPool (class in kombu.connection) ChannelPool() (kombu.Connection method) (kombu.connection.Connection method) cleanup() (kombu.transport.django.managers.MessageManager method) cleanup_every (kombu.transport.django.managers.MessageManager attribute) clear() (kombu.simple.SimpleBuffer method) (kombu.simple.SimpleQueue method) (kombu.transport.virtual.BrokerState method) client (kombu.transport.base.Transport 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.zookeeper.Channel attribute) (kombu.transport.zookeeper.Transport.Channel attribute) clone() (kombu.Connection method) (kombu.connection.Connection method) close() (kombu.compat.Consumer method) (kombu.Connection method) (kombu.compat.ConsumerSet method) (kombu.compat.Publisher method) (kombu.connection.Connection method) (kombu.pools.ProducerPool.Producer method) (kombu.simple.SimpleBuffer method) (kombu.simple.SimpleQueue method) (kombu.transport.SQS.Channel method) (kombu.transport.SQS.Transport.Channel method) (kombu.transport.mongodb.Channel method) (kombu.transport.mongodb.Transport.Channel method) (kombu.transport.pyamqp.Connection method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.redis.Channel method) (kombu.transport.redis.Transport.Channel method) (kombu.transport.virtual.Channel method) (kombu.transport.virtual.scheduling.FairCycle method) close_channel() (kombu.transport.base.Transport method) (kombu.transport.virtual.Transport method) close_connection() (kombu.transport.base.Transport method) (kombu.transport.pyamqp.Transport method) (kombu.transport.virtual.Transport method) close_resource() (kombu.pools.ProducerPool method) collect() (kombu.connection.Connection method) collect_replies() (in module kombu.common) completes_cycle() (kombu.Connection method) (kombu.connection.Connection method) compress() (in module kombu.compression) compression (kombu.compat.Publisher attribute) (kombu.Producer attribute) (kombu.pools.ProducerPool.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.Connection method) (kombu.connection.Connection method) connect_max_retries (kombu.mixins.ConsumerMixin attribute) connect_timeout (kombu.Connection attribute) (kombu.connection.Connection attribute) connected (kombu.Connection attribute) (kombu.connection.Connection attribute) Connection (class in kombu) (class in kombu.connection) (class in kombu.transport.pyamqp) connection (kombu.compat.Consumer attribute) (kombu.Connection attribute) (kombu.Consumer attribute) (kombu.Producer attribute) (kombu.compat.ConsumerSet attribute) (kombu.compat.Publisher attribute) (kombu.connection.Connection attribute) (kombu.pidbox.Mailbox attribute) (kombu.pools.ProducerPool.Producer attribute) Connection.Channel (class in kombu.transport.pyamqp) Connection.Channel.Message (class in kombu.transport.pyamqp) Connection.Channel.Message.MessageStateError connection_errors (kombu.Connection attribute) (kombu.connection.Connection attribute) (kombu.mixins.ConsumerMixin attribute) (kombu.transport.SQS.Transport attribute) (kombu.transport.base.Transport attribute) (kombu.transport.django.Transport attribute) (kombu.transport.filesystem.Transport attribute) (kombu.transport.mongodb.Transport attribute) (kombu.transport.pyamqp.Connection attribute) (kombu.transport.pyamqp.Transport attribute) (kombu.transport.sqlalchemy.Transport attribute) (kombu.transport.zookeeper.Transport attribute) connection_for_write() (kombu.transport.django.managers.MessageManager method) ConnectionLimitExceeded ConnectionPool (class in kombu.connection) conninfo (kombu.transport.SQS.Channel attribute) (kombu.transport.SQS.Transport.Channel attribute) consume() (kombu.compat.Consumer method) (kombu.Consumer method) (kombu.Queue method) (kombu.compat.ConsumerSet method) (kombu.mixins.ConsumerMixin 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) ConsumerMixin (class in kombu.mixins) ConsumerSet (class in kombu.compat) consuming_from() (kombu.compat.Consumer method) (kombu.Consumer method) (kombu.compat.ConsumerSet method) content_encoding (kombu.transport.base.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.virtual.Message attribute) content_type (kombu.transport.base.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.virtual.Message attribute) create() (kombu.pools.PoolGroup method) create_backend() (kombu.connection.Connection method) create_binding() (kombu.transport.SQS.Channel.Table method) (kombu.transport.SQS.Transport.Channel.Table method) create_channel() (kombu.transport.base.Transport method) (kombu.transport.pyamqp.Transport method) (kombu.transport.virtual.Transport method) create_producer() (kombu.pools.ProducerPool method) create_transport() (kombu.Connection method) (kombu.connection.Connection method) critical() (kombu.log.LogMixin method) cycle (kombu.Connection attribute) (kombu.connection.Connection attribute) (kombu.transport.virtual.Transport attribute) Cycle (kombu.transport.virtual.Transport attribute)

D

data_folder_in (kombu.transport.filesystem.Channel attribute) (kombu.transport.filesystem.Transport.Channel attribute) data_folder_out (kombu.transport.filesystem.Channel attribute) (kombu.transport.filesystem.Transport.Channel attribute) debug() (kombu.log.LogMixin method) declare() (kombu.compat.Consumer method) (kombu.Consumer method) (kombu.Exchange method) (kombu.Producer method) (kombu.Queue method) (kombu.compat.ConsumerSet method) (kombu.compat.Publisher method) (kombu.pools.ProducerPool.Producer method) declared_entities (kombu.Connection attribute) (kombu.connection.Connection attribute) decode() (in module kombu.serialization) (kombu.transport.base.Message method) (kombu.transport.pyamqp.Connection.Channel.Message method) (kombu.transport.virtual.Message method) decompress() (in module kombu.compression) default_channel (kombu.Connection attribute) (kombu.connection.Connection attribute) default_connection_params (kombu.transport.pyamqp.Transport attribute) default_encode() (in module kombu.utils.encoding) default_encoding() (in module kombu.utils.encoding) default_port (kombu.transport.base.Transport attribute) (kombu.transport.SQS.Transport attribute) (kombu.transport.django.Transport attribute) (kombu.transport.filesystem.Transport attribute) (kombu.transport.mongodb.Transport attribute) (kombu.transport.pyamqp.Transport attribute) (kombu.transport.redis.Transport attribute) (kombu.transport.sqlalchemy.Transport attribute) (kombu.transport.virtual.Transport attribute) (kombu.transport.zookeeper.Transport attribute) default_region (kombu.transport.SQS.Channel attribute) (kombu.transport.SQS.Transport.Channel attribute) DEFAULT_TRANSPORT (in module kombu.transport) default_visibility_timeout (kombu.transport.SQS.Channel attribute) (kombu.transport.SQS.Transport.Channel attribute) default_wait_time_seconds (kombu.transport.SQS.Channel attribute) (kombu.transport.SQS.Transport.Channel attribute) delete() (kombu.Exchange method) (kombu.Queue method) deliver() (kombu.transport.virtual.exchange.DirectExchange method) (kombu.transport.virtual.exchange.FanoutExchange method) (kombu.transport.virtual.exchange.TopicExchange method) delivery_info (kombu.transport.base.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.virtual.Message attribute)

delivery_mode (kombu.Exchange attribute), [1] delivery_tag (kombu.transport.base.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.virtual.Message attribute) detect_environment() (in module kombu.syn) 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.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.virtual.Channel method) (kombu.transport.virtual.Transport method) drain_nowait() (kombu.Connection method) (kombu.connection.Connection method) driver_name (kombu.transport.django.Transport attribute) (kombu.transport.SQS.Transport attribute) (kombu.transport.filesystem.Transport attribute) (kombu.transport.memory.Transport attribute) (kombu.transport.mongodb.Transport attribute) (kombu.transport.pyamqp.Transport attribute) (kombu.transport.redis.Transport attribute) (kombu.transport.sqlalchemy.Transport attribute) (kombu.transport.zookeeper.Transport attribute) driver_type (kombu.transport.django.Transport attribute) (kombu.transport.SQS.Transport attribute) (kombu.transport.filesystem.Transport attribute) (kombu.transport.memory.Transport attribute) (kombu.transport.mongodb.Transport attribute) (kombu.transport.pyamqp.Transport attribute) (kombu.transport.redis.Transport attribute) (kombu.transport.sqlalchemy.Transport attribute) (kombu.transport.zookeeper.Transport attribute) driver_version() (kombu.transport.django.Transport method) (kombu.transport.filesystem.Transport method) (kombu.transport.memory.Transport method) (kombu.transport.mongodb.Transport method) (kombu.transport.redis.Transport method) (kombu.transport.sqlalchemy.Transport method) (kombu.transport.zookeeper.Transport method) durable (kombu.compat.Consumer attribute) (kombu.Exchange attribute), [1] (kombu.Queue attribute), [1] (kombu.compat.Publisher attribute)

E

emergency_dump_state() (in module kombu.utils) enable_insecure_serializers() (in module kombu) encode() (in module kombu.serialization), [1] encoders() (in module kombu.compression) ensure() (kombu.Connection method) (kombu.connection.Connection method) ensure_bytes() (in module kombu.utils.encoding) ensure_connection() (kombu.Connection method) (kombu.connection.Connection method) entity_name() (kombu.transport.SQS.Channel method) (kombu.transport.SQS.Transport.Channel method) 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 EqualityDict (class in kombu.utils) equivalent() (kombu.transport.virtual.exchange.ExchangeType method) error() (kombu.log.LogMixin method) establish_connection() (kombu.mixins.ConsumerMixin method) (kombu.transport.base.Transport method) (kombu.transport.pyamqp.Transport method) (kombu.transport.virtual.Transport method) evaluate() (kombu.utils.functional.promise method) eventloop() (in module kombu.common) eventmap (kombu.Connection attribute) (kombu.connection.Connection attribute)

eventmap() (kombu.transport.pyamqp.Transport method) Exchange (class in kombu) exchange (kombu.compat.Consumer attribute) (kombu.Producer attribute) (kombu.Queue attribute), [1] (kombu.compat.Publisher attribute) (kombu.pidbox.Mailbox attribute) (kombu.pools.ProducerPool.Producer attribute) exchange_bind() (kombu.transport.pyamqp.Connection.Channel method) exchange_declare() (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.virtual.Channel method) exchange_delete() (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.SQS.Channel method) (kombu.transport.SQS.Channel.Table method) (kombu.transport.SQS.Transport.Channel method) (kombu.transport.SQS.Transport.Channel.Table 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) extra_context() (kombu.mixins.ConsumerMixin method)

F

failover_strategy (kombu.Connection attribute) (kombu.connection.Connection attribute) FairCycle (class in kombu.transport.virtual.scheduling) FanoutExchange (class in kombu.transport.virtual.exchange) fetch() (kombu.compat.Consumer method) (kombu.transport.django.managers.QueueManager method) fill_rate (kombu.utils.limits.TokenBucket attribute) Finalize (class in kombu.utils.finalize) flow() (kombu.compat.Consumer method) (kombu.Consumer method) (kombu.compat.ConsumerSet 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) force_close_all() (kombu.connection.ChannelPool method) (kombu.connection.ConnectionPool method) forward() (kombu.clocks.LamportClock method) from_dict() (kombu.Queue class method) from_transport_options (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) from_utf8() (in module kombu.utils.encoding) fxrange() (in module kombu.utils) fxrangemax() (in module kombu.utils)

G

get() (kombu.Queue method) (kombu.simple.SimpleBuffer method) (kombu.simple.SimpleQueue method) (kombu.transport.virtual.QoS method) (kombu.transport.virtual.scheduling.FairCycle method) get_bindings() (kombu.transport.pyamqp.Connection.Channel method) get_consumers() (kombu.mixins.ConsumerMixin method) get_decoder() (in module kombu.compression) get_encoder() (in module kombu.compression) get_errno() (in module kombu.utils.compat) get_exchanges() (kombu.transport.SQS.Channel method) (kombu.transport.SQS.Channel.Table method) (kombu.transport.SQS.Transport.Channel method) (kombu.transport.SQS.Transport.Channel.Table method) get_item() (kombu.transport.SQS.Channel.Table method) (kombu.transport.SQS.Transport.Channel.Table 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_nowait() (kombu.simple.SimpleBuffer method) (kombu.simple.SimpleQueue method) get_queue() (kombu.pidbox.Mailbox method) (kombu.transport.SQS.Channel.Table method) (kombu.transport.SQS.Transport.Channel.Table method) get_reply_queue() (kombu.pidbox.Mailbox method) get_table() (kombu.transport.mongodb.Channel method) (kombu.transport.SQS.Channel method) (kombu.transport.SQS.Transport.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_transport_cls() (in module kombu.transport) (kombu.Connection method) (kombu.connection.Connection method)

H

handle() (kombu.pidbox.Node method) handle_call() (kombu.pidbox.Node method) handle_cast() (kombu.pidbox.Node method) handle_event() (kombu.transport.redis.Transport method) handle_message() (kombu.pidbox.Node method) handler() (kombu.pidbox.Node method) handlers (kombu.pidbox.Node attribute)

headers (kombu.transport.base.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.virtual.Message attribute) heartbeat (kombu.Connection attribute) (kombu.connection.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 attribute) hostname (kombu.Connection attribute) (kombu.connection.Connection attribute) (kombu.pidbox.Node attribute)

I

id (kombu.transport.sqlalchemy.models.Message attribute) (kombu.transport.sqlalchemy.models.Queue attribute) info() (kombu.Connection method) (kombu.connection.Connection method) (kombu.log.LogMixin method) insured() (in module kombu.common) ipublish() (in module kombu.common) is_alive() (kombu.transport.pyamqp.Connection method) is_bound (kombu.abstract.MaybeChannelBound attribute)

is_enabled_for() (kombu.log.LogMixin method) is_evented (kombu.Connection attribute) (kombu.connection.Connection attribute) isend_reply() (in module kombu.common) iterconsume() (kombu.compat.Consumer method) (kombu.compat.ConsumerSet method) itermessages() (in module kombu.common) iterqueue() (kombu.compat.Consumer method)

K

key_to_pattern() (kombu.transport.virtual.exchange.TopicExchange method) keyprefix_queue (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) kombu (module) kombu.abstract (module) kombu.clocks (module) kombu.common (module) kombu.compat (module) kombu.compression (module) kombu.connection (module) kombu.exceptions (module) kombu.log (module) kombu.mixins (module) kombu.pidbox (module) kombu.pools (module) kombu.serialization (module) kombu.simple (module) kombu.syn (module) kombu.transport (module) kombu.transport.base (module) kombu.transport.django (module) kombu.transport.django.management.commands.clean_kombu_messages (module) kombu.transport.django.managers (module) kombu.transport.django.models (module) kombu.transport.filesystem (module) kombu.transport.memory (module) kombu.transport.mongodb (module)

kombu.transport.pyamqp (module) kombu.transport.redis (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.virtual.scheduling (module) kombu.transport.zmq (module) kombu.transport.zookeeper (module) kombu.utils (module) kombu.utils.amq_manager (module) kombu.utils.compat (module) kombu.utils.debug (module) kombu.utils.encoding (module) kombu.utils.eventio (module) kombu.utils.finalize (module) kombu.utils.functional (module) kombu.utils.limits (module) kombu.utils.text (module) kombu.utils.url (module) KOMBU_LOG_CHANNEL KOMBU_LOG_CONNECTION, [1] KOMBU_LOG_DEBUG, [1], [2] kwdict() (in module kombu.utils)

L

LamportClock (class in kombu.clocks) LifoQueue (class in kombu.utils.compat) LimitExceeded (kombu.connection.ChannelPool attribute) (kombu.connection.ConnectionPool attribute) listen() (kombu.pidbox.Node method) log() (kombu.log.LogMixin method) logger (kombu.log.LogMixin attribute)

logger_name (kombu.log.LogMixin attribute) login_method (kombu.Connection attribute) (kombu.connection.Connection attribute) LogMixin (class in kombu.log) Logwrapped (class in kombu.utils.debug) lookup() (kombu.transport.virtual.exchange.DirectExchange method) (kombu.transport.virtual.exchange.ExchangeType method) (kombu.transport.virtual.exchange.FanoutExchange method) (kombu.transport.virtual.exchange.TopicExchange method)

M

Mailbox (class in kombu.pidbox) mailbox (kombu.pidbox.Node attribute) manager (kombu.Connection attribute) (kombu.connection.Connection attribute) max_connections (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel 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.Producer method) (kombu.compat.Publisher method) (kombu.pools.ProducerPool.Producer method) maybe_list() (in module kombu.utils) maybe_promise() (in module kombu.utils.functional) maybe_switch_next() (kombu.Connection method) (kombu.connection.Connection method) MaybeChannelBound (class in kombu.abstract) Message (class in kombu.transport.base) (class in kombu.transport.django.models) (class in kombu.transport.pyamqp) (class in kombu.transport.sqlalchemy.models) (class in kombu.transport.virtual) message (kombu.transport.pyamqp.Connection.Channel.Message.MessageStateError attribute)

Message (kombu.transport.virtual.Channel attribute) message (kombu.transport.virtual.Message.MessageStateError attribute) Message() (kombu.Exchange method) Message.DoesNotExist Message.MessageStateError Message.MultipleObjectsReturned 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) MessageManager (class in kombu.transport.django.managers) messages (kombu.transport.django.models.Queue attribute) (kombu.transport.sqlalchemy.models.Queue attribute) MessageStateError missed_heartbeats (kombu.transport.pyamqp.Connection attribute) more_to_read (kombu.Connection attribute) (kombu.connection.Connection attribute) 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) nb_keep_draining (kombu.transport.pyamqp.Transport attribute) nested() (in module kombu.utils) new() (kombu.pools.ProducerPool method)

no_ack (kombu.compat.Consumer attribute) (kombu.Consumer attribute) (kombu.Queue attribute) (kombu.compat.ConsumerSet attribute) (kombu.simple.SimpleBuffer attribute) (kombu.simple.SimpleQueue attribute) no_ack_consumers (kombu.transport.pyamqp.Connection.Channel attribute) Node (class in kombu.pidbox) Node() (kombu.pidbox.Mailbox method) NotBoundError

O

objects (kombu.transport.django.models.Message attribute) (kombu.transport.django.models.Queue attribute) on_connection_error() (kombu.mixins.ConsumerMixin method) on_connection_revived() (kombu.mixins.ConsumerMixin method) on_consume_end() (kombu.mixins.ConsumerMixin method) on_consume_ready() (kombu.mixins.ConsumerMixin method) on_declared (kombu.Queue attribute) on_decode_error (kombu.compat.Consumer attribute) (kombu.Consumer attribute) (kombu.compat.ConsumerSet attribute)

on_decode_error() (kombu.mixins.ConsumerMixin method) on_iteration() (kombu.mixins.ConsumerMixin method) on_message (kombu.compat.Consumer attribute) (kombu.Consumer attribute) (kombu.compat.ConsumerSet attribute) on_poll_empty() (kombu.transport.redis.Transport method) on_poll_init() (kombu.transport.pyamqp.Transport method) (kombu.transport.redis.Transport method) on_poll_start() (kombu.transport.pyamqp.Transport method) (kombu.transport.redis.Transport method) on_return (kombu.compat.Publisher attribute) (kombu.Producer attribute) (kombu.pools.ProducerPool.Producer attribute)

P

parse_url() (in module kombu.utils.url) passive (kombu.Exchange attribute) password (kombu.Connection attribute) (kombu.connection.Connection attribute) payload (kombu.transport.base.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.sqlalchemy.models.Message attribute) (kombu.transport.virtual.Message attribute) 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) polling_interval (kombu.transport.django.Transport attribute) (kombu.transport.SQS.Transport attribute) (kombu.transport.mongodb.Transport attribute) (kombu.transport.redis.Transport attribute) (kombu.transport.virtual.Transport attribute) (kombu.transport.zookeeper.Transport attribute) pool (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) Pool() (kombu.Connection method) (kombu.connection.Connection method) PoolGroup (class in kombu.pools) pop() (kombu.transport.django.managers.MessageManager method) port (kombu.Connection attribute) (kombu.connection.Connection attribute) prefetch_count (kombu.transport.virtual.QoS attribute) prepare() (kombu.pools.ProducerPool 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.virtual.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_steps (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) process_next() (kombu.compat.Consumer method) processed_folder (kombu.transport.filesystem.Channel attribute) (kombu.transport.filesystem.Transport.Channel attribute) Producer (class in kombu) producer (kombu.simple.SimpleBuffer attribute) (kombu.simple.SimpleQueue attribute) Producer() (kombu.Connection method) (kombu.connection.Connection method) (kombu.transport.pyamqp.Connection.Channel method) ProducerPool (class in kombu.pools) ProducerPool.Producer (class in kombu.pools) promise (class in kombu.utils.functional) properties (kombu.transport.base.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.virtual.Message attribute) publish() (kombu.compat.Publisher method) (kombu.Exchange method) (kombu.Producer method) (kombu.pools.ProducerPool.Producer method) (kombu.transport.django.managers.QueueManager method) Publisher (class in kombu.compat) purge() (kombu.compat.Consumer method) (kombu.Consumer method) (kombu.Queue method) (kombu.compat.ConsumerSet method) (kombu.transport.django.managers.QueueManager method) put() (kombu.simple.SimpleBuffer method) (kombu.simple.SimpleQueue method)

Q

QoS (class in kombu.transport.virtual) qos (kombu.transport.virtual.Channel attribute) qos() (kombu.compat.Consumer method) (kombu.Consumer method) (kombu.compat.ConsumerSet method) qsize() (kombu.simple.SimpleBuffer method) (kombu.simple.SimpleQueue method) Queue (class in kombu) (class in kombu.transport.django.models) (class in kombu.transport.sqlalchemy.models) queue (kombu.compat.Consumer attribute) (kombu.simple.SimpleBuffer attribute) (kombu.simple.SimpleQueue attribute) (kombu.transport.django.models.Message attribute) Queue.DoesNotExist Queue.MultipleObjectsReturned queue_arguments (kombu.Queue attribute) queue_bind() (kombu.Queue method) (kombu.transport.SQS.Channel.Table method) (kombu.transport.SQS.Transport.Channel.Table method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.virtual.Channel method)

queue_declare() (kombu.Queue method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.virtual.Channel method) queue_delete() (kombu.transport.mongodb.Channel method) (kombu.transport.SQS.Channel.Table method) (kombu.transport.SQS.Transport.Channel.Table method) (kombu.transport.mongodb.Transport.Channel method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.virtual.Channel method) queue_id (kombu.transport.sqlalchemy.models.Message attribute) queue_name_prefix (kombu.transport.SQS.Channel attribute) (kombu.transport.SQS.Transport.Channel attribute) queue_opts (kombu.simple.SimpleBuffer attribute) (kombu.simple.SimpleQueue attribute) queue_purge() (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.virtual.Channel method) queue_unbind() (kombu.Queue method) (kombu.transport.pyamqp.Connection.Channel method) QueueManager (class in kombu.transport.django.managers) queues (kombu.compat.Consumer attribute) (kombu.Consumer attribute) (kombu.compat.ConsumerSet attribute) (kombu.transport.memory.Channel attribute) (kombu.transport.memory.Transport.Channel attribute)

R

raw_encode() (in module kombu.serialization) read_timeout() (kombu.transport.pyamqp.Connection method) receive() (kombu.compat.Consumer method) (kombu.Consumer method) (kombu.compat.ConsumerSet method) recover() (kombu.compat.Consumer method) (kombu.Consumer method) (kombu.compat.ConsumerSet method) recoverable_channel_errors (kombu.connection.Connection attribute) recoverable_connection_errors (kombu.connection.Connection attribute) refresh_connection() (kombu.transport.django.Channel method) (kombu.transport.django.Transport.Channel method) region (kombu.transport.SQS.Channel attribute) (kombu.transport.SQS.Transport.Channel attribute) register() (in module kombu.compression) (in module kombu.serialization) register_callback() (kombu.compat.Consumer method) (kombu.Consumer method) (kombu.compat.ConsumerSet method) register_group() (in module kombu.pools) registry (in module kombu.serialization) reject() (kombu.transport.base.Message method) (kombu.transport.pyamqp.Connection.Channel.Message method) (kombu.transport.redis.Channel.QoS method) (kombu.transport.redis.Transport.Channel.QoS method) (kombu.transport.virtual.Message method) (kombu.transport.virtual.QoS method) reject_log_error() (kombu.transport.pyamqp.Connection.Channel.Message method) (kombu.transport.virtual.Message method) release() (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) reply() (kombu.pidbox.Node method) reply_exchange (kombu.pidbox.Mailbox attribute)

reprcall() (in module kombu.utils) reprkwargs() (in module kombu.utils) requeue() (kombu.transport.base.Message method) (kombu.transport.pyamqp.Connection.Channel.Message method) (kombu.transport.virtual.Message method) reset() (in module kombu.pools) resolve_transport() (in module kombu.transport) restart_limit (kombu.mixins.ConsumerMixin attribute) 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_over_time() (in module kombu.utils) revive() (kombu.abstract.MaybeChannelBound method) (kombu.Connection method) (kombu.Consumer method) (kombu.Producer method) (kombu.compat.Consumer method) (kombu.compat.ConsumerSet method) (kombu.compat.Publisher method) (kombu.connection.Connection method) (kombu.pools.ProducerPool.Producer method) routes_for() (kombu.transport.SQS.Channel.Table method) (kombu.transport.SQS.Transport.Channel.Table method) routing_key (kombu.compat.Consumer attribute) (kombu.Producer attribute) (kombu.Queue attribute), [1] (kombu.compat.Publisher attribute) (kombu.pools.ProducerPool.Producer attribute) run() (kombu.mixins.ConsumerMixin method)

S

safe_repr() (in module kombu.utils.encoding) safe_str() (in module kombu.utils.encoding) say() (in module kombu.utils) sdb (kombu.transport.SQS.Channel attribute) (kombu.transport.SQS.Transport.Channel attribute) select() (kombu.transport.SQS.Channel.Table method) (kombu.transport.SQS.Transport.Channel.Table method) select_for_update() (in module kombu.transport.django.managers) send() (kombu.compat.Publisher method) send_heartbeat() (kombu.transport.pyamqp.Connection method) send_reply() (in module kombu.common) sent_at (kombu.transport.sqlalchemy.models.Message attribute) sep (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) serializable() (kombu.transport.virtual.Message method) serializer (kombu.compat.Publisher attribute) (kombu.Producer attribute) (kombu.pools.ProducerPool.Producer attribute) SerializerNotInstalled server_capabilities (kombu.transport.pyamqp.Connection attribute) session (kombu.transport.sqlalchemy.Channel attribute) (kombu.transport.sqlalchemy.Transport.Channel attribute) set_limit() (in module kombu.pools) setup() (kombu.pools.ProducerPool method) setup_logging() (in module kombu.log) (in module kombu.utils.debug) should_stop (kombu.mixins.ConsumerMixin attribute)

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) size() (kombu.transport.django.managers.QueueManager method) sock (kombu.transport.pyamqp.Connection attribute) socket_timeout (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) sort_heap() (kombu.clocks.LamportClock method) sqs (kombu.transport.SQS.Channel attribute) (kombu.transport.SQS.Transport.Channel attribute) ssl (kombu.Connection attribute) (kombu.connection.Connection attribute) state (kombu.pidbox.Node attribute) (kombu.transport.memory.Transport attribute) (kombu.transport.virtual.Channel attribute) (kombu.transport.virtual.Transport attribute) still_active() (kombu.utils.finalize.Finalize method) store_processed (kombu.transport.filesystem.Channel attribute) (kombu.transport.filesystem.Transport.Channel attribute) str_to_bytes() (in module kombu.utils.encoding) subclient (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) supports_ev (kombu.transport.pyamqp.Transport attribute) (kombu.transport.redis.Transport attribute) supports_fanout (kombu.transport.mongodb.Channel attribute) (kombu.transport.SQS.Channel attribute) (kombu.transport.SQS.Transport.Channel attribute) (kombu.transport.mongodb.Transport.Channel attribute) (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) supports_heartbeats (kombu.Connection attribute) (kombu.connection.Connection attribute) (kombu.transport.pyamqp.Transport attribute) switch() (kombu.Connection method) (kombu.connection.Connection method)

T

table (kombu.transport.SQS.Channel attribute) (kombu.transport.SQS.Transport.Channel attribute) TimeoutError (in module kombu.exceptions) timestamp (kombu.utils.limits.TokenBucket attribute) TokenBucket (class in kombu.utils.limits) TopicExchange (class in kombu.transport.virtual.exchange) TRANSIENT_DELIVERY_MODE (kombu.Exchange attribute) Transport (class in kombu.transport.base) (class in kombu.transport.SQS) (class in kombu.transport.django) (class in kombu.transport.filesystem) (class in kombu.transport.memory) (class in kombu.transport.mongodb) (class in kombu.transport.pyamqp) (class in kombu.transport.redis) (class in kombu.transport.sqlalchemy) (class in kombu.transport.virtual) (class in kombu.transport.zookeeper) transport (kombu.Connection attribute) (kombu.connection.Connection attribute) Transport.Channel (class in kombu.transport.django) (class in kombu.transport.SQS) (class in kombu.transport.filesystem) (class in kombu.transport.memory) (class in kombu.transport.mongodb) (class in kombu.transport.redis) (class in kombu.transport.sqlalchemy) (class in kombu.transport.zookeeper) Transport.Channel.QoS (class in kombu.transport.redis) Transport.Channel.Table (class in kombu.transport.SQS)

Transport.Connection (class in kombu.transport.pyamqp) Transport.Connection.Channel (class in kombu.transport.pyamqp) Transport.Connection.Channel.Message (class in kombu.transport.pyamqp) TRANSPORT_ALIASES (in module kombu.transport) transport_options (kombu.connection.Connection attribute) (kombu.transport.SQS.Channel attribute) (kombu.transport.SQS.Transport.Channel attribute) (kombu.transport.filesystem.Channel attribute) (kombu.transport.filesystem.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.virtual.Channel method)

U

unacked_index_key (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Channel.QoS attribute) (kombu.transport.redis.Transport.Channel attribute) (kombu.transport.redis.Transport.Channel.QoS attribute) unacked_key (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Channel.QoS attribute) (kombu.transport.redis.Transport.Channel attribute) (kombu.transport.redis.Transport.Channel.QoS attribute) unacked_mutex_expire (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Channel.QoS attribute) (kombu.transport.redis.Transport.Channel attribute) (kombu.transport.redis.Transport.Channel.QoS attribute) unacked_mutex_key (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Channel.QoS attribute) (kombu.transport.redis.Transport.Channel attribute) (kombu.transport.redis.Transport.Channel.QoS attribute) unacked_restore_limit (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute)

unbind_from() (kombu.Exchange method) (kombu.Queue method) uri_prefix (kombu.Connection attribute) (kombu.connection.Connection attribute) URL userid (kombu.Connection attribute) (kombu.connection.Connection attribute) uuid() (in module kombu.common) (in module kombu.utils)

V

value (kombu.clocks.LamportClock attribute) version (kombu.transport.sqlalchemy.models.Message attribute) VHOST

virtual_host (kombu.Connection attribute) (kombu.connection.Connection attribute) visibility_timeout (kombu.transport.redis.Channel attribute) (kombu.transport.SQS.Channel attribute) (kombu.transport.SQS.Transport.Channel attribute) (kombu.transport.redis.Channel.QoS attribute) (kombu.transport.redis.Transport.Channel attribute) (kombu.transport.redis.Transport.Channel.QoS attribute) 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.SQS.Channel attribute) (kombu.transport.SQS.Transport attribute) (kombu.transport.SQS.Transport.Channel attribute) warn() (kombu.log.LogMixin method)

when_bound() (kombu.abstract.MaybeChannelBound method) (kombu.Queue method) wildcards (kombu.transport.virtual.exchange.TopicExchange attribute)