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.message.Message attribute) (kombu.transport.librabbitmq.Connection.Channel.Message attribute) (kombu.transport.librabbitmq.Connection.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.virtual.Message attribute) ack() (kombu.message.Message method) (kombu.transport.base.Message method) (kombu.transport.librabbitmq.Connection.Channel.Message method) (kombu.transport.librabbitmq.Connection.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.message.Message method) (kombu.transport.librabbitmq.Connection.Channel.Message method) (kombu.transport.librabbitmq.Connection.Message method) (kombu.transport.pyamqp.Connection.Channel.Message method) (kombu.transport.virtual.Message method) acknowledged (kombu.message.Message attribute) (kombu.transport.base.Message attribute) (kombu.transport.librabbitmq.Connection.Channel.Message attribute) (kombu.transport.librabbitmq.Connection.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.virtual.Message attribute) acquire() (kombu.async.semaphore.LaxBoundedSemaphore method) (kombu.connection.ChannelPool method) (kombu.connection.ConnectionPool method) active_queues (kombu.transport.redis.Channel attribute) (kombu.transport.redis.Transport.Channel attribute) add() (kombu.async.Hub method) (kombu.async.hub.Hub method) 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) add_reader() (kombu.async.Hub method) (kombu.async.hub.Hub method) add_writer() (kombu.async.Hub method) (kombu.async.hub.Hub method) adjust() (kombu.clocks.LamportClock method)

after_reply_message_received() (kombu.transport.librabbitmq.Connection.Channel method) (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) AMQP_PROTOCOL_HEADER (kombu.transport.amqplib.Connection 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) apply_entry() (kombu.async.timer.Timer method) args (kombu.async.timer.Entry attribute) (kombu.async.timer.Timer.Entry attribute) (kombu.compat.Consumer.ContentDisallowed attribute) (kombu.compat.ConsumerSet.ContentDisallowed attribute) (kombu.transport.librabbitmq.Connection.Channel.Message.MessageStateError attribute) (kombu.transport.librabbitmq.Connection.Message.MessageStateError attribute) (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) as_url() (in module kombu.utils.url) 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.librabbitmq.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.pyamqp.Connection.Channel method) (kombu.transport.virtual.Channel method) basic_cancel() (kombu.transport.amqplib.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.librabbitmq.Connection.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_consume() (kombu.transport.amqplib.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.django.Channel method) (kombu.transport.django.Transport.Channel method) (kombu.transport.librabbitmq.Connection.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.librabbitmq.Connection.Channel method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.virtual.Channel method) basic_publish() (kombu.transport.librabbitmq.Connection.Channel method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.virtual.Channel method) basic_publish_confirm() (kombu.transport.pyamqp.Connection.Channel method) basic_qos() (kombu.transport.librabbitmq.Connection.Channel method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.virtual.Channel method) basic_recover() (kombu.transport.librabbitmq.Connection.Channel method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.virtual.Channel method) basic_recover_async() (kombu.transport.pyamqp.Connection.Channel method)

basic_reject() (kombu.transport.librabbitmq.Connection.Channel method) (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() (kombu.Exchange method) binding_arguments (kombu.Queue attribute) bindings (kombu.transport.virtual.BrokerState attribute) body (kombu.message.Message attribute) (kombu.transport.base.Message attribute) (kombu.transport.librabbitmq.Connection.Channel.Message attribute) (kombu.transport.librabbitmq.Connection.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 (class in kombu.utils) call() (kombu.pidbox.Mailbox method) call_after() (kombu.async.timer.Timer method) call_at() (kombu.async.Hub method) (kombu.async.hub.Hub method) (kombu.async.timer.Timer method) call_later() (kombu.async.Hub method) (kombu.async.hub.Hub method) call_repeatedly() (kombu.async.Hub method) (kombu.async.hub.Hub method) (kombu.async.timer.Timer method) call_soon() (kombu.async.Hub method) (kombu.async.hub.Hub method) callback_for() (in module kombu.async.debug) callbacks (kombu.compat.Consumer attribute) (kombu.Consumer attribute) (kombu.compat.ConsumerSet attribute) (kombu.transport.librabbitmq.Connection 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) can_consume_max_estimate() (kombu.transport.virtual.QoS method) can_parse_url (kombu.transport.mongodb.Transport attribute) (kombu.transport.sqlalchemy.Transport attribute) cancel() (kombu.async.timer.Entry method) (kombu.Consumer method) (kombu.Queue method) (kombu.async.timer.Timer method) (kombu.async.timer.Timer.Entry method) (kombu.compat.Consumer method) (kombu.compat.ConsumerSet method) cancel_by_queue() (kombu.compat.Consumer method) (kombu.Consumer method) (kombu.compat.ConsumerSet method) cancelled (kombu.async.timer.Entry attribute) (kombu.async.timer.Timer.Entry attribute) capacity (kombu.utils.limits.TokenBucket attribute) cast() (kombu.pidbox.Mailbox method) Channel (class in kombu.transport.amqplib) (class in kombu.transport.SLMQ) (class in kombu.transport.SQS) (class in kombu.transport.beanstalk) (class in kombu.transport.couchdb) (class in kombu.transport.django) (class in kombu.transport.filesystem) (class in kombu.transport.librabbitmq) (class in kombu.transport.memory) (class in kombu.transport.mongodb) (class in kombu.transport.pyamqp) (class in kombu.transport.pyro) (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.message.Message 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.librabbitmq.Connection.Channel.Message attribute) (kombu.transport.librabbitmq.Connection.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.amqplib.Connection method) (kombu.transport.amqplib.Transport.Connection method) (kombu.transport.librabbitmq.Connection method) (kombu.transport.pyamqp.Connection method) Channel.Message (class in kombu.transport.amqplib) (class in kombu.transport.librabbitmq) (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.amqplib.Transport attribute) (kombu.transport.base.Transport attribute) (kombu.transport.beanstalk.Transport attribute) (kombu.transport.couchdb.Transport attribute) (kombu.transport.django.Transport attribute) (kombu.transport.librabbitmq.Transport attribute) (kombu.transport.mongodb.Transport attribute) (kombu.transport.pyamqp.Connection attribute) (kombu.transport.pyamqp.Transport attribute) (kombu.transport.zookeeper.Transport attribute) channel_max (kombu.transport.librabbitmq.Connection 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.async.semaphore.LaxBoundedSemaphore method) (kombu.async.timer.Timer method) (kombu.simple.SimpleBuffer method) (kombu.simple.SimpleQueue method) (kombu.transport.virtual.BrokerState method) client (kombu.transport.base.Transport attribute) (kombu.transport.beanstalk.Channel attribute) (kombu.transport.beanstalk.Transport.Channel attribute) (kombu.transport.couchdb.Channel attribute) (kombu.transport.couchdb.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.zookeeper.Channel attribute) (kombu.transport.zookeeper.Transport.Channel attribute) client_heartbeat (kombu.transport.pyamqp.Connection attribute) clock (kombu.clocks.timetuple attribute) clone() (kombu.Connection method) (kombu.connection.Connection method) close() (kombu.async.Hub method) (kombu.Connection method) (kombu.async.hub.Hub method) (kombu.compat.Consumer 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.amqplib.Channel method) (kombu.transport.beanstalk.Channel method) (kombu.transport.beanstalk.Transport.Channel method) (kombu.transport.librabbitmq.Connection method) (kombu.transport.librabbitmq.Connection.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.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.amqplib.Transport method) (kombu.transport.base.Transport method) (kombu.transport.librabbitmq.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) (kombu.transport.librabbitmq.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) (kombu.transport.amqplib.Connection attribute) (kombu.transport.amqplib.Transport.Connection attribute) (kombu.transport.librabbitmq.Connection attribute) (kombu.transport.pyamqp.Connection attribute) Connection (class in kombu) (class in kombu.connection) (class in kombu.transport.amqplib) (class in kombu.transport.librabbitmq) (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 (kombu.transport.amqplib.Connection attribute) Connection.Channel (class in kombu.transport.librabbitmq) (class in kombu.transport.pyamqp) Connection.Channel.Message (class in kombu.transport.librabbitmq) (class in kombu.transport.pyamqp) Connection.Channel.Message.MessageStateError, [1] Connection.Message (class in kombu.transport.librabbitmq) Connection.Message.MessageStateError Connection.SSLTransport (class in kombu.transport.amqplib) Connection.TCPTransport (class in kombu.transport.amqplib) connection_errors (kombu.Connection attribute) (kombu.connection.Connection attribute) (kombu.mixins.ConsumerMixin attribute) (kombu.transport.SLMQ.Transport attribute) (kombu.transport.SQS.Transport attribute) (kombu.transport.amqplib.Transport attribute) (kombu.transport.base.Transport attribute) (kombu.transport.beanstalk.Transport attribute) (kombu.transport.couchdb.Transport attribute) (kombu.transport.librabbitmq.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.SLMQ.Channel attribute) (kombu.transport.SLMQ.Transport.Channel attribute) (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.librabbitmq.Connection.Channel method) (kombu.transport.pyamqp.Connection.Channel method) Consumer.ContentDisallowed consumer_context() (kombu.mixins.ConsumerMixin method) ConsumerMixin (class in kombu.mixins) ConsumerSet (class in kombu.compat) ConsumerSet.ContentDisallowed consuming_from() (kombu.compat.Consumer method) (kombu.Consumer method) (kombu.compat.ConsumerSet method) content_encoding (kombu.message.Message attribute) (kombu.transport.base.Message attribute) (kombu.transport.librabbitmq.Connection.Channel.Message attribute) (kombu.transport.librabbitmq.Connection.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.virtual.Message attribute) content_type (kombu.message.Message attribute) (kombu.transport.base.Message attribute) (kombu.transport.librabbitmq.Connection.Channel.Message attribute) (kombu.transport.librabbitmq.Connection.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.virtual.Message attribute) create() (kombu.pools.PoolGroup method) create_binding() (kombu.transport.SQS.Channel.Table method) (kombu.transport.SQS.Transport.Channel.Table method) create_broadcast_cursor() (kombu.transport.mongodb.Channel method) (kombu.transport.mongodb.Transport.Channel method) create_channel() (kombu.transport.amqplib.Transport method) (kombu.transport.base.Transport method) (kombu.transport.librabbitmq.Transport method) (kombu.transport.pyamqp.Transport method) (kombu.transport.virtual.Transport method) create_connection() (kombu.mixins.ConsumerMixin method) create_loop() (kombu.async.Hub method) (kombu.async.hub.Hub method) create_message_view() (in module kombu.transport.couchdb) 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) Cycle (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.message.Message method) (kombu.transport.base.Message method) (kombu.transport.librabbitmq.Connection.Channel.Message method) (kombu.transport.librabbitmq.Connection.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.amqplib.Transport attribute) (kombu.transport.librabbitmq.Transport attribute) (kombu.transport.pyamqp.Transport attribute) default_encode() (in module kombu.utils.encoding) default_encoding() (in module kombu.utils.encoding) default_encoding_file (in module kombu.utils.encoding) default_port (kombu.transport.amqplib.Transport attribute) (kombu.transport.SLMQ.Transport attribute) (kombu.transport.SQS.Transport attribute) (kombu.transport.base.Transport attribute) (kombu.transport.beanstalk.Transport attribute) (kombu.transport.couchdb.Transport attribute) (kombu.transport.django.Transport attribute) (kombu.transport.filesystem.Transport attribute) (kombu.transport.librabbitmq.Transport attribute) (kombu.transport.mongodb.Transport attribute) (kombu.transport.pyamqp.Transport attribute) (kombu.transport.pyro.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.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.SQS.Channel attribute) (kombu.transport.SQS.Transport.Channel attribute) delete() (kombu.Exchange method) (kombu.Queue method) delete_message() (kombu.transport.SLMQ.Channel method) (kombu.transport.SLMQ.Transport.Channel method) deleter() (kombu.utils.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.message.Message attribute) (kombu.transport.base.Message attribute) (kombu.transport.librabbitmq.Connection.Channel.Message attribute) (kombu.transport.librabbitmq.Connection.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.virtual.Message attribute) delivery_mode (kombu.Exchange attribute), [1] delivery_tag (kombu.message.Message attribute) (kombu.transport.base.Message attribute) (kombu.transport.librabbitmq.Connection.Channel.Message attribute) (kombu.transport.librabbitmq.Connection.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.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.SQS.Channel method) (kombu.transport.SQS.Transport.Channel method) (kombu.transport.amqplib.Connection method) (kombu.transport.amqplib.Transport method) (kombu.transport.amqplib.Transport.Connection method) (kombu.transport.base.Transport method) (kombu.transport.librabbitmq.Connection method) (kombu.transport.librabbitmq.Transport method) (kombu.transport.pyamqp.Connection method) (kombu.transport.pyamqp.Transport method) (kombu.transport.virtual.Channel method) (kombu.transport.virtual.Transport method) driver_name (kombu.transport.amqplib.Transport attribute) (kombu.transport.SQS.Transport attribute) (kombu.transport.beanstalk.Transport attribute) (kombu.transport.couchdb.Transport attribute) (kombu.transport.django.Transport attribute) (kombu.transport.filesystem.Transport attribute) (kombu.transport.librabbitmq.Transport attribute) (kombu.transport.memory.Transport attribute) (kombu.transport.mongodb.Transport attribute) (kombu.transport.pyamqp.Transport attribute) (kombu.transport.pyro.Transport attribute) (kombu.transport.redis.Transport attribute) (kombu.transport.sqlalchemy.Transport attribute) (kombu.transport.zookeeper.Transport attribute) driver_type (kombu.transport.amqplib.Transport attribute) (kombu.transport.SQS.Transport attribute) (kombu.transport.beanstalk.Transport attribute) (kombu.transport.couchdb.Transport attribute) (kombu.transport.django.Transport attribute) (kombu.transport.filesystem.Transport attribute) (kombu.transport.librabbitmq.Transport attribute) (kombu.transport.memory.Transport attribute) (kombu.transport.mongodb.Transport attribute) (kombu.transport.pyamqp.Transport attribute) (kombu.transport.pyro.Transport attribute) (kombu.transport.redis.Transport attribute) (kombu.transport.sqlalchemy.Transport attribute) (kombu.transport.zookeeper.Transport attribute) driver_version() (kombu.transport.beanstalk.Transport method) (kombu.transport.couchdb.Transport method) (kombu.transport.django.Transport method) (kombu.transport.filesystem.Transport method) (kombu.transport.librabbitmq.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.async.semaphore) dumps() (in module kombu.serialization) 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) 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) enter_after() (kombu.async.timer.Timer method) enter_at() (kombu.async.timer.Timer method) entity_name() (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.async.timer) 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) ERR (kombu.async.Hub attribute) (kombu.async.hub.Hub attribute) error() (kombu.log.LogMixin method) errors (kombu.message.Message attribute) (kombu.transport.librabbitmq.Connection.Channel.Message attribute) (kombu.transport.librabbitmq.Connection.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.virtual.Message attribute) establish_connection() (kombu.mixins.ConsumerMixin method) (kombu.transport.amqplib.Transport method) (kombu.transport.base.Transport method) (kombu.transport.librabbitmq.Transport method) (kombu.transport.pyamqp.Transport method) (kombu.transport.virtual.Transport method)

evaluate() (kombu.utils.functional.lazy method) eventloop() (in module kombu.common) events (kombu.transport.amqplib.Channel attribute) 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.librabbitmq.Connection.Channel method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.virtual.Channel method) exchange_delete() (kombu.transport.librabbitmq.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.pyamqp.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] exec_() (in module kombu.five) 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) 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) (kombu.transport.django.managers.QueueManager method) fileno() (in module kombu.utils) (kombu.transport.librabbitmq.Connection method) fill_rate (kombu.utils.limits.TokenBucket attribute) fire_timers() (kombu.async.Hub method) (kombu.async.hub.Hub method) flow() (kombu.compat.Consumer method) (kombu.Consumer method) (kombu.compat.ConsumerSet method) (kombu.transport.librabbitmq.Connection.Channel 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) frame_max (kombu.transport.librabbitmq.Connection attribute) 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) fun (kombu.async.timer.Entry attribute) (kombu.async.timer.Timer.Entry attribute) 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.librabbitmq.Connection.Channel method) (kombu.transport.pyamqp.Connection.Channel method) get_broadcast() (kombu.transport.mongodb.Channel method) (kombu.transport.mongodb.Transport.Channel method) get_broadcast_cursor() (kombu.transport.mongodb.Channel method) (kombu.transport.mongodb.Transport.Channel method) get_consumers() (kombu.mixins.ConsumerMixin method) get_decoder() (in module kombu.compression) get_default_encoding_file() (in module kombu.utils.encoding) get_encoder() (in module kombu.compression) get_errno() (in module kombu.utils.compat) get_event_loop() (in module kombu.async) (in module kombu.async.hub) 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_heartbeat_interval() (kombu.connection.Connection method) (kombu.transport.pyamqp.Transport 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.amqplib.Transport method) (kombu.transport.librabbitmq.Transport method) (kombu.transport.pyamqp.Transport method) get_messages() (kombu.transport.mongodb.Channel method) (kombu.transport.mongodb.Transport.Channel 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_routing() (kombu.transport.mongodb.Channel method) (kombu.transport.mongodb.Transport.Channel 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) grow() (kombu.async.semaphore.LaxBoundedSemaphore method)

H

handle() (kombu.pidbox.Node method) handle_call() (kombu.pidbox.Node method) handle_cast() (kombu.pidbox.Node method) handle_error() (kombu.async.timer.Timer method) handle_message() (kombu.pidbox.Node method) handler() (kombu.pidbox.Node method) handlers (kombu.pidbox.Node attribute)

headers (kombu.message.Message attribute) (kombu.transport.base.Message attribute) (kombu.transport.librabbitmq.Connection.Channel.Message attribute) (kombu.transport.librabbitmq.Connection.Message attribute) (kombu.transport.pyamqp.Connection.Channel.Message attribute) (kombu.transport.virtual.Message attribute) heartbeat (kombu.Connection attribute) (kombu.connection.Connection attribute) (kombu.transport.librabbitmq.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 attribute) hostname (kombu.Connection attribute) (kombu.connection.Connection attribute) (kombu.pidbox.Node attribute) (kombu.transport.librabbitmq.Connection attribute) Hub (class in kombu.async) (class in kombu.async.hub)

I

id (kombu.clocks.timetuple attribute) (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) is_alive() (kombu.transport.amqplib.Transport method) (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)

is_list() (in module kombu.utils.functional) is_open (kombu.transport.librabbitmq.Connection.Channel attribute) items() (in module kombu.five) 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_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() (in module kombu.five) kombu (module) kombu.abstract (module) kombu.async (module) kombu.async.debug (module) kombu.async.hub (module) kombu.async.semaphore (module) kombu.async.timer (module) kombu.clocks (module) kombu.common (module) kombu.compat (module) kombu.compression (module) kombu.connection (module) kombu.exceptions (module) kombu.five (module) kombu.log (module) kombu.message (module) kombu.mixins (module) kombu.pidbox (module) kombu.pools (module) kombu.serialization (module) kombu.simple (module) kombu.syn (module) kombu.transport (module) kombu.transport.amqplib (module) kombu.transport.base (module) kombu.transport.beanstalk (module) kombu.transport.couchdb (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.librabbitmq (module) kombu.transport.memory (module) kombu.transport.mongodb (module) kombu.transport.pyamqp (module) kombu.transport.pyro (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.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.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] kwargs (kombu.async.timer.Entry attribute) (kombu.async.timer.Timer.Entry attribute) kwdict() (in module kombu.utils)

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.async.semaphore) lazy (class in kombu.utils.functional) 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) loop (kombu.async.Hub attribute) (kombu.async.hub.Hub attribute)

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_evaluate() (in module kombu.utils.functional) maybe_fileno() (in module kombu.utils) maybe_list() (in module kombu.utils) (in module kombu.utils.functional) maybe_sanitize_url() (in module kombu.utils.url) maybe_switch_next() (kombu.Connection method) (kombu.connection.Connection method) MaybeChannelBound (class in kombu.abstract) Message (class in kombu.message) (class in kombu.transport.amqplib) (class in kombu.transport.base) (class in kombu.transport.django.models) (class in kombu.transport.librabbitmq) (class in kombu.transport.pyamqp) (class in kombu.transport.sqlalchemy.models) (class in kombu.transport.virtual)

message (kombu.compat.Consumer.ContentDisallowed attribute) (kombu.compat.ConsumerSet.ContentDisallowed attribute) (kombu.transport.librabbitmq.Connection.Channel.Message.MessageStateError attribute) (kombu.transport.librabbitmq.Connection.Message.MessageStateError attribute) (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, [1] Message.MultipleObjectsReturned message_cls (kombu.transport.sqlalchemy.Channel attribute) (kombu.transport.sqlalchemy.Transport.Channel attribute) message_to_python() (kombu.transport.amqplib.Channel method) (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) MessageStateError monotonic() (in module kombu.five) 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) nested() (in module kombu.utils) new() (kombu.pools.ProducerPool method) nextfun() (in module kombu.five)

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.librabbitmq.Connection.Channel attribute) (kombu.transport.pyamqp.Connection.Channel attribute) Node (class in kombu.pidbox) Node() (kombu.pidbox.Mailbox method) NotBoundError

O

obj (kombu.clocks.timetuple attribute) objects (kombu.transport.django.models.Message attribute) (kombu.transport.django.models.Queue attribute) on_close (kombu.async.Hub attribute) (kombu.async.hub.Hub 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_error (kombu.async.timer.Timer attribute) on_iteration() (kombu.mixins.ConsumerMixin method) on_message (kombu.compat.Consumer attribute) (kombu.Consumer attribute) (kombu.compat.ConsumerSet attribute) on_readable() (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) (kombu.transport.librabbitmq.Connection attribute) payload (kombu.message.Message attribute) (kombu.transport.base.Message attribute) (kombu.transport.librabbitmq.Connection.Channel.Message attribute) (kombu.transport.librabbitmq.Connection.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.beanstalk.Transport attribute) (kombu.transport.SLMQ.Transport attribute) (kombu.transport.SQS.Transport attribute) (kombu.transport.couchdb.Transport attribute) (kombu.transport.django.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) (kombu.transport.librabbitmq.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.amqplib.Channel method) (kombu.transport.librabbitmq.Channel method) (kombu.transport.librabbitmq.Connection.Channel method) (kombu.transport.librabbitmq.Transport.Connection.Channel method) (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.librabbitmq.Connection.Channel method) (kombu.transport.pyamqp.Connection.Channel method) ProducerPool (class in kombu.pools) ProducerPool.Producer (class in kombu.pools) properties (kombu.message.Message attribute) (kombu.transport.base.Message attribute) (kombu.transport.librabbitmq.Connection.Channel.Message attribute) (kombu.transport.librabbitmq.Connection.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) qos_semantics_matches_spec (kombu.connection.Connection attribute) qos_semantics_matches_spec() (kombu.transport.librabbitmq.Transport method) (kombu.transport.pyamqp.Transport 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.async.timer.Timer attribute) (kombu.compat.Consumer attribute) (kombu.simple.SimpleBuffer attribute) (kombu.simple.SimpleQueue attribute) (kombu.transport.django.models.Message attribute) Queue.ContentDisallowed Queue.DoesNotExist Queue.MultipleObjectsReturned queue_arguments (kombu.Queue attribute)

queue_bind() (kombu.Queue 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.librabbitmq.Connection.Channel method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.virtual.Channel method) queue_cls (kombu.transport.sqlalchemy.Channel attribute) (kombu.transport.sqlalchemy.Transport.Channel attribute) queue_declare() (kombu.Queue method) (kombu.transport.librabbitmq.Connection.Channel method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.virtual.Channel method) queue_delete() (kombu.transport.librabbitmq.Connection.Channel method) (kombu.transport.SQS.Channel.Table method) (kombu.transport.SQS.Transport.Channel.Table method) (kombu.transport.mongodb.Channel method) (kombu.transport.mongodb.Transport.Channel method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.virtual.Channel method) queue_name_prefix (kombu.transport.SLMQ.Channel attribute) (kombu.transport.SLMQ.Transport.Channel attribute) (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.librabbitmq.Connection.Channel method) (kombu.transport.pyamqp.Connection.Channel method) (kombu.transport.virtual.Channel method) queue_unbind() (kombu.Queue method) (kombu.transport.librabbitmq.Connection.Channel 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) queues() (kombu.transport.pyro.Channel method) (kombu.transport.pyro.Transport.Channel method)

R

raw_encode() (in module kombu.serialization) READ (kombu.async.Hub attribute) (kombu.async.hub.Hub attribute) read_frame() (kombu.transport.amqplib.Connection.SSLTransport method) (kombu.transport.amqplib.Connection.TCPTransport method) read_timeout() (kombu.transport.amqplib.Connection method) (kombu.transport.amqplib.Transport.Connection method) (kombu.transport.pyamqp.Connection method) receive() (kombu.compat.Consumer method) (kombu.Consumer method) (kombu.compat.ConsumerSet method) reconnect() (kombu.transport.librabbitmq.Connection method) recover() (kombu.compat.Consumer method) (kombu.Consumer method) (kombu.compat.ConsumerSet method) recoverable_channel_errors (kombu.Connection attribute) (kombu.connection.Connection attribute) (kombu.transport.base.Transport attribute) (kombu.transport.pyamqp.Connection attribute) (kombu.transport.pyamqp.Transport attribute) recoverable_connection_errors (kombu.Connection attribute) (kombu.connection.Connection attribute) (kombu.transport.base.Transport attribute) (kombu.transport.pyamqp.Connection attribute) (kombu.transport.pyamqp.Transport 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) register_with_event_loop() (kombu.Connection method) (kombu.connection.Connection method) (kombu.transport.amqplib.Transport method) (kombu.transport.librabbitmq.Transport method) (kombu.transport.pyamqp.Transport method) (kombu.transport.redis.Transport method) registry (in module kombu.serialization) reject() (kombu.message.Message method) (kombu.transport.base.Message method) (kombu.transport.librabbitmq.Connection.Channel.Message method) (kombu.transport.librabbitmq.Connection.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.message.Message method) (kombu.transport.librabbitmq.Connection.Channel.Message method) (kombu.transport.librabbitmq.Connection.Message method) (kombu.transport.pyamqp.Connection.Channel.Message method) (kombu.transport.virtual.Message method) release() (kombu.async.semaphore.LaxBoundedSemaphore method) (kombu.Connection method) (kombu.compat.Publisher method) (kombu.connection.ChannelPool method) (kombu.connection.Connection method) (kombu.connection.ConnectionPool method) (kombu.pools.ProducerPool method) (kombu.pools.ProducerPool.Producer method) remove() (kombu.async.Hub method) (kombu.async.hub.Hub method) remove_reader() (kombu.async.Hub method) (kombu.async.hub.Hub method) remove_writer() (kombu.async.Hub method) (kombu.async.hub.Hub method) reply() (kombu.pidbox.Node method) reply_exchange (kombu.pidbox.Mailbox attribute)

repr_active() (in module kombu.async.debug) (kombu.async.Hub method) (kombu.async.hub.Hub method) repr_events() (in module kombu.async.debug) (kombu.async.Hub method) (kombu.async.hub.Hub method) repr_flag() (in module kombu.async.debug) repr_readers() (in module kombu.async.debug) repr_writers() (in module kombu.async.debug) reprcall() (in module kombu.utils) reprkwargs() (in module kombu.utils) requeue() (kombu.message.Message method) (kombu.transport.base.Message method) (kombu.transport.librabbitmq.Connection.Channel.Message method) (kombu.transport.librabbitmq.Connection.Message method) (kombu.transport.pyamqp.Connection.Channel.Message method) (kombu.transport.virtual.Message method) reraise() (in module kombu.five) reset() (in module kombu.pools) (kombu.async.Hub method) (kombu.async.hub.Hub method) 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) run_forever() (kombu.async.Hub method) (kombu.async.hub.Hub method) run_once() (kombu.async.Hub method) (kombu.async.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) say() (in module kombu.utils) schedule (kombu.async.timer.Timer attribute) scheduler (kombu.async.Hub attribute) (kombu.async.hub.Hub attribute) 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) server_heartbeat (kombu.transport.pyamqp.Connection attribute) session (kombu.transport.sqlalchemy.Channel attribute) (kombu.transport.sqlalchemy.Transport.Channel attribute) set_default_encoding_file() (in module kombu.utils.encoding) set_event_loop() (in module kombu.async) (in module kombu.async.hub) set_limit() (in module kombu.pools) setter() (kombu.utils.cached_property method) setup() (kombu.pools.ProducerPool method)

setup_logging() (in module kombu.log) (in module kombu.utils.debug) shared_queues (kombu.transport.pyro.Channel attribute) (kombu.transport.pyro.Transport attribute) (kombu.transport.pyro.Transport.Channel attribute) should_stop (kombu.mixins.ConsumerMixin attribute) shrink() (kombu.async.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) size() (kombu.transport.django.managers.QueueManager method) slmq (kombu.transport.SLMQ.Channel attribute) (kombu.transport.SLMQ.Transport.Channel attribute) 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.pyro.Transport attribute) (kombu.transport.virtual.Channel attribute) (kombu.transport.virtual.Transport attribute) stop() (kombu.async.Hub method) (kombu.async.hub.Hub method) (kombu.async.timer.Timer 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.amqplib.Transport attribute) (kombu.transport.librabbitmq.Transport attribute) (kombu.transport.pyamqp.Transport attribute) (kombu.transport.redis.Transport attribute) supports_fanout (kombu.transport.memory.Channel attribute) (kombu.transport.SQS.Channel attribute) (kombu.transport.SQS.Transport.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) 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) timedelta_seconds() (in module kombu.utils.compat) TimeoutError (in module kombu.exceptions) Timer (class in kombu.async.timer) Timer.Entry (class in kombu.async.timer) timespec (class in kombu.five) timestamp (kombu.clocks.timetuple attribute) (kombu.utils.limits.TokenBucket attribute) timetuple (class in kombu.clocks) to_timestamp() (in module kombu.async.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.amqplib) (class in kombu.transport.SLMQ) (class in kombu.transport.SQS) (class in kombu.transport.base) (class in kombu.transport.beanstalk) (class in kombu.transport.couchdb) (class in kombu.transport.django) (class in kombu.transport.filesystem) (class in kombu.transport.librabbitmq) (class in kombu.transport.memory) (class in kombu.transport.mongodb) (class in kombu.transport.pyamqp) (class in kombu.transport.pyro) (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.beanstalk) (class in kombu.transport.SLMQ) (class in kombu.transport.SQS) (class in kombu.transport.couchdb) (class in kombu.transport.django) (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.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.amqplib) (class in kombu.transport.librabbitmq) (class in kombu.transport.pyamqp) Transport.Connection.Channel (class in kombu.transport.librabbitmq) (class in kombu.transport.pyamqp) Transport.Connection.Channel.Message (class in kombu.transport.librabbitmq) (class in kombu.transport.pyamqp) Transport.Connection.Message (class in kombu.transport.librabbitmq) TRANSPORT_ALIASES (in module kombu.transport) transport_options (kombu.connection.Connection attribute) (kombu.transport.SLMQ.Channel attribute) (kombu.transport.SLMQ.Transport.Channel attribute) (kombu.transport.SQS.Channel attribute) (kombu.transport.SQS.Transport.Channel attribute) (kombu.transport.filesystem.Channel attribute) (kombu.transport.filesystem.Transport.Channel attribute) tref (kombu.async.timer.Entry attribute) (kombu.async.timer.Timer.Entry attribute) tv_nsec (kombu.five.timespec attribute) tv_sec (kombu.five.timespec 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) (kombu.transport.librabbitmq.Connection attribute) uuid() (in module kombu.common) (in module kombu.utils)

V

value (kombu.clocks.LamportClock attribute) values() (in module kombu.five) verify_connection() (kombu.transport.amqplib.Transport method) (kombu.transport.librabbitmq.Transport method) (kombu.transport.pyamqp.Transport method) version (kombu.transport.sqlalchemy.models.Message attribute) version_string_as_tuple() (in module kombu.utils.text)

VHOST view_created (kombu.transport.couchdb.Channel attribute) (kombu.transport.couchdb.Transport.Channel attribute) virtual_host (kombu.Connection attribute) (kombu.connection.Connection attribute) (kombu.transport.librabbitmq.Connection attribute) visibility_timeout (kombu.transport.redis.Channel attribute) (kombu.transport.SLMQ.Channel attribute) (kombu.transport.SLMQ.Transport.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) with_metaclass() (in module kombu.five) WRITE (kombu.async.Hub attribute) (kombu.async.hub.Hub attribute)