Search.setIndex({docnames:["changelog","faq","index","introduction","reference/index","reference/kombu","reference/kombu.abstract","reference/kombu.asynchronous","reference/kombu.asynchronous.aws","reference/kombu.asynchronous.aws.connection","reference/kombu.asynchronous.aws.sqs","reference/kombu.asynchronous.aws.sqs.connection","reference/kombu.asynchronous.aws.sqs.message","reference/kombu.asynchronous.aws.sqs.queue","reference/kombu.asynchronous.debug","reference/kombu.asynchronous.http","reference/kombu.asynchronous.http.base","reference/kombu.asynchronous.http.curl","reference/kombu.asynchronous.hub","reference/kombu.asynchronous.semaphore","reference/kombu.asynchronous.timer","reference/kombu.clocks","reference/kombu.common","reference/kombu.compat","reference/kombu.compression","reference/kombu.connection","reference/kombu.exceptions","reference/kombu.log","reference/kombu.matcher","reference/kombu.message","reference/kombu.mixins","reference/kombu.pidbox","reference/kombu.pools","reference/kombu.resource","reference/kombu.serialization","reference/kombu.simple","reference/kombu.transport","reference/kombu.transport.SLMQ","reference/kombu.transport.SQS","reference/kombu.transport.azureservicebus","reference/kombu.transport.azurestoragequeues","reference/kombu.transport.base","reference/kombu.transport.consul","reference/kombu.transport.etcd","reference/kombu.transport.filesystem","reference/kombu.transport.librabbitmq","reference/kombu.transport.memory","reference/kombu.transport.mongodb","reference/kombu.transport.pyamqp","reference/kombu.transport.pyro","reference/kombu.transport.qpid","reference/kombu.transport.redis","reference/kombu.transport.sqlalchemy","reference/kombu.transport.virtual","reference/kombu.transport.virtual.exchange","reference/kombu.transport.zookeeper","reference/kombu.utils.amq_manager","reference/kombu.utils.collections","reference/kombu.utils.compat","reference/kombu.utils.debug","reference/kombu.utils.div","reference/kombu.utils.encoding","reference/kombu.utils.eventio","reference/kombu.utils.functional","reference/kombu.utils.imports","reference/kombu.utils.json","reference/kombu.utils.limits","reference/kombu.utils.objects","reference/kombu.utils.scheduling","reference/kombu.utils.text","reference/kombu.utils.time","reference/kombu.utils.url","reference/kombu.utils.uuid","userguide/connections","userguide/consumers","userguide/examples","userguide/failover","userguide/index","userguide/introduction","userguide/pools","userguide/producers","userguide/serialization","userguide/simple"],envversion:{"sphinx.domains.c":2,"sphinx.domains.changeset":1,"sphinx.domains.citation":1,"sphinx.domains.cpp":4,"sphinx.domains.index":1,"sphinx.domains.javascript":2,"sphinx.domains.math":2,"sphinx.domains.python":3,"sphinx.domains.rst":2,"sphinx.domains.std":2,"sphinx.ext.intersphinx":1,"sphinx.ext.todo":2,"sphinx.ext.viewcode":1,sphinx:56},filenames:["changelog.rst","faq.rst","index.rst","introduction.rst","reference/index.rst","reference/kombu.rst","reference/kombu.abstract.rst","reference/kombu.asynchronous.rst","reference/kombu.asynchronous.aws.rst","reference/kombu.asynchronous.aws.connection.rst","reference/kombu.asynchronous.aws.sqs.rst","reference/kombu.asynchronous.aws.sqs.connection.rst","reference/kombu.asynchronous.aws.sqs.message.rst","reference/kombu.asynchronous.aws.sqs.queue.rst","reference/kombu.asynchronous.debug.rst","reference/kombu.asynchronous.http.rst","reference/kombu.asynchronous.http.base.rst","reference/kombu.asynchronous.http.curl.rst","reference/kombu.asynchronous.hub.rst","reference/kombu.asynchronous.semaphore.rst","reference/kombu.asynchronous.timer.rst","reference/kombu.clocks.rst","reference/kombu.common.rst","reference/kombu.compat.rst","reference/kombu.compression.rst","reference/kombu.connection.rst","reference/kombu.exceptions.rst","reference/kombu.log.rst","reference/kombu.matcher.rst","reference/kombu.message.rst","reference/kombu.mixins.rst","reference/kombu.pidbox.rst","reference/kombu.pools.rst","reference/kombu.resource.rst","reference/kombu.serialization.rst","reference/kombu.simple.rst","reference/kombu.transport.rst","reference/kombu.transport.SLMQ.rst","reference/kombu.transport.SQS.rst","reference/kombu.transport.azureservicebus.rst","reference/kombu.transport.azurestoragequeues.rst","reference/kombu.transport.base.rst","reference/kombu.transport.consul.rst","reference/kombu.transport.etcd.rst","reference/kombu.transport.filesystem.rst","reference/kombu.transport.librabbitmq.rst","reference/kombu.transport.memory.rst","reference/kombu.transport.mongodb.rst","reference/kombu.transport.pyamqp.rst","reference/kombu.transport.pyro.rst","reference/kombu.transport.qpid.rst","reference/kombu.transport.redis.rst","reference/kombu.transport.sqlalchemy.rst","reference/kombu.transport.virtual.rst","reference/kombu.transport.virtual.exchange.rst","reference/kombu.transport.zookeeper.rst","reference/kombu.utils.amq_manager.rst","reference/kombu.utils.collections.rst","reference/kombu.utils.compat.rst","reference/kombu.utils.debug.rst","reference/kombu.utils.div.rst","reference/kombu.utils.encoding.rst","reference/kombu.utils.eventio.rst","reference/kombu.utils.functional.rst","reference/kombu.utils.imports.rst","reference/kombu.utils.json.rst","reference/kombu.utils.limits.rst","reference/kombu.utils.objects.rst","reference/kombu.utils.scheduling.rst","reference/kombu.utils.text.rst","reference/kombu.utils.time.rst","reference/kombu.utils.url.rst","reference/kombu.utils.uuid.rst","userguide/connections.rst","userguide/consumers.rst","userguide/examples.rst","userguide/failover.rst","userguide/index.rst","userguide/introduction.rst","userguide/pools.rst","userguide/producers.rst","userguide/serialization.rst","userguide/simple.rst"],objects:{"":[[5,0,0,"-","kombu"]],"kombu.Connection":[[5,2,1,"","ChannelPool"],[5,2,1,"","Consumer"],[5,2,1,"","Pool"],[5,2,1,"","Producer"],[5,2,1,"","SimpleBuffer"],[5,2,1,"","SimpleQueue"],[5,2,1,"","_close"],[5,2,1,"","as_uri"],[5,2,1,"","autoretry"],[5,2,1,"","channel"],[5,3,1,"","channel_errors"],[5,2,1,"","clone"],[5,2,1,"","close"],[5,2,1,"","completes_cycle"],[5,2,1,"","connect"],[5,3,1,"","connect_timeout"],[5,3,1,"","connected"],[5,3,1,"","connection"],[5,3,1,"","connection_errors"],[5,2,1,"","create_transport"],[5,3,1,"","cycle"],[5,3,1,"","declared_entities"],[5,3,1,"","default_channel"],[5,2,1,"","drain_events"],[5,2,1,"","ensure"],[5,2,1,"","ensure_connection"],[5,3,1,"","failover_strategy"],[5,2,1,"","get_manager"],[5,2,1,"","get_transport_cls"],[5,3,1,"","heartbeat"],[5,2,1,"","heartbeat_check"],[5,3,1,"","host"],[5,3,1,"","hostname"],[5,2,1,"","info"],[5,3,1,"","is_evented"],[5,3,1,"","login_method"],[5,3,1,"","manager"],[5,2,1,"","maybe_close_channel"],[5,2,1,"","maybe_switch_next"],[5,3,1,"","password"],[5,3,1,"","port"],[5,3,1,"","recoverable_channel_errors"],[5,3,1,"","recoverable_connection_errors"],[5,2,1,"","register_with_event_loop"],[5,2,1,"","release"],[5,2,1,"","revive"],[5,3,1,"","ssl"],[5,3,1,"","supports_heartbeats"],[5,2,1,"","switch"],[5,3,1,"","transport"],[5,3,1,"","uri_prefix"],[5,3,1,"","userid"],[5,3,1,"","virtual_host"]],"kombu.Consumer":[[5,2,1,"","add_queue"],[5,3,1,"","auto_declare"],[5,3,1,"","callbacks"],[5,2,1,"","cancel"],[5,2,1,"","cancel_by_queue"],[5,3,1,"","channel"],[5,3,1,"","connection"],[5,2,1,"","consume"],[5,2,1,"","consuming_from"],[5,2,1,"","declare"],[5,2,1,"","flow"],[5,3,1,"","no_ack"],[5,3,1,"","on_decode_error"],[5,3,1,"","on_message"],[5,2,1,"","purge"],[5,2,1,"","qos"],[5,3,1,"","queues"],[5,2,1,"","receive"],[5,2,1,"","recover"],[5,2,1,"","register_callback"],[5,2,1,"","revive"]],"kombu.Exchange":[[5,2,1,"","Message"],[5,3,1,"","PERSISTENT_DELIVERY_MODE"],[5,3,1,"","TRANSIENT_DELIVERY_MODE"],[5,3,1,"","arguments"],[5,3,1,"","attrs"],[5,3,1,"id0","auto_delete"],[5,2,1,"","bind_to"],[5,2,1,"","binding"],[5,4,1,"","can_cache_declaration"],[5,3,1,"","channel"],[5,2,1,"","declare"],[5,2,1,"","delete"],[5,3,1,"id1","delivery_mode"],[5,3,1,"id2","durable"],[5,2,1,"","maybe_bind"],[5,3,1,"id3","name"],[5,3,1,"id4","no_declare"],[5,3,1,"","passive"],[5,2,1,"","publish"],[5,3,1,"id5","type"],[5,2,1,"","unbind_from"]],"kombu.Producer":[[5,3,1,"","auto_declare"],[5,3,1,"","channel"],[5,3,1,"","compression"],[5,3,1,"","connection"],[5,2,1,"","declare"],[5,3,1,"","exchange"],[5,2,1,"","maybe_declare"],[5,3,1,"","on_return"],[5,2,1,"","publish"],[5,2,1,"","revive"],[5,3,1,"","routing_key"],[5,3,1,"","serializer"]],"kombu.Queue":[[5,5,1,"","ContentDisallowed"],[5,3,1,"","alias"],[5,2,1,"","as_dict"],[5,3,1,"","attrs"],[5,3,1,"id6","auto_delete"],[5,2,1,"","bind"],[5,2,1,"","bind_to"],[5,3,1,"","binding_arguments"],[5,4,1,"","can_cache_declaration"],[5,2,1,"","cancel"],[5,3,1,"","channel"],[5,2,1,"","consume"],[5,3,1,"","consumer_arguments"],[5,2,1,"","declare"],[5,2,1,"","delete"],[5,3,1,"id7","durable"],[5,3,1,"id8","exchange"],[5,3,1,"id9","exclusive"],[5,3,1,"","expires"],[5,2,1,"","from_dict"],[5,2,1,"","get"],[5,3,1,"","max_length"],[5,3,1,"","max_length_bytes"],[5,3,1,"","max_priority"],[5,2,1,"","maybe_bind"],[5,3,1,"","message_ttl"],[5,3,1,"id10","name"],[5,3,1,"","no_ack"],[5,3,1,"","no_declare"],[5,3,1,"","on_declared"],[5,2,1,"","purge"],[5,3,1,"","queue_arguments"],[5,2,1,"","queue_bind"],[5,2,1,"","queue_declare"],[5,2,1,"","queue_unbind"],[5,3,1,"id11","routing_key"],[5,2,1,"","unbind_from"],[5,2,1,"","when_bound"]],"kombu.abstract":[[6,1,1,"","MaybeChannelBound"]],"kombu.abstract.MaybeChannelBound":[[6,2,1,"","bind"],[6,3,1,"","can_cache_declaration"],[6,4,1,"","channel"],[6,4,1,"","is_bound"],[6,2,1,"","maybe_bind"],[6,2,1,"","revive"],[6,2,1,"","when_bound"]],"kombu.asynchronous":[[7,1,1,"","Hub"],[8,0,0,"-","aws"],[14,0,0,"-","debug"],[7,6,1,"","get_event_loop"],[15,0,0,"-","http"],[18,0,0,"-","hub"],[19,0,0,"-","semaphore"],[7,6,1,"","set_event_loop"],[20,0,0,"-","timer"]],"kombu.asynchronous.Hub":[[7,3,1,"","ERR"],[7,3,1,"","READ"],[7,3,1,"","WRITE"],[7,2,1,"","add"],[7,2,1,"","add_reader"],[7,2,1,"","add_writer"],[7,2,1,"","call_at"],[7,2,1,"","call_later"],[7,2,1,"","call_repeatedly"],[7,2,1,"","call_soon"],[7,2,1,"","close"],[7,2,1,"","create_loop"],[7,2,1,"","fire_timers"],[7,4,1,"","loop"],[7,2,1,"","on_callback_error"],[7,3,1,"","on_close"],[7,4,1,"","poller"],[7,2,1,"","remove"],[7,2,1,"","remove_reader"],[7,2,1,"","remove_writer"],[7,2,1,"","repr_active"],[7,2,1,"","repr_events"],[7,2,1,"","reset"],[7,2,1,"","run_forever"],[7,2,1,"","run_once"],[7,4,1,"","scheduler"],[7,2,1,"","stop"]],"kombu.asynchronous.aws":[[8,6,1,"","connect_sqs"],[9,0,0,"-","connection"],[10,0,0,"-","sqs"]],"kombu.asynchronous.aws.connection":[[9,1,1,"","AsyncConnection"],[9,1,1,"","AsyncHTTPSConnection"]],"kombu.asynchronous.aws.connection.AsyncConnection":[[9,2,1,"","get_http_connection"]],"kombu.asynchronous.aws.connection.AsyncHTTPSConnection":[[9,1,1,"","Request"],[9,3,1,"","Response"],[9,3,1,"","body"],[9,2,1,"","close"],[9,2,1,"","connect"],[9,3,1,"","default_ports"],[9,2,1,"","endheaders"],[9,2,1,"","getrequest"],[9,2,1,"","getresponse"],[9,3,1,"","method"],[9,3,1,"","path"],[9,2,1,"","putheader"],[9,2,1,"","putrequest"],[9,2,1,"","request"],[9,2,1,"","send"],[9,2,1,"","set_debuglevel"]],"kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request":[[9,3,1,"","auth_mode"],[9,3,1,"","auth_password"],[9,3,1,"","auth_username"],[9,3,1,"","body"],[9,3,1,"","ca_certs"],[9,3,1,"","client_cert"],[9,3,1,"","client_key"],[9,3,1,"","connect_timeout"],[9,3,1,"","follow_redirects"],[9,3,1,"","headers"],[9,3,1,"","max_redirects"],[9,3,1,"","method"],[9,3,1,"","network_interface"],[9,3,1,"","on_header"],[9,3,1,"","on_prepare"],[9,3,1,"","on_ready"],[9,3,1,"","on_stream"],[9,3,1,"","on_timeout"],[9,3,1,"","proxy_host"],[9,3,1,"","proxy_password"],[9,3,1,"","proxy_port"],[9,3,1,"","proxy_username"],[9,3,1,"","request_timeout"],[9,2,1,"","then"],[9,3,1,"","url"],[9,3,1,"","use_gzip"],[9,3,1,"","user_agent"],[9,3,1,"","validate_cert"]],"kombu.asynchronous.aws.sqs":[[11,0,0,"-","connection"],[12,0,0,"-","message"],[13,0,0,"-","queue"]],"kombu.asynchronous.aws.sqs.connection":[[11,1,1,"","AsyncSQSConnection"]],"kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection":[[11,2,1,"","add_permission"],[11,2,1,"","change_message_visibility"],[11,2,1,"","change_message_visibility_batch"],[11,2,1,"","create_queue"],[11,2,1,"","delete_message"],[11,2,1,"","delete_message_batch"],[11,2,1,"","delete_message_from_handle"],[11,2,1,"","delete_queue"],[11,2,1,"","get_all_queues"],[11,2,1,"","get_dead_letter_source_queues"],[11,2,1,"","get_queue"],[11,2,1,"","get_queue_attributes"],[11,2,1,"","get_queue_url"],[11,2,1,"","lookup"],[11,2,1,"","receive_message"],[11,2,1,"","remove_permission"],[11,2,1,"","send_message"],[11,2,1,"","send_message_batch"],[11,2,1,"","set_queue_attribute"]],"kombu.asynchronous.aws.sqs.message":[[12,1,1,"","AsyncMessage"],[12,1,1,"","AsyncRawMessage"],[12,1,1,"","BaseAsyncMessage"]],"kombu.asynchronous.aws.sqs.message.AsyncMessage":[[12,3,1,"","accept"],[12,3,1,"","body"],[12,3,1,"","channel"],[12,3,1,"","content_encoding"],[12,3,1,"","content_type"],[12,3,1,"","delivery_info"],[12,3,1,"","delivery_tag"],[12,2,1,"","encode"],[12,3,1,"","headers"],[12,3,1,"","properties"]],"kombu.asynchronous.aws.sqs.message.AsyncRawMessage":[[12,3,1,"","accept"],[12,3,1,"","body"],[12,3,1,"","channel"],[12,3,1,"","content_encoding"],[12,3,1,"","content_type"],[12,3,1,"","delivery_info"],[12,3,1,"","delivery_tag"],[12,3,1,"","headers"],[12,3,1,"","properties"]],"kombu.asynchronous.aws.sqs.message.BaseAsyncMessage":[[12,3,1,"","accept"],[12,3,1,"","body"],[12,3,1,"","channel"],[12,3,1,"","content_encoding"],[12,3,1,"","content_type"],[12,3,1,"","delivery_info"],[12,3,1,"","delivery_tag"],[12,3,1,"","headers"],[12,3,1,"","properties"]],"kombu.asynchronous.aws.sqs.queue":[[13,1,1,"","AsyncQueue"],[13,6,1,"","list_first"]],"kombu.asynchronous.aws.sqs.queue.AsyncQueue":[[13,2,1,"","add_permission"],[13,2,1,"","change_message_visibility_batch"],[13,2,1,"","clear"],[13,2,1,"","count"],[13,2,1,"","count_slow"],[13,2,1,"","delete"],[13,2,1,"","delete_message"],[13,2,1,"","delete_message_batch"],[13,2,1,"","dump"],[13,2,1,"","get_attributes"],[13,2,1,"","get_messages"],[13,2,1,"","get_timeout"],[13,2,1,"","load"],[13,2,1,"","load_from_file"],[13,2,1,"","load_from_filename"],[13,2,1,"","load_from_s3"],[13,2,1,"","read"],[13,2,1,"","remove_permission"],[13,2,1,"","save"],[13,2,1,"","save_to_file"],[13,2,1,"","save_to_filename"],[13,2,1,"","save_to_s3"],[13,2,1,"","set_attribute"],[13,2,1,"","set_timeout"],[13,2,1,"","write"],[13,2,1,"","write_batch"]],"kombu.asynchronous.debug":[[14,6,1,"","callback_for"],[14,6,1,"","repr_active"],[14,6,1,"","repr_events"],[14,6,1,"","repr_flag"],[14,6,1,"","repr_readers"],[14,6,1,"","repr_writers"]],"kombu.asynchronous.http":[[15,6,1,"","Client"],[15,1,1,"","Headers"],[15,1,1,"","Request"],[15,1,1,"","Response"],[16,0,0,"-","base"],[17,0,0,"-","curl"]],"kombu.asynchronous.http.Headers":[[15,3,1,"","complete"]],"kombu.asynchronous.http.Request":[[15,3,1,"","auth_mode"],[15,3,1,"","auth_password"],[15,3,1,"","auth_username"],[15,3,1,"","body"],[15,3,1,"","ca_certs"],[15,3,1,"","client_cert"],[15,3,1,"","client_key"],[15,3,1,"","connect_timeout"],[15,3,1,"","follow_redirects"],[15,3,1,"","headers"],[15,3,1,"","max_redirects"],[15,3,1,"","method"],[15,3,1,"","network_interface"],[15,3,1,"","on_header"],[15,3,1,"","on_prepare"],[15,3,1,"","on_ready"],[15,3,1,"","on_stream"],[15,3,1,"","on_timeout"],[15,3,1,"","proxy_host"],[15,3,1,"","proxy_password"],[15,3,1,"","proxy_port"],[15,3,1,"","proxy_username"],[15,3,1,"","request_timeout"],[15,2,1,"","then"],[15,3,1,"","url"],[15,3,1,"","use_gzip"],[15,3,1,"","user_agent"],[15,3,1,"","validate_cert"]],"kombu.asynchronous.http.Response":[[15,4,1,"","body"],[15,3,1,"id0","buffer"],[15,3,1,"id1","code"],[15,4,1,"","content"],[15,3,1,"id2","effective_url"],[15,3,1,"id3","error"],[15,3,1,"id4","headers"],[15,2,1,"","raise_for_error"],[15,3,1,"id5","request"],[15,3,1,"id6","status"],[15,4,1,"","status_code"]],"kombu.asynchronous.http.base":[[16,1,1,"","Headers"],[16,1,1,"","Request"],[16,1,1,"","Response"]],"kombu.asynchronous.http.base.Headers":[[16,3,1,"","complete"]],"kombu.asynchronous.http.base.Request":[[16,3,1,"","auth_mode"],[16,3,1,"","auth_password"],[16,3,1,"","auth_username"],[16,3,1,"","body"],[16,3,1,"","ca_certs"],[16,3,1,"","client_cert"],[16,3,1,"","client_key"],[16,3,1,"","connect_timeout"],[16,3,1,"","follow_redirects"],[16,3,1,"","headers"],[16,3,1,"","max_redirects"],[16,3,1,"","method"],[16,3,1,"","network_interface"],[16,3,1,"","on_header"],[16,3,1,"","on_prepare"],[16,3,1,"","on_ready"],[16,3,1,"","on_stream"],[16,3,1,"","on_timeout"],[16,3,1,"","proxy_host"],[16,3,1,"","proxy_password"],[16,3,1,"","proxy_port"],[16,3,1,"","proxy_username"],[16,3,1,"","request_timeout"],[16,2,1,"","then"],[16,3,1,"","url"],[16,3,1,"","use_gzip"],[16,3,1,"","user_agent"],[16,3,1,"","validate_cert"]],"kombu.asynchronous.http.base.Response":[[16,4,1,"","body"],[16,3,1,"id0","buffer"],[16,3,1,"id1","code"],[16,4,1,"","content"],[16,3,1,"id2","effective_url"],[16,3,1,"id3","error"],[16,3,1,"id4","headers"],[16,2,1,"","raise_for_error"],[16,3,1,"id5","request"],[16,3,1,"id6","status"],[16,4,1,"","status_code"]],"kombu.asynchronous.http.curl":[[17,1,1,"","CurlClient"]],"kombu.asynchronous.http.curl.CurlClient":[[17,3,1,"","Curl"],[17,2,1,"","add_request"],[17,2,1,"","close"],[17,2,1,"","on_readable"],[17,2,1,"","on_writable"]],"kombu.asynchronous.hub":[[18,1,1,"","Hub"],[18,6,1,"","get_event_loop"],[18,6,1,"","set_event_loop"]],"kombu.asynchronous.hub.Hub":[[18,3,1,"","ERR"],[18,3,1,"","READ"],[18,3,1,"","WRITE"],[18,2,1,"","add"],[18,2,1,"","add_reader"],[18,2,1,"","add_writer"],[18,2,1,"","call_at"],[18,2,1,"","call_later"],[18,2,1,"","call_repeatedly"],[18,2,1,"","call_soon"],[18,2,1,"","close"],[18,2,1,"","create_loop"],[18,2,1,"","fire_timers"],[18,4,1,"","loop"],[18,2,1,"","on_callback_error"],[18,3,1,"","on_close"],[18,4,1,"","poller"],[18,2,1,"","remove"],[18,2,1,"","remove_reader"],[18,2,1,"","remove_writer"],[18,2,1,"","repr_active"],[18,2,1,"","repr_events"],[18,2,1,"","reset"],[18,2,1,"","run_forever"],[18,2,1,"","run_once"],[18,4,1,"","scheduler"],[18,2,1,"","stop"]],"kombu.asynchronous.semaphore":[[19,1,1,"","DummyLock"],[19,1,1,"","LaxBoundedSemaphore"]],"kombu.asynchronous.semaphore.LaxBoundedSemaphore":[[19,2,1,"","acquire"],[19,2,1,"","clear"],[19,2,1,"","grow"],[19,2,1,"","release"],[19,2,1,"","shrink"]],"kombu.asynchronous.timer":[[20,1,1,"","Entry"],[20,1,1,"","Timer"],[20,6,1,"","to_timestamp"]],"kombu.asynchronous.timer.Entry":[[20,3,1,"","args"],[20,2,1,"","cancel"],[20,3,1,"","canceled"],[20,4,1,"","cancelled"],[20,3,1,"","fun"],[20,3,1,"","kwargs"],[20,3,1,"","tref"]],"kombu.asynchronous.timer.Timer":[[20,1,1,"","Entry"],[20,2,1,"","apply_entry"],[20,2,1,"","call_after"],[20,2,1,"","call_at"],[20,2,1,"","call_repeatedly"],[20,2,1,"","cancel"],[20,2,1,"","clear"],[20,2,1,"","enter_after"],[20,2,1,"","enter_at"],[20,2,1,"","handle_error"],[20,3,1,"","on_error"],[20,4,1,"","queue"],[20,4,1,"","schedule"],[20,2,1,"","stop"]],"kombu.asynchronous.timer.Timer.Entry":[[20,3,1,"","args"],[20,2,1,"","cancel"],[20,3,1,"","canceled"],[20,4,1,"","cancelled"],[20,3,1,"","fun"],[20,3,1,"","kwargs"],[20,3,1,"","tref"]],"kombu.clocks":[[21,1,1,"","LamportClock"],[21,1,1,"","timetuple"]],"kombu.clocks.LamportClock":[[21,2,1,"","adjust"],[21,2,1,"","forward"],[21,2,1,"","sort_heap"],[21,3,1,"","value"]],"kombu.clocks.timetuple":[[21,4,1,"","clock"],[21,4,1,"","id"],[21,4,1,"","obj"],[21,4,1,"","timestamp"]],"kombu.common":[[22,1,1,"","Broadcast"],[22,6,1,"","collect_replies"],[22,6,1,"","drain_consumer"],[22,6,1,"","eventloop"],[22,6,1,"","insured"],[22,6,1,"","itermessages"],[22,6,1,"","maybe_declare"],[22,6,1,"","send_reply"],[22,6,1,"","uuid"]],"kombu.common.Broadcast":[[22,3,1,"","attrs"]],"kombu.compat":[[23,1,1,"","Consumer"],[23,1,1,"","ConsumerSet"],[23,1,1,"","Publisher"]],"kombu.compat.Consumer":[[23,5,1,"","ContentDisallowed"],[23,3,1,"","accept"],[23,2,1,"","add_queue"],[23,3,1,"","auto_declare"],[23,3,1,"","auto_delete"],[23,3,1,"","callbacks"],[23,2,1,"","cancel"],[23,2,1,"","cancel_by_queue"],[23,3,1,"","channel"],[23,2,1,"","close"],[23,4,1,"","connection"],[23,2,1,"","consume"],[23,2,1,"","consuming_from"],[23,2,1,"","declare"],[23,2,1,"","discard_all"],[23,3,1,"","durable"],[23,3,1,"","exchange"],[23,3,1,"","exchange_type"],[23,3,1,"","exclusive"],[23,2,1,"","fetch"],[23,2,1,"","flow"],[23,2,1,"","iterconsume"],[23,2,1,"","iterqueue"],[23,3,1,"","no_ack"],[23,3,1,"","on_decode_error"],[23,3,1,"","on_message"],[23,3,1,"","prefetch_count"],[23,2,1,"","process_next"],[23,2,1,"","purge"],[23,2,1,"","qos"],[23,3,1,"","queue"],[23,4,1,"","queues"],[23,2,1,"","receive"],[23,2,1,"","recover"],[23,2,1,"","register_callback"],[23,2,1,"","revive"],[23,3,1,"","routing_key"],[23,2,1,"","wait"]],"kombu.compat.Consumer.ContentDisallowed":[[23,3,1,"","args"],[23,2,1,"","with_traceback"]],"kombu.compat.ConsumerSet":[[23,5,1,"","ContentDisallowed"],[23,3,1,"","accept"],[23,2,1,"","add_consumer"],[23,2,1,"","add_consumer_from_dict"],[23,2,1,"","add_queue"],[23,3,1,"","auto_declare"],[23,3,1,"","callbacks"],[23,2,1,"","cancel"],[23,2,1,"","cancel_by_queue"],[23,3,1,"","channel"],[23,2,1,"","close"],[23,4,1,"","connection"],[23,2,1,"","consume"],[23,2,1,"","consuming_from"],[23,2,1,"","declare"],[23,2,1,"","discard_all"],[23,2,1,"","flow"],[23,2,1,"","iterconsume"],[23,3,1,"","no_ack"],[23,3,1,"","on_decode_error"],[23,3,1,"","on_message"],[23,3,1,"","prefetch_count"],[23,2,1,"","purge"],[23,2,1,"","qos"],[23,4,1,"","queues"],[23,2,1,"","receive"],[23,2,1,"","recover"],[23,2,1,"","register_callback"],[23,2,1,"","revive"]],"kombu.compat.ConsumerSet.ContentDisallowed":[[23,3,1,"","args"],[23,2,1,"","with_traceback"]],"kombu.compat.Publisher":[[23,3,1,"","auto_declare"],[23,3,1,"","auto_delete"],[23,4,1,"","backend"],[23,4,1,"","channel"],[23,2,1,"","close"],[23,3,1,"","compression"],[23,4,1,"","connection"],[23,2,1,"","declare"],[23,3,1,"","durable"],[23,3,1,"","exchange"],[23,3,1,"","exchange_type"],[23,2,1,"","maybe_declare"],[23,3,1,"","on_return"],[23,2,1,"","publish"],[23,2,1,"","release"],[23,2,1,"","revive"],[23,3,1,"","routing_key"],[23,2,1,"","send"],[23,3,1,"","serializer"]],"kombu.compression":[[24,6,1,"","compress"],[24,6,1,"","decompress"],[24,6,1,"","encoders"],[24,6,1,"","get_decoder"],[24,6,1,"","get_encoder"],[24,6,1,"","register"]],"kombu.connection":[[25,1,1,"","ChannelPool"],[25,1,1,"","Connection"],[25,1,1,"","ConnectionPool"]],"kombu.connection.ChannelPool":[[25,3,1,"","LimitExceeded"],[25,2,1,"","acquire"],[25,2,1,"","force_close_all"],[25,2,1,"","release"]],"kombu.connection.Connection":[[25,2,1,"","ChannelPool"],[25,2,1,"","Consumer"],[25,2,1,"","Pool"],[25,2,1,"","Producer"],[25,2,1,"","SimpleBuffer"],[25,2,1,"","SimpleQueue"],[25,2,1,"","as_uri"],[25,2,1,"","autoretry"],[25,2,1,"","channel"],[25,4,1,"","channel_errors"],[25,2,1,"","clone"],[25,2,1,"","close"],[25,2,1,"","collect"],[25,2,1,"","completes_cycle"],[25,2,1,"","connect"],[25,3,1,"","connect_timeout"],[25,4,1,"","connected"],[25,4,1,"","connection"],[25,4,1,"","connection_errors"],[25,2,1,"","create_transport"],[25,3,1,"","cycle"],[25,3,1,"","declared_entities"],[25,4,1,"","default_channel"],[25,2,1,"","drain_events"],[25,2,1,"","ensure"],[25,2,1,"","ensure_connection"],[25,3,1,"","failover_strategies"],[25,3,1,"","failover_strategy"],[25,2,1,"","get_heartbeat_interval"],[25,2,1,"","get_manager"],[25,2,1,"","get_transport_cls"],[25,3,1,"","heartbeat"],[25,2,1,"","heartbeat_check"],[25,4,1,"","host"],[25,3,1,"","hostname"],[25,2,1,"","info"],[25,4,1,"","is_evented"],[25,3,1,"","login_method"],[25,4,1,"","manager"],[25,2,1,"","maybe_close_channel"],[25,2,1,"","maybe_switch_next"],[25,3,1,"","password"],[25,3,1,"","port"],[25,4,1,"","qos_semantics_matches_spec"],[25,4,1,"","recoverable_channel_errors"],[25,4,1,"","recoverable_connection_errors"],[25,2,1,"","register_with_event_loop"],[25,2,1,"","release"],[25,3,1,"","resolve_aliases"],[25,2,1,"","revive"],[25,3,1,"","ssl"],[25,2,1,"","supports_exchange_type"],[25,4,1,"","supports_heartbeats"],[25,2,1,"","switch"],[25,4,1,"","transport"],[25,3,1,"","transport_options"],[25,3,1,"","uri_prefix"],[25,3,1,"","userid"],[25,3,1,"","virtual_host"]],"kombu.connection.ConnectionPool":[[25,3,1,"","LimitExceeded"],[25,2,1,"","acquire"],[25,2,1,"","force_close_all"],[25,2,1,"","release"]],"kombu.exceptions":[[26,5,1,"","ChannelLimitExceeded"],[26,5,1,"","ConnectionLimitExceeded"],[26,5,1,"","LimitExceeded"],[26,5,1,"","MessageStateError"],[26,5,1,"","NotBoundError"],[26,3,1,"","TimeoutError"]],"kombu.log":[[27,1,1,"","LogMixin"],[27,6,1,"","get_loglevel"],[27,6,1,"","setup_logging"]],"kombu.log.LogMixin":[[27,2,1,"","annotate"],[27,2,1,"","critical"],[27,2,1,"","debug"],[27,2,1,"","error"],[27,2,1,"","get_logger"],[27,2,1,"","get_loglevel"],[27,2,1,"","info"],[27,2,1,"","is_enabled_for"],[27,2,1,"","log"],[27,4,1,"","logger"],[27,4,1,"","logger_name"],[27,2,1,"","warn"]],"kombu.matcher":[[28,5,1,"","MatcherNotInstalled"],[28,1,1,"","MatcherRegistry"],[28,6,1,"","match"],[28,6,1,"","register"],[28,6,1,"","register_glob"],[28,6,1,"","register_pcre"],[28,7,1,"","registry"],[28,6,1,"","unregister"]],"kombu.matcher.MatcherRegistry":[[28,5,1,"","MatcherNotInstalled"],[28,2,1,"","match"],[28,3,1,"","matcher_pattern_first"],[28,2,1,"","register"],[28,2,1,"","unregister"]],"kombu.message":[[29,1,1,"","Message"]],"kombu.message.Message":[[29,5,1,"","MessageStateError"],[29,3,1,"","accept"],[29,2,1,"","ack"],[29,2,1,"","ack_log_error"],[29,4,1,"","acknowledged"],[29,3,1,"","body"],[29,3,1,"","channel"],[29,3,1,"","content_encoding"],[29,3,1,"","content_type"],[29,2,1,"","decode"],[29,3,1,"","delivery_info"],[29,3,1,"","delivery_tag"],[29,3,1,"","errors"],[29,3,1,"","headers"],[29,4,1,"","payload"],[29,3,1,"","properties"],[29,2,1,"","reject"],[29,2,1,"","reject_log_error"],[29,2,1,"","requeue"]],"kombu.mixins":[[30,1,1,"","ConsumerMixin"],[30,1,1,"","ConsumerProducerMixin"]],"kombu.mixins.ConsumerMixin":[[30,2,1,"","Consumer"],[30,4,1,"","channel_errors"],[30,3,1,"","connect_max_retries"],[30,4,1,"","connection_errors"],[30,2,1,"","consume"],[30,2,1,"","consumer_context"],[30,2,1,"","create_connection"],[30,2,1,"","establish_connection"],[30,2,1,"","extra_context"],[30,2,1,"","get_consumers"],[30,2,1,"","maybe_conn_error"],[30,2,1,"","on_connection_error"],[30,2,1,"","on_connection_revived"],[30,2,1,"","on_consume_end"],[30,2,1,"","on_consume_ready"],[30,2,1,"","on_decode_error"],[30,2,1,"","on_iteration"],[30,4,1,"","restart_limit"],[30,2,1,"","run"],[30,3,1,"","should_stop"]],"kombu.mixins.ConsumerProducerMixin":[[30,2,1,"","on_consume_end"],[30,4,1,"","producer"],[30,4,1,"","producer_connection"]],"kombu.pidbox":[[31,1,1,"","Mailbox"],[31,1,1,"","Node"]],"kombu.pidbox.Mailbox":[[31,2,1,"","Node"],[31,2,1,"","abcast"],[31,2,1,"","call"],[31,2,1,"","cast"],[31,3,1,"","connection"],[31,3,1,"","exchange"],[31,2,1,"","get_queue"],[31,2,1,"","get_reply_queue"],[31,2,1,"","multi_call"],[31,3,1,"","namespace"],[31,3,1,"","reply_exchange"],[31,3,1,"","type"]],"kombu.pidbox.Node":[[31,2,1,"","Consumer"],[31,3,1,"","channel"],[31,2,1,"","dispatch"],[31,2,1,"","dispatch_from_message"],[31,2,1,"","handle"],[31,2,1,"","handle_call"],[31,2,1,"","handle_cast"],[31,2,1,"","handle_message"],[31,2,1,"","handler"],[31,3,1,"","handlers"],[31,3,1,"","hostname"],[31,2,1,"","listen"],[31,3,1,"","mailbox"],[31,2,1,"","reply"],[31,3,1,"","state"]],"kombu.pools":[[32,1,1,"","PoolGroup"],[32,1,1,"","ProducerPool"],[32,6,1,"","get_limit"],[32,6,1,"","register_group"],[32,6,1,"","reset"],[32,6,1,"","set_limit"]],"kombu.pools.PoolGroup":[[32,2,1,"","create"]],"kombu.pools.ProducerPool":[[32,1,1,"","Producer"],[32,3,1,"","close_after_fork"],[32,2,1,"","close_resource"],[32,2,1,"","create_producer"],[32,2,1,"","new"],[32,2,1,"","prepare"],[32,2,1,"","release"],[32,2,1,"","setup"]],"kombu.pools.ProducerPool.Producer":[[32,3,1,"","auto_declare"],[32,4,1,"","channel"],[32,2,1,"","close"],[32,3,1,"","compression"],[32,4,1,"","connection"],[32,2,1,"","declare"],[32,3,1,"","exchange"],[32,2,1,"","maybe_declare"],[32,3,1,"","on_return"],[32,2,1,"","publish"],[32,2,1,"","release"],[32,2,1,"","revive"],[32,3,1,"","routing_key"],[32,3,1,"","serializer"]],"kombu.resource":[[33,1,1,"","LifoQueue"],[33,1,1,"","Resource"]],"kombu.resource.Resource":[[33,5,1,"","LimitExceeded"],[33,2,1,"","acquire"],[33,3,1,"","close_after_fork"],[33,2,1,"","close_resource"],[33,2,1,"","collect_resource"],[33,2,1,"","force_close_all"],[33,4,1,"","limit"],[33,2,1,"","prepare"],[33,2,1,"","release"],[33,2,1,"","release_resource"],[33,2,1,"","replace"],[33,2,1,"","resize"],[33,2,1,"","setup"]],"kombu.serialization":[[34,5,1,"","SerializerNotInstalled"],[34,6,1,"","dumps"],[34,6,1,"","loads"],[34,6,1,"","raw_encode"],[34,6,1,"","register"],[34,7,1,"","registry"],[34,6,1,"","unregister"]],"kombu.simple":[[35,1,1,"","SimpleBuffer"],[35,1,1,"","SimpleQueue"]],"kombu.simple.SimpleBuffer":[[35,2,1,"","__len__"],[35,3,1,"","channel"],[35,2,1,"","clear"],[35,2,1,"","close"],[35,3,1,"","consumer"],[35,3,1,"","exchange_opts"],[35,2,1,"","get"],[35,2,1,"","get_nowait"],[35,3,1,"","no_ack"],[35,3,1,"","producer"],[35,2,1,"","put"],[35,2,1,"","qsize"],[35,3,1,"","queue"],[35,3,1,"","queue_opts"]],"kombu.simple.SimpleQueue":[[35,2,1,"","__len__"],[35,3,1,"","channel"],[35,2,1,"","clear"],[35,2,1,"","close"],[35,3,1,"","consumer"],[35,3,1,"","exchange_opts"],[35,2,1,"","get"],[35,2,1,"","get_nowait"],[35,3,1,"","no_ack"],[35,3,1,"","producer"],[35,2,1,"","put"],[35,2,1,"","qsize"],[35,3,1,"","queue"],[35,3,1,"","queue_opts"]],"kombu.transport":[[36,7,1,"","DEFAULT_TRANSPORT"],[37,0,0,"-","SLMQ"],[38,0,0,"-","SQS"],[36,7,1,"","TRANSPORT_ALIASES"],[39,0,0,"-","azureservicebus"],[40,0,0,"-","azurestoragequeues"],[41,0,0,"-","base"],[42,0,0,"-","consul"],[43,0,0,"-","etcd"],[44,0,0,"-","filesystem"],[36,6,1,"","get_transport_cls"],[46,0,0,"-","memory"],[47,0,0,"-","mongodb"],[48,0,0,"-","pyamqp"],[49,0,0,"-","pyro"],[50,0,0,"-","qpid"],[51,0,0,"-","redis"],[36,6,1,"","resolve_transport"],[52,0,0,"-","sqlalchemy"],[53,0,0,"-","virtual"],[55,0,0,"-","zookeeper"]],"kombu.transport.SLMQ":[[37,1,1,"","Channel"],[37,1,1,"","Transport"]],"kombu.transport.SLMQ.Channel":[[37,2,1,"","basic_ack"],[37,2,1,"","basic_cancel"],[37,2,1,"","basic_consume"],[37,4,1,"","conninfo"],[37,3,1,"","default_visibility_timeout"],[37,2,1,"","delete_message"],[37,3,1,"","domain_format"],[37,2,1,"","entity_name"],[37,4,1,"","queue_name_prefix"],[37,4,1,"","slmq"],[37,4,1,"","transport_options"],[37,4,1,"","visibility_timeout"]],"kombu.transport.SLMQ.Transport":[[37,1,1,"","Channel"],[37,3,1,"","connection_errors"],[37,3,1,"","default_port"],[37,3,1,"","polling_interval"]],"kombu.transport.SLMQ.Transport.Channel":[[37,2,1,"","basic_ack"],[37,2,1,"","basic_cancel"],[37,2,1,"","basic_consume"],[37,4,1,"","conninfo"],[37,3,1,"","default_visibility_timeout"],[37,2,1,"","delete_message"],[37,3,1,"","domain_format"],[37,2,1,"","entity_name"],[37,4,1,"","queue_name_prefix"],[37,4,1,"","slmq"],[37,4,1,"","transport_options"],[37,4,1,"","visibility_timeout"]],"kombu.transport.SQS":[[38,1,1,"","Channel"],[38,1,1,"","Transport"]],"kombu.transport.SQS.Channel":[[38,1,1,"","QoS"],[38,2,1,"","asynsqs"],[38,2,1,"","basic_ack"],[38,2,1,"","basic_cancel"],[38,2,1,"","basic_consume"],[38,2,1,"","canonical_queue_name"],[38,2,1,"","close"],[38,4,1,"","conninfo"],[38,3,1,"","default_region"],[38,3,1,"","default_visibility_timeout"],[38,3,1,"","default_wait_time_seconds"],[38,3,1,"","domain_format"],[38,2,1,"","drain_events"],[38,4,1,"","endpoint_url"],[38,2,1,"","entity_name"],[38,2,1,"","generate_sts_session_token"],[38,4,1,"","is_secure"],[38,2,1,"","new_sqs_client"],[38,4,1,"","port"],[38,4,1,"","predefined_queues"],[38,4,1,"","queue_name_prefix"],[38,4,1,"","region"],[38,4,1,"","regioninfo"],[38,2,1,"","sqs"],[38,4,1,"","sqs_base64_encoding"],[38,4,1,"","supports_fanout"],[38,4,1,"","transport_options"],[38,4,1,"","visibility_timeout"],[38,4,1,"","wait_time_seconds"]],"kombu.transport.SQS.Channel.QoS":[[38,2,1,"","apply_backoff_policy"],[38,2,1,"","extract_task_name_and_number_of_retries"],[38,2,1,"","reject"]],"kombu.transport.SQS.Transport":[[38,1,1,"","Channel"],[38,3,1,"","channel_errors"],[38,3,1,"","connection_errors"],[38,4,1,"","default_connection_params"],[38,3,1,"","default_port"],[38,3,1,"","driver_name"],[38,3,1,"","driver_type"],[38,3,1,"","implements"],[38,3,1,"","polling_interval"],[38,3,1,"","wait_time_seconds"]],"kombu.transport.SQS.Transport.Channel":[[38,1,1,"","QoS"],[38,2,1,"","asynsqs"],[38,2,1,"","basic_ack"],[38,2,1,"","basic_cancel"],[38,2,1,"","basic_consume"],[38,2,1,"","canonical_queue_name"],[38,2,1,"","close"],[38,4,1,"","conninfo"],[38,3,1,"","default_region"],[38,3,1,"","default_visibility_timeout"],[38,3,1,"","default_wait_time_seconds"],[38,3,1,"","domain_format"],[38,2,1,"","drain_events"],[38,4,1,"","endpoint_url"],[38,2,1,"","entity_name"],[38,2,1,"","generate_sts_session_token"],[38,4,1,"","is_secure"],[38,2,1,"","new_sqs_client"],[38,4,1,"","port"],[38,4,1,"","predefined_queues"],[38,4,1,"","queue_name_prefix"],[38,4,1,"","region"],[38,4,1,"","regioninfo"],[38,2,1,"","sqs"],[38,4,1,"","sqs_base64_encoding"],[38,4,1,"","supports_fanout"],[38,4,1,"","transport_options"],[38,4,1,"","visibility_timeout"],[38,4,1,"","wait_time_seconds"]],"kombu.transport.SQS.Transport.Channel.QoS":[[38,2,1,"","apply_backoff_policy"],[38,2,1,"","extract_task_name_and_number_of_retries"],[38,2,1,"","reject"]],"kombu.transport.azureservicebus":[[39,1,1,"","Channel"],[39,1,1,"","Transport"]],"kombu.transport.azureservicebus.Channel":[[39,2,1,"","basic_ack"],[39,2,1,"","basic_cancel"],[39,2,1,"","basic_consume"],[39,2,1,"","close"],[39,4,1,"","conninfo"],[39,3,1,"","default_peek_lock_seconds"],[39,3,1,"","default_retry_backoff_factor"],[39,3,1,"","default_retry_backoff_max"],[39,3,1,"","default_retry_total"],[39,3,1,"","default_uamqp_keep_alive_interval"],[39,3,1,"","default_wait_time_seconds"],[39,3,1,"","domain_format"],[39,2,1,"","entity_name"],[39,4,1,"","peek_lock_seconds"],[39,4,1,"","queue_mgmt_service"],[39,4,1,"","queue_name_prefix"],[39,4,1,"","queue_service"],[39,4,1,"","retry_backoff_factor"],[39,4,1,"","retry_backoff_max"],[39,4,1,"","retry_total"],[39,4,1,"","transport_options"],[39,4,1,"","uamqp_keep_alive_interval"],[39,4,1,"","wait_time_seconds"]],"kombu.transport.azureservicebus.Transport":[[39,1,1,"","Channel"],[39,2,1,"","as_uri"],[39,3,1,"","can_parse_url"],[39,3,1,"","default_port"],[39,2,1,"","parse_uri"],[39,3,1,"","polling_interval"]],"kombu.transport.azureservicebus.Transport.Channel":[[39,2,1,"","basic_ack"],[39,2,1,"","basic_cancel"],[39,2,1,"","basic_consume"],[39,2,1,"","close"],[39,4,1,"","conninfo"],[39,3,1,"","default_peek_lock_seconds"],[39,3,1,"","default_retry_backoff_factor"],[39,3,1,"","default_retry_backoff_max"],[39,3,1,"","default_retry_total"],[39,3,1,"","default_uamqp_keep_alive_interval"],[39,3,1,"","default_wait_time_seconds"],[39,3,1,"","domain_format"],[39,2,1,"","entity_name"],[39,4,1,"","peek_lock_seconds"],[39,4,1,"","queue_mgmt_service"],[39,4,1,"","queue_name_prefix"],[39,4,1,"","queue_service"],[39,4,1,"","retry_backoff_factor"],[39,4,1,"","retry_backoff_max"],[39,4,1,"","retry_total"],[39,4,1,"","transport_options"],[39,4,1,"","uamqp_keep_alive_interval"],[39,4,1,"","wait_time_seconds"]],"kombu.transport.azurestoragequeues":[[40,1,1,"","Channel"],[40,1,1,"","Transport"]],"kombu.transport.azurestoragequeues.Channel":[[40,2,1,"","basic_consume"],[40,4,1,"","conninfo"],[40,3,1,"","domain_format"],[40,2,1,"","entity_name"],[40,3,1,"","no_ack"],[40,4,1,"","queue_name_prefix"],[40,4,1,"","queue_service"],[40,4,1,"","transport_options"]],"kombu.transport.azurestoragequeues.Transport":[[40,1,1,"","Channel"],[40,3,1,"","default_port"],[40,3,1,"","polling_interval"]],"kombu.transport.azurestoragequeues.Transport.Channel":[[40,2,1,"","basic_consume"],[40,4,1,"","conninfo"],[40,3,1,"","domain_format"],[40,2,1,"","entity_name"],[40,3,1,"","no_ack"],[40,4,1,"","queue_name_prefix"],[40,4,1,"","queue_service"],[40,4,1,"","transport_options"]],"kombu.transport.base":[[41,1,1,"","Message"],[41,1,1,"","Transport"]],"kombu.transport.base.Message":[[41,2,1,"","ack"],[41,3,1,"","acknowledged"],[41,3,1,"","body"],[41,3,1,"","channel"],[41,3,1,"","content_encoding"],[41,3,1,"","content_type"],[41,2,1,"","decode"],[41,3,1,"","delivery_info"],[41,3,1,"","delivery_tag"],[41,3,1,"","headers"],[41,3,1,"","payload"],[41,3,1,"","properties"],[41,2,1,"","reject"],[41,2,1,"","requeue"]],"kombu.transport.base.Transport":[[41,3,1,"","channel_errors"],[41,3,1,"","client"],[41,2,1,"","close_channel"],[41,2,1,"","close_connection"],[41,3,1,"","connection_errors"],[41,2,1,"","create_channel"],[41,3,1,"","default_port"],[41,2,1,"","drain_events"],[41,2,1,"","establish_connection"],[41,3,1,"","recoverable_channel_errors"],[41,3,1,"","recoverable_connection_errors"]],"kombu.transport.consul":[[42,1,1,"","Channel"],[42,1,1,"","Transport"]],"kombu.transport.consul.Channel":[[42,3,1,"","index"],[42,4,1,"","lock_name"],[42,3,1,"","prefix"],[42,3,1,"","session_ttl"],[42,3,1,"","timeout"]],"kombu.transport.consul.Transport":[[42,1,1,"","Channel"],[42,3,1,"","default_port"],[42,3,1,"","driver_name"],[42,3,1,"","driver_type"],[42,2,1,"","driver_version"],[42,2,1,"","verify_connection"]],"kombu.transport.consul.Transport.Channel":[[42,3,1,"","index"],[42,4,1,"","lock_name"],[42,3,1,"","prefix"],[42,3,1,"","session_ttl"],[42,3,1,"","timeout"]],"kombu.transport.etcd":[[43,1,1,"","Channel"],[43,1,1,"","Transport"]],"kombu.transport.etcd.Channel":[[43,3,1,"","index"],[43,3,1,"","lock_ttl"],[43,4,1,"","lock_value"],[43,3,1,"","prefix"],[43,3,1,"","session_ttl"],[43,3,1,"","timeout"]],"kombu.transport.etcd.Transport":[[43,1,1,"","Channel"],[43,3,1,"","default_port"],[43,3,1,"","driver_name"],[43,3,1,"","driver_type"],[43,2,1,"","driver_version"],[43,3,1,"","implements"],[43,3,1,"","polling_interval"],[43,2,1,"","verify_connection"]],"kombu.transport.etcd.Transport.Channel":[[43,3,1,"","index"],[43,3,1,"","lock_ttl"],[43,4,1,"","lock_value"],[43,3,1,"","prefix"],[43,3,1,"","session_ttl"],[43,3,1,"","timeout"]],"kombu.transport.filesystem":[[44,1,1,"","Channel"],[44,1,1,"","Transport"]],"kombu.transport.filesystem.Channel":[[44,4,1,"","data_folder_in"],[44,4,1,"","data_folder_out"],[44,4,1,"","processed_folder"],[44,4,1,"","store_processed"],[44,4,1,"","transport_options"]],"kombu.transport.filesystem.Transport":[[44,1,1,"","Channel"],[44,3,1,"","default_port"],[44,3,1,"","driver_name"],[44,3,1,"","driver_type"],[44,2,1,"","driver_version"],[44,3,1,"","global_state"]],"kombu.transport.filesystem.Transport.Channel":[[44,4,1,"","data_folder_in"],[44,4,1,"","data_folder_out"],[44,4,1,"","processed_folder"],[44,4,1,"","store_processed"],[44,4,1,"","transport_options"]],"kombu.transport.memory":[[46,1,1,"","Channel"],[46,1,1,"","Transport"]],"kombu.transport.memory.Channel":[[46,2,1,"","after_reply_message_received"],[46,2,1,"","close"],[46,3,1,"","do_restore"],[46,3,1,"","events"],[46,3,1,"","queues"],[46,3,1,"","supports_fanout"]],"kombu.transport.memory.Transport":[[46,1,1,"","Channel"],[46,3,1,"","driver_name"],[46,3,1,"","driver_type"],[46,2,1,"","driver_version"],[46,3,1,"","global_state"],[46,3,1,"","implements"]],"kombu.transport.memory.Transport.Channel":[[46,2,1,"","after_reply_message_received"],[46,2,1,"","close"],[46,3,1,"","do_restore"],[46,3,1,"","events"],[46,3,1,"","queues"],[46,3,1,"","supports_fanout"]],"kombu.transport.mongodb":[[47,1,1,"","Channel"],[47,1,1,"","Transport"]],"kombu.transport.mongodb.Channel":[[47,4,1,"","broadcast"],[47,3,1,"","broadcast_collection"],[47,3,1,"","calc_queue_size"],[47,3,1,"","capped_queue_size"],[47,4,1,"","client"],[47,3,1,"","connect_timeout"],[47,3,1,"","default_database"],[47,3,1,"","default_hostname"],[47,3,1,"","default_port"],[47,3,1,"","from_transport_options"],[47,2,1,"","get_now"],[47,2,1,"","get_table"],[47,4,1,"","messages"],[47,3,1,"","messages_collection"],[47,2,1,"","prepare_queue_arguments"],[47,2,1,"","queue_delete"],[47,4,1,"","queues"],[47,3,1,"","queues_collection"],[47,4,1,"","routing"],[47,3,1,"","routing_collection"],[47,3,1,"","ssl"],[47,3,1,"","supports_fanout"],[47,3,1,"","ttl"]],"kombu.transport.mongodb.Transport":[[47,1,1,"","Channel"],[47,3,1,"","can_parse_url"],[47,3,1,"","channel_errors"],[47,3,1,"","connection_errors"],[47,3,1,"","default_port"],[47,3,1,"","driver_name"],[47,3,1,"","driver_type"],[47,2,1,"","driver_version"],[47,3,1,"","implements"],[47,3,1,"","polling_interval"]],"kombu.transport.mongodb.Transport.Channel":[[47,4,1,"","broadcast"],[47,3,1,"","broadcast_collection"],[47,3,1,"","calc_queue_size"],[47,3,1,"","capped_queue_size"],[47,4,1,"","client"],[47,3,1,"","connect_timeout"],[47,3,1,"","default_database"],[47,3,1,"","default_hostname"],[47,3,1,"","default_port"],[47,3,1,"","from_transport_options"],[47,2,1,"","get_now"],[47,2,1,"","get_table"],[47,4,1,"","messages"],[47,3,1,"","messages_collection"],[47,2,1,"","prepare_queue_arguments"],[47,2,1,"","queue_delete"],[47,4,1,"","queues"],[47,3,1,"","queues_collection"],[47,4,1,"","routing"],[47,3,1,"","routing_collection"],[47,3,1,"","ssl"],[47,3,1,"","supports_fanout"],[47,3,1,"","ttl"]],"kombu.transport.pyamqp":[[48,1,1,"","Channel"],[48,1,1,"","Connection"],[48,1,1,"","Message"],[48,1,1,"","Transport"]],"kombu.transport.pyamqp.Channel":[[48,1,1,"","Message"],[48,3,1,"","auto_decode"],[48,3,1,"","channel_id"],[48,3,1,"","connection"],[48,3,1,"","is_closing"],[48,2,1,"","message_to_python"],[48,3,1,"","method_queue"],[48,2,1,"","prepare_message"],[48,2,1,"","prepare_queue_arguments"]],"kombu.transport.pyamqp.Channel.Message":[[48,3,1,"","accept"],[48,3,1,"","body"],[48,3,1,"","channel"],[48,3,1,"","content_encoding"],[48,3,1,"","content_type"],[48,3,1,"","delivery_info"],[48,3,1,"","delivery_tag"],[48,3,1,"","headers"],[48,3,1,"","properties"]],"kombu.transport.pyamqp.Connection":[[48,1,1,"","Channel"],[48,2,1,"","Transport"],[48,3,1,"","auto_decode"],[48,2,1,"","blocking_read"],[48,3,1,"","bytes_recv"],[48,3,1,"","bytes_sent"],[48,2,1,"","channel"],[48,3,1,"","channel_errors"],[48,3,1,"","channel_id"],[48,3,1,"","client_heartbeat"],[48,2,1,"","close"],[48,2,1,"","collect"],[48,2,1,"","connect"],[48,4,1,"","connected"],[48,3,1,"","connection"],[48,3,1,"","connection_errors"],[48,2,1,"","dispatch_method"],[48,2,1,"","drain_events"],[48,4,1,"","frame_writer"],[48,3,1,"","heartbeat"],[48,2,1,"","heartbeat_tick"],[48,2,1,"","is_alive"],[48,3,1,"","is_closing"],[48,3,1,"","last_heartbeat_received"],[48,3,1,"","last_heartbeat_sent"],[48,3,1,"","library_properties"],[48,3,1,"","method_queue"],[48,3,1,"","negotiate_capabilities"],[48,4,1,"","on_inbound_frame"],[48,2,1,"","on_inbound_method"],[48,3,1,"","prev_recv"],[48,3,1,"","prev_sent"],[48,3,1,"","recoverable_channel_errors"],[48,3,1,"","recoverable_connection_errors"],[48,2,1,"","send_heartbeat"],[48,2,1,"","send_method"],[48,4,1,"","server_capabilities"],[48,3,1,"","server_heartbeat"],[48,4,1,"","sock"],[48,2,1,"","then"],[48,4,1,"","transport"],[48,2,1,"","wait"]],"kombu.transport.pyamqp.Connection.Channel":[[48,2,1,"","Consumer"],[48,1,1,"","Message"],[48,2,1,"","Producer"],[48,2,1,"","after_reply_message_received"],[48,3,1,"","auto_decode"],[48,2,1,"","basic_ack"],[48,2,1,"","basic_cancel"],[48,2,1,"","basic_consume"],[48,2,1,"","basic_get"],[48,2,1,"","basic_publish"],[48,2,1,"","basic_publish_confirm"],[48,2,1,"","basic_qos"],[48,2,1,"","basic_recover"],[48,2,1,"","basic_recover_async"],[48,2,1,"","basic_reject"],[48,3,1,"","channel_id"],[48,2,1,"","close"],[48,2,1,"","collect"],[48,2,1,"","confirm_select"],[48,3,1,"","connection"],[48,2,1,"","dispatch_method"],[48,2,1,"","exchange_bind"],[48,2,1,"","exchange_declare"],[48,2,1,"","exchange_delete"],[48,2,1,"","exchange_unbind"],[48,2,1,"","flow"],[48,2,1,"","get_bindings"],[48,3,1,"","is_closing"],[48,2,1,"","message_to_python"],[48,3,1,"","method_queue"],[48,3,1,"","no_ack_consumers"],[48,2,1,"","open"],[48,2,1,"","prepare_message"],[48,2,1,"","prepare_queue_arguments"],[48,2,1,"","queue_bind"],[48,2,1,"","queue_declare"],[48,2,1,"","queue_delete"],[48,2,1,"","queue_purge"],[48,2,1,"","queue_unbind"],[48,2,1,"","send_method"],[48,2,1,"","then"],[48,2,1,"","tx_commit"],[48,2,1,"","tx_rollback"],[48,2,1,"","tx_select"],[48,2,1,"","wait"]],"kombu.transport.pyamqp.Connection.Channel.Message":[[48,5,1,"","MessageStateError"],[48,3,1,"","accept"],[48,2,1,"","ack"],[48,2,1,"","ack_log_error"],[48,4,1,"","acknowledged"],[48,3,1,"","body"],[48,3,1,"","channel"],[48,3,1,"","content_encoding"],[48,3,1,"","content_type"],[48,2,1,"","decode"],[48,3,1,"","delivery_info"],[48,3,1,"","delivery_tag"],[48,3,1,"","errors"],[48,3,1,"","headers"],[48,4,1,"","payload"],[48,3,1,"","properties"],[48,2,1,"","reject"],[48,2,1,"","reject_log_error"],[48,2,1,"","requeue"]],"kombu.transport.pyamqp.Connection.Channel.Message.MessageStateError":[[48,3,1,"","args"],[48,2,1,"","with_traceback"]],"kombu.transport.pyamqp.Message":[[48,3,1,"","accept"],[48,3,1,"","body"],[48,3,1,"","channel"],[48,3,1,"","content_encoding"],[48,3,1,"","content_type"],[48,3,1,"","delivery_info"],[48,3,1,"","delivery_tag"],[48,3,1,"","headers"],[48,3,1,"","properties"]],"kombu.transport.pyamqp.Transport":[[48,1,1,"","Connection"],[48,3,1,"","channel_errors"],[48,2,1,"","close_connection"],[48,3,1,"","connection_errors"],[48,2,1,"","create_channel"],[48,4,1,"","default_connection_params"],[48,3,1,"","default_port"],[48,3,1,"","default_ssl_port"],[48,2,1,"","drain_events"],[48,3,1,"","driver_name"],[48,3,1,"","driver_type"],[48,2,1,"","driver_version"],[48,2,1,"","establish_connection"],[48,2,1,"","get_heartbeat_interval"],[48,2,1,"","get_manager"],[48,2,1,"","heartbeat_check"],[48,3,1,"","implements"],[48,2,1,"","qos_semantics_matches_spec"],[48,3,1,"","recoverable_channel_errors"],[48,3,1,"","recoverable_connection_errors"],[48,2,1,"","register_with_event_loop"],[48,2,1,"","verify_connection"]],"kombu.transport.pyamqp.Transport.Connection":[[48,1,1,"","Channel"],[48,3,1,"","auto_decode"],[48,3,1,"","channel_id"],[48,3,1,"","connection"],[48,3,1,"","is_closing"],[48,3,1,"","method_queue"]],"kombu.transport.pyamqp.Transport.Connection.Channel":[[48,1,1,"","Message"],[48,3,1,"","auto_decode"],[48,3,1,"","channel_id"],[48,3,1,"","connection"],[48,3,1,"","is_closing"],[48,2,1,"","message_to_python"],[48,3,1,"","method_queue"],[48,2,1,"","prepare_message"],[48,2,1,"","prepare_queue_arguments"]],"kombu.transport.pyamqp.Transport.Connection.Channel.Message":[[48,3,1,"","accept"],[48,3,1,"","body"],[48,3,1,"","channel"],[48,3,1,"","content_encoding"],[48,3,1,"","content_type"],[48,3,1,"","delivery_info"],[48,3,1,"","delivery_tag"],[48,3,1,"","headers"],[48,3,1,"","properties"]],"kombu.transport.pyro":[[49,1,1,"","Channel"],[49,1,1,"","KombuBroker"],[49,1,1,"","Transport"]],"kombu.transport.pyro.Channel":[[49,2,1,"","after_reply_message_received"],[49,2,1,"","close"],[49,2,1,"","queues"],[49,4,1,"","shared_queues"]],"kombu.transport.pyro.Transport":[[49,1,1,"","Channel"],[49,3,1,"","default_port"],[49,3,1,"","driver_name"],[49,3,1,"","driver_type"],[49,2,1,"","driver_version"],[49,3,1,"","global_state"],[49,4,1,"","shared_queues"]],"kombu.transport.pyro.Transport.Channel":[[49,2,1,"","after_reply_message_received"],[49,2,1,"","close"],[49,2,1,"","queues"],[49,4,1,"","shared_queues"]],"kombu.transport.qpid":[[50,1,1,"","Channel"],[50,1,1,"","Connection"],[50,1,1,"","Message"],[50,1,1,"","Transport"]],"kombu.transport.qpid.Channel":[[50,1,1,"","Message"],[50,1,1,"","QoS"],[50,2,1,"","basic_ack"],[50,2,1,"","basic_cancel"],[50,2,1,"","basic_consume"],[50,2,1,"","basic_get"],[50,2,1,"","basic_publish"],[50,2,1,"","basic_qos"],[50,2,1,"","basic_reject"],[50,3,1,"","body_encoding"],[50,2,1,"","close"],[50,3,1,"","codecs"],[50,2,1,"","decode_body"],[50,2,1,"","encode_body"],[50,2,1,"","exchange_declare"],[50,2,1,"","exchange_delete"],[50,2,1,"","prepare_message"],[50,4,1,"","qos"],[50,2,1,"","queue_bind"],[50,2,1,"","queue_declare"],[50,2,1,"","queue_delete"],[50,2,1,"","queue_purge"],[50,2,1,"","queue_unbind"],[50,2,1,"","typeof"]],"kombu.transport.qpid.Channel.Message":[[50,3,1,"","accept"],[50,3,1,"","body"],[50,3,1,"","channel"],[50,3,1,"","content_encoding"],[50,3,1,"","content_type"],[50,3,1,"","delivery_info"],[50,3,1,"","delivery_tag"],[50,3,1,"","headers"],[50,3,1,"","properties"],[50,2,1,"","serializable"]],"kombu.transport.qpid.Channel.QoS":[[50,2,1,"","ack"],[50,2,1,"","append"],[50,2,1,"","can_consume"],[50,2,1,"","can_consume_max_estimate"],[50,2,1,"","get"],[50,2,1,"","reject"]],"kombu.transport.qpid.Connection":[[50,1,1,"","Channel"],[50,2,1,"","close"],[50,2,1,"","close_channel"],[50,2,1,"","get_qpid_connection"]],"kombu.transport.qpid.Connection.Channel":[[50,1,1,"","Message"],[50,1,1,"","QoS"],[50,2,1,"","basic_ack"],[50,2,1,"","basic_cancel"],[50,2,1,"","basic_consume"],[50,2,1,"","basic_get"],[50,2,1,"","basic_publish"],[50,2,1,"","basic_qos"],[50,2,1,"","basic_reject"],[50,3,1,"","body_encoding"],[50,2,1,"","close"],[50,3,1,"","codecs"],[50,2,1,"","decode_body"],[50,2,1,"","encode_body"],[50,2,1,"","exchange_declare"],[50,2,1,"","exchange_delete"],[50,2,1,"","prepare_message"],[50,4,1,"","qos"],[50,2,1,"","queue_bind"],[50,2,1,"","queue_declare"],[50,2,1,"","queue_delete"],[50,2,1,"","queue_purge"],[50,2,1,"","queue_unbind"],[50,2,1,"","typeof"]],"kombu.transport.qpid.Connection.Channel.Message":[[50,3,1,"","accept"],[50,3,1,"","body"],[50,3,1,"","channel"],[50,3,1,"","content_encoding"],[50,3,1,"","content_type"],[50,3,1,"","delivery_info"],[50,3,1,"","delivery_tag"],[50,3,1,"","headers"],[50,3,1,"","properties"],[50,2,1,"","serializable"]],"kombu.transport.qpid.Connection.Channel.QoS":[[50,2,1,"","ack"],[50,2,1,"","append"],[50,2,1,"","can_consume"],[50,2,1,"","can_consume_max_estimate"],[50,2,1,"","get"],[50,2,1,"","reject"]],"kombu.transport.qpid.Message":[[50,3,1,"","accept"],[50,3,1,"","body"],[50,3,1,"","channel"],[50,3,1,"","content_encoding"],[50,3,1,"","content_type"],[50,3,1,"","delivery_info"],[50,3,1,"","delivery_tag"],[50,3,1,"","headers"],[50,3,1,"","properties"],[50,2,1,"","serializable"]],"kombu.transport.qpid.Transport":[[50,1,1,"","Connection"],[50,3,1,"","channel_errors"],[50,2,1,"","close_connection"],[50,3,1,"","connection_errors"],[50,2,1,"","create_channel"],[50,4,1,"","default_connection_params"],[50,2,1,"","drain_events"],[50,3,1,"","driver_name"],[50,3,1,"","driver_type"],[50,2,1,"","establish_connection"],[50,3,1,"","implements"],[50,2,1,"","on_readable"],[50,3,1,"","polling_interval"],[50,3,1,"","recoverable_channel_errors"],[50,3,1,"","recoverable_connection_errors"],[50,2,1,"","register_with_event_loop"],[50,2,1,"","verify_runtime_environment"]],"kombu.transport.qpid.Transport.Connection":[[50,1,1,"","Channel"],[50,2,1,"","close"],[50,2,1,"","close_channel"],[50,2,1,"","get_qpid_connection"]],"kombu.transport.qpid.Transport.Connection.Channel":[[50,1,1,"","Message"],[50,1,1,"","QoS"],[50,2,1,"","basic_ack"],[50,2,1,"","basic_cancel"],[50,2,1,"","basic_consume"],[50,2,1,"","basic_get"],[50,2,1,"","basic_publish"],[50,2,1,"","basic_qos"],[50,2,1,"","basic_reject"],[50,3,1,"","body_encoding"],[50,2,1,"","close"],[50,3,1,"","codecs"],[50,2,1,"","decode_body"],[50,2,1,"","encode_body"],[50,2,1,"","exchange_declare"],[50,2,1,"","exchange_delete"],[50,2,1,"","prepare_message"],[50,4,1,"","qos"],[50,2,1,"","queue_bind"],[50,2,1,"","queue_declare"],[50,2,1,"","queue_delete"],[50,2,1,"","queue_purge"],[50,2,1,"","queue_unbind"],[50,2,1,"","typeof"]],"kombu.transport.qpid.Transport.Connection.Channel.Message":[[50,3,1,"","accept"],[50,3,1,"","body"],[50,3,1,"","channel"],[50,3,1,"","content_encoding"],[50,3,1,"","content_type"],[50,3,1,"","delivery_info"],[50,3,1,"","delivery_tag"],[50,3,1,"","headers"],[50,3,1,"","properties"],[50,2,1,"","serializable"]],"kombu.transport.qpid.Transport.Connection.Channel.QoS":[[50,2,1,"","ack"],[50,2,1,"","append"],[50,2,1,"","can_consume"],[50,2,1,"","can_consume_max_estimate"],[50,2,1,"","get"],[50,2,1,"","reject"]],"kombu.transport.redis":[[51,1,1,"","Channel"],[51,1,1,"","SentinelChannel"],[51,1,1,"","Transport"]],"kombu.transport.redis.Channel":[[51,1,1,"","QoS"],[51,3,1,"","ack_emulation"],[51,4,1,"","active_queues"],[51,4,1,"","async_pool"],[51,2,1,"","basic_cancel"],[51,2,1,"","basic_consume"],[51,4,1,"","client"],[51,2,1,"","close"],[51,2,1,"","conn_or_acquire"],[51,3,1,"","connection_class"],[51,3,1,"","connection_class_ssl"],[51,3,1,"","fanout_patterns"],[51,3,1,"","fanout_prefix"],[51,3,1,"","from_transport_options"],[51,2,1,"","get_table"],[51,3,1,"","global_keyprefix"],[51,3,1,"","health_check_interval"],[51,3,1,"","keyprefix_fanout"],[51,3,1,"","keyprefix_queue"],[51,3,1,"","max_connections"],[51,4,1,"","pool"],[51,2,1,"","priority"],[51,3,1,"","priority_steps"],[51,3,1,"","queue_order_strategy"],[51,3,1,"","retry_on_timeout"],[51,3,1,"","sep"],[51,3,1,"","socket_connect_timeout"],[51,3,1,"","socket_keepalive"],[51,3,1,"","socket_keepalive_options"],[51,3,1,"","socket_timeout"],[51,4,1,"","subclient"],[51,3,1,"","supports_fanout"],[51,3,1,"","unacked_index_key"],[51,3,1,"","unacked_key"],[51,3,1,"","unacked_mutex_expire"],[51,3,1,"","unacked_mutex_key"],[51,3,1,"","unacked_restore_limit"],[51,3,1,"","visibility_timeout"]],"kombu.transport.redis.Channel.QoS":[[51,2,1,"","ack"],[51,2,1,"","append"],[51,2,1,"","pipe_or_acquire"],[51,2,1,"","reject"],[51,3,1,"","restore_at_shutdown"],[51,2,1,"","restore_by_tag"],[51,2,1,"","restore_unacked"],[51,2,1,"","restore_visible"],[51,4,1,"","unacked_index_key"],[51,4,1,"","unacked_key"],[51,4,1,"","unacked_mutex_expire"],[51,4,1,"","unacked_mutex_key"],[51,4,1,"","visibility_timeout"]],"kombu.transport.redis.SentinelChannel":[[51,3,1,"","connection_class"],[51,3,1,"","connection_class_ssl"],[51,3,1,"","from_transport_options"]],"kombu.transport.redis.Transport":[[51,1,1,"","Channel"],[51,3,1,"","channel_errors"],[51,3,1,"","connection_errors"],[51,3,1,"","default_port"],[51,3,1,"","driver_name"],[51,3,1,"","driver_type"],[51,2,1,"","driver_version"],[51,3,1,"","implements"],[51,2,1,"","on_readable"],[51,3,1,"","polling_interval"],[51,2,1,"","register_with_event_loop"]],"kombu.transport.redis.Transport.Channel":[[51,1,1,"","QoS"],[51,3,1,"","ack_emulation"],[51,4,1,"","active_queues"],[51,4,1,"","async_pool"],[51,2,1,"","basic_cancel"],[51,2,1,"","basic_consume"],[51,4,1,"","client"],[51,2,1,"","close"],[51,2,1,"","conn_or_acquire"],[51,3,1,"","connection_class"],[51,3,1,"","connection_class_ssl"],[51,3,1,"","fanout_patterns"],[51,3,1,"","fanout_prefix"],[51,3,1,"","from_transport_options"],[51,2,1,"","get_table"],[51,3,1,"","global_keyprefix"],[51,3,1,"","health_check_interval"],[51,3,1,"","keyprefix_fanout"],[51,3,1,"","keyprefix_queue"],[51,3,1,"","max_connections"],[51,4,1,"","pool"],[51,2,1,"","priority"],[51,3,1,"","priority_steps"],[51,3,1,"","queue_order_strategy"],[51,3,1,"","retry_on_timeout"],[51,3,1,"","sep"],[51,3,1,"","socket_connect_timeout"],[51,3,1,"","socket_keepalive"],[51,3,1,"","socket_keepalive_options"],[51,3,1,"","socket_timeout"],[51,4,1,"","subclient"],[51,3,1,"","supports_fanout"],[51,3,1,"","unacked_index_key"],[51,3,1,"","unacked_key"],[51,3,1,"","unacked_mutex_expire"],[51,3,1,"","unacked_mutex_key"],[51,3,1,"","unacked_restore_limit"],[51,3,1,"","visibility_timeout"]],"kombu.transport.redis.Transport.Channel.QoS":[[51,2,1,"","ack"],[51,2,1,"","append"],[51,2,1,"","pipe_or_acquire"],[51,2,1,"","reject"],[51,3,1,"","restore_at_shutdown"],[51,2,1,"","restore_by_tag"],[51,2,1,"","restore_unacked"],[51,2,1,"","restore_visible"],[51,4,1,"","unacked_index_key"],[51,4,1,"","unacked_key"],[51,4,1,"","unacked_mutex_expire"],[51,4,1,"","unacked_mutex_key"],[51,4,1,"","visibility_timeout"]],"kombu.transport.sqlalchemy":[[52,1,1,"","Channel"],[52,1,1,"","Transport"],[52,0,0,"-","models"]],"kombu.transport.sqlalchemy.Channel":[[52,4,1,"","message_cls"],[52,4,1,"","queue_cls"],[52,4,1,"","session"]],"kombu.transport.sqlalchemy.Transport":[[52,1,1,"","Channel"],[52,3,1,"","can_parse_url"],[52,3,1,"","connection_errors"],[52,3,1,"","default_port"],[52,3,1,"","driver_name"],[52,3,1,"","driver_type"],[52,2,1,"","driver_version"]],"kombu.transport.sqlalchemy.Transport.Channel":[[52,4,1,"","message_cls"],[52,4,1,"","queue_cls"],[52,4,1,"","session"]],"kombu.transport.sqlalchemy.models":[[52,1,1,"","Message"],[52,1,1,"","Queue"]],"kombu.transport.sqlalchemy.models.Message":[[52,3,1,"","id"],[52,3,1,"","payload"],[52,3,1,"","sent_at"],[52,3,1,"","version"],[52,3,1,"","visible"]],"kombu.transport.sqlalchemy.models.Queue":[[52,3,1,"","id"],[52,3,1,"","name"]],"kombu.transport.virtual":[[53,1,1,"","AbstractChannel"],[53,1,1,"","BrokerState"],[53,1,1,"","Channel"],[53,1,1,"","Message"],[53,1,1,"","QoS"],[53,1,1,"","Transport"],[54,0,0,"-","exchange"]],"kombu.transport.virtual.BrokerState":[[53,2,1,"","binding_declare"],[53,2,1,"","binding_delete"],[53,3,1,"","bindings"],[53,2,1,"","clear"],[53,3,1,"","exchanges"],[53,2,1,"","has_binding"],[53,2,1,"","queue_bindings"],[53,2,1,"","queue_bindings_delete"],[53,3,1,"","queue_index"]],"kombu.transport.virtual.Channel":[[53,3,1,"","Message"],[53,2,1,"","basic_ack"],[53,2,1,"","basic_cancel"],[53,2,1,"","basic_consume"],[53,2,1,"","basic_get"],[53,2,1,"","basic_publish"],[53,2,1,"","basic_qos"],[53,2,1,"","basic_recover"],[53,2,1,"","basic_reject"],[53,2,1,"","close"],[53,3,1,"","do_restore"],[53,2,1,"","drain_events"],[53,2,1,"","exchange_declare"],[53,2,1,"","exchange_delete"],[53,3,1,"","exchange_types"],[53,2,1,"","flow"],[53,2,1,"","get_table"],[53,2,1,"","message_to_python"],[53,2,1,"","prepare_message"],[53,3,1,"","qos"],[53,2,1,"","queue_bind"],[53,2,1,"","queue_declare"],[53,2,1,"","queue_delete"],[53,2,1,"","queue_purge"],[53,3,1,"","state"],[53,2,1,"","typeof"]],"kombu.transport.virtual.Message":[[53,5,1,"","MessageStateError"],[53,3,1,"","accept"],[53,2,1,"","ack"],[53,2,1,"","ack_log_error"],[53,4,1,"","acknowledged"],[53,3,1,"","body"],[53,3,1,"","channel"],[53,3,1,"","content_encoding"],[53,3,1,"","content_type"],[53,2,1,"","decode"],[53,3,1,"","delivery_info"],[53,3,1,"","delivery_tag"],[53,3,1,"","errors"],[53,3,1,"","headers"],[53,4,1,"","payload"],[53,3,1,"","properties"],[53,2,1,"","reject"],[53,2,1,"","reject_log_error"],[53,2,1,"","requeue"],[53,2,1,"","serializable"]],"kombu.transport.virtual.Message.MessageStateError":[[53,3,1,"","args"],[53,2,1,"","with_traceback"]],"kombu.transport.virtual.QoS":[[53,2,1,"","ack"],[53,2,1,"","append"],[53,2,1,"","can_consume"],[53,2,1,"","can_consume_max_estimate"],[53,2,1,"","get"],[53,3,1,"","prefetch_count"],[53,2,1,"","reject"],[53,3,1,"","restore_at_shutdown"],[53,2,1,"","restore_unacked"],[53,2,1,"","restore_unacked_once"],[53,2,1,"","restore_visible"]],"kombu.transport.virtual.Transport":[[53,3,1,"","Channel"],[53,3,1,"","Cycle"],[53,2,1,"","close_channel"],[53,2,1,"","close_connection"],[53,2,1,"","create_channel"],[53,3,1,"","cycle"],[53,3,1,"","default_port"],[53,2,1,"","drain_events"],[53,2,1,"","establish_connection"],[53,3,1,"","polling_interval"],[53,3,1,"","state"]],"kombu.transport.virtual.exchange":[[54,1,1,"","DirectExchange"],[54,1,1,"","ExchangeType"],[54,1,1,"","FanoutExchange"],[54,1,1,"","TopicExchange"]],"kombu.transport.virtual.exchange.DirectExchange":[[54,2,1,"","deliver"],[54,2,1,"","lookup"],[54,3,1,"","type"]],"kombu.transport.virtual.exchange.ExchangeType":[[54,2,1,"","equivalent"],[54,2,1,"","lookup"],[54,2,1,"","prepare_bind"],[54,3,1,"","type"]],"kombu.transport.virtual.exchange.FanoutExchange":[[54,2,1,"","deliver"],[54,2,1,"","lookup"],[54,3,1,"","type"]],"kombu.transport.virtual.exchange.TopicExchange":[[54,2,1,"","deliver"],[54,2,1,"","key_to_pattern"],[54,2,1,"","lookup"],[54,2,1,"","prepare_bind"],[54,3,1,"","type"],[54,3,1,"","wildcards"]],"kombu.transport.zookeeper":[[55,1,1,"","Channel"],[55,1,1,"","Transport"]],"kombu.transport.zookeeper.Channel":[[55,4,1,"","client"]],"kombu.transport.zookeeper.Transport":[[55,1,1,"","Channel"],[55,3,1,"","channel_errors"],[55,3,1,"","connection_errors"],[55,3,1,"","default_port"],[55,3,1,"","driver_name"],[55,3,1,"","driver_type"],[55,2,1,"","driver_version"],[55,3,1,"","polling_interval"]],"kombu.transport.zookeeper.Transport.Channel":[[55,4,1,"","client"]],"kombu.utils":[[56,0,0,"-","amq_manager"],[57,0,0,"-","collections"],[58,0,0,"-","compat"],[59,0,0,"-","debug"],[60,0,0,"-","div"],[61,0,0,"-","encoding"],[62,0,0,"-","eventio"],[63,0,0,"-","functional"],[64,0,0,"-","imports"],[65,0,0,"-","json"],[66,0,0,"-","limits"],[67,0,0,"-","objects"],[68,0,0,"-","scheduling"],[69,0,0,"-","text"],[70,0,0,"-","time"],[71,0,0,"-","url"],[72,0,0,"-","uuid"]],"kombu.utils.amq_manager":[[56,6,1,"","get_manager"]],"kombu.utils.collections":[[57,1,1,"","EqualityDict"],[57,1,1,"","HashedSeq"],[57,6,1,"","eqhash"]],"kombu.utils.collections.HashedSeq":[[57,3,1,"","hashvalue"]],"kombu.utils.compat":[[58,6,1,"","coro"],[58,6,1,"","detect_environment"],[58,6,1,"","entrypoints"],[58,6,1,"","fileno"],[58,6,1,"","maybe_fileno"],[58,6,1,"","nested"]],"kombu.utils.debug":[[59,1,1,"","Logwrapped"],[59,6,1,"","setup_logging"]],"kombu.utils.div":[[60,6,1,"","emergency_dump_state"]],"kombu.utils.encoding":[[61,6,1,"","bytes_to_str"],[61,6,1,"","default_encode"],[61,6,1,"","default_encoding"],[61,7,1,"","default_encoding_file"],[61,6,1,"","ensure_bytes"],[61,6,1,"","from_utf8"],[61,6,1,"","get_default_encoding_file"],[61,6,1,"","safe_repr"],[61,6,1,"","safe_str"],[61,6,1,"","set_default_encoding_file"],[61,6,1,"","str_to_bytes"]],"kombu.utils.eventio":[[62,6,1,"","poll"]],"kombu.utils.functional":[[63,1,1,"","LRUCache"],[63,6,1,"","dictfilter"],[63,6,1,"","is_list"],[63,1,1,"","lazy"],[63,6,1,"","maybe_evaluate"],[63,6,1,"","maybe_list"],[63,6,1,"","memoize"],[63,6,1,"","retry_over_time"]],"kombu.utils.functional.LRUCache":[[63,2,1,"","incr"],[63,2,1,"","items"],[63,2,1,"","iteritems"],[63,2,1,"","iterkeys"],[63,2,1,"","itervalues"],[63,2,1,"","keys"],[63,2,1,"","popitem"],[63,2,1,"","update"],[63,2,1,"","values"]],"kombu.utils.functional.lazy":[[63,2,1,"","evaluate"]],"kombu.utils.imports":[[64,6,1,"","symbol_by_name"]],"kombu.utils.json":[[65,1,1,"","JSONEncoder"],[65,6,1,"","dumps"],[65,6,1,"","loads"]],"kombu.utils.json.JSONEncoder":[[65,2,1,"","default"]],"kombu.utils.limits":[[66,1,1,"","TokenBucket"]],"kombu.utils.limits.TokenBucket":[[66,2,1,"","add"],[66,2,1,"","can_consume"],[66,3,1,"","capacity"],[66,2,1,"","clear_pending"],[66,2,1,"","expected_time"],[66,3,1,"","fill_rate"],[66,2,1,"","pop"],[66,3,1,"","timestamp"]],"kombu.utils.objects":[[67,1,1,"","cached_property"]],"kombu.utils.objects.cached_property":[[67,2,1,"","deleter"],[67,2,1,"","setter"]],"kombu.utils.scheduling":[[68,1,1,"","FairCycle"],[68,1,1,"","priority_cycle"],[68,1,1,"","round_robin_cycle"],[68,1,1,"","sorted_cycle"]],"kombu.utils.scheduling.FairCycle":[[68,2,1,"","close"],[68,2,1,"","get"]],"kombu.utils.scheduling.priority_cycle":[[68,2,1,"","rotate"]],"kombu.utils.scheduling.round_robin_cycle":[[68,2,1,"","consume"],[68,2,1,"","rotate"],[68,2,1,"","update"]],"kombu.utils.scheduling.sorted_cycle":[[68,2,1,"","consume"]],"kombu.utils.text":[[69,6,1,"","escape_regex"],[69,6,1,"","fmatch_best"],[69,6,1,"","fmatch_iter"],[69,6,1,"","version_string_as_tuple"]],"kombu.utils.time":[[70,6,1,"","maybe_s_to_ms"]],"kombu.utils.url":[[71,6,1,"","as_url"],[71,6,1,"","maybe_sanitize_url"],[71,6,1,"","parse_ssl_cert_reqs"],[71,6,1,"","parse_url"],[71,6,1,"","sanitize_url"],[71,6,1,"","url_to_parts"],[71,1,1,"","urlparts"]],"kombu.utils.url.urlparts":[[71,3,1,"","hostname"],[71,3,1,"","password"],[71,3,1,"","path"],[71,3,1,"","port"],[71,3,1,"","query"],[71,3,1,"","scheme"],[71,3,1,"","username"]],"kombu.utils.uuid":[[72,6,1,"","uuid"]],kombu:[[5,1,1,"","Connection"],[5,1,1,"","Consumer"],[5,1,1,"","Exchange"],[5,1,1,"","Producer"],[5,1,1,"","Queue"],[6,0,0,"-","abstract"],[7,0,0,"-","asynchronous"],[21,0,0,"-","clocks"],[22,0,0,"-","common"],[23,0,0,"-","compat"],[24,0,0,"-","compression"],[25,0,0,"-","connection"],[5,6,1,"","disable_insecure_serializers"],[5,6,1,"","enable_insecure_serializers"],[26,0,0,"-","exceptions"],[27,0,0,"-","log"],[28,0,0,"-","matcher"],[29,0,0,"-","message"],[30,0,0,"-","mixins"],[31,0,0,"-","pidbox"],[32,0,0,"-","pools"],[33,0,0,"-","resource"],[34,0,0,"-","serialization"],[35,0,0,"-","simple"],[36,0,0,"-","transport"]]},objnames:{"0":["py","module","Python module"],"1":["py","class","Python class"],"2":["py","method","Python method"],"3":["py","attribute","Python attribute"],"4":["py","property","Python property"],"5":["py","exception","Python exception"],"6":["py","function","Python function"],"7":["py","data","Python data"]},objtypes:{"0":"py:module","1":"py:class","2":"py:method","3":"py:attribute","4":"py:property","5":"py:exception","6":"py:function","7":"py:data"},terms:{"0":[3,5,9,11,15,16,20,21,23,25,29,30,31,32,33,38,39,41,44,47,48,50,51,52,53,69,71,73,74,76,79,80],"011":48,"0x101805650":79,"0x6fffff751710":76,"0x6fffff8547a0":76,"1":[3,5,7,11,13,18,19,22,25,30,31,37,38,39,40,44,47,48,50,52,53,55,63,66,71,73,74,75,76,82],"10":[5,7,13,17,18,30,31,38,42,43,50,51,59,74,79],"100":79,"100000":47,"120":39,"123":[37,38,40],"123456":38,"124":[37,38,40],"125":[37,38,40],"126":[37,38,40],"127":47,"1301013":3,"16":48,"18":[4,77],"1800":[37,38],"2":[3,4,5,19,21,25,38,48,50,63,71,73,77,80,81],"20":[9,38],"200":[15,16,52],"2012":79,"2022":[4,77],"2181":55,"2379":43,"24":[7,18],"25":51,"256":48,"26379":[51,73],"26380":51,"27017":47,"2nd":38,"2s":80,"3":[3,5,19,21,25,38,39,43,48,51,71,73,74,76],"30":[9,15,16,39,42,43,63,80],"300":51,"3000":[5,25],"320":38,"33":[37,38,40],"34":[37,38,40,81],"35":[37,38,40],"354":[5,25],"36":[37,38,40],"3600":51,"37":[37,38,40],"38":[37,38,40],"39":[37,38,40],"3rd":38,"4":[3,5,7,18,38,48,51,71,73],"40":[37,38,40],"403":48,"404":[15,16,48],"41":[37,38,40],"42":[37,38,40],"43":[37,38,40],"44":[37,38,40],"443":9,"45":[37,38,40],"46":[37,38,40],"47":[37,38,40],"4th":38,"5":[3,4,5,21,25,38,39,48,71,77],"500":[15,16],"503":48,"507":48,"511490":66,"530":48,"540":48,"5671":[48,50],"5672":[5,25,48,73,75,76,79,82],"58":[37,38,40],"59":[37,38,40],"5th":38,"6":[9,15,16,38,50,51,69,71,81],"60":[37,38,39,40],"61":[37,38,40],"62":[37,38,40],"63":[37,38,40],"6379":[51,73,79],"64":[37,38,40],"640":38,"6th":38,"7":50,"8":[3,34,39,61,73,81],"80":[9,38],"8500":42,"9":[5,23,32,48,50,51,80],"900":38,"9090":49,"91":[37,38,40],"92":[37,38,40],"93":[37,38,40],"94":[37,38,40],"95":[37,38,40],"96":[37,38,40],"abstract":[4,53],"boolean":[48,52,81],"byte":[5,15,16,34,48,61],"case":[5,23,25,33,34,38,48,50,51,63,74,79,80,81],"catch":63,"class":[4,5,7,9,11,12,13,15,16,17,18,19,20,21,22,23,25,27,28,29,31,32,33,35,36,37,38,39,40,42,43,44,46,47,48,49,50,51,52,54,55,57,59,63,64,65,66,67,68,71,73,75,76,77,80,81,82],"default":[3,5,9,14,15,16,22,23,25,28,29,30,32,33,34,36,38,39,41,48,50,51,52,53,54,58,61,64,65,73,74,77,80,81],"do":[3,5,19,25,38,39,48,50,53,71,73,79,81,82],"enum":[5,23,32,80],"final":[5,25,31,48,50],"float":[5,9,15,16,21,22,23,25,32,33,39,48,63,66,69,70,80,81],"function":[4,5,7,18,20,21,22,23,24,25,28,48,50,52,60,65,72,74,75,76,79,80,81],"import":[3,4,5,22,25,30,38,44,48,51,73,74,75,76,78,79,80,81,82],"int":[5,9,15,16,20,21,22,23,25,29,32,38,39,41,48,50,53,63,70,71,74,80],"long":[5,48,50,63,64,76,78],"new":[3,5,15,23,24,25,28,32,33,34,38,39,48,50,62,63,74,76,78,79,81],"null":48,"public":[5,25,32,50],"return":[5,8,14,21,23,24,25,28,29,30,31,32,34,38,41,43,47,48,50,53,54,58,63,65,66,70,71,74,75,76,78,80,81],"short":[38,48,64],"static":39,"super":[30,76],"switch":[5,25],"transient":[5,25,46,48,49,50,78,82],"true":[3,5,9,15,16,22,23,25,28,29,30,31,32,33,35,38,39,40,41,44,46,47,48,50,51,52,53,54,63,64,65,66,73,74,75,76,79,80,82],"try":[5,23,25,26,30,31,38,63,64,65,74,75,76],"typeof":[50,53],"void":61,"while":[3,5,23,30,31,48,50,63,74,76,80,82],A:[3,5,9,15,16,21,23,24,25,28,32,34,48,50,73,74,78,80,81],AND:5,As:[39,50],At:48,But:[73,76],By:[5,22,23,32,48,51,63,74,79,80,81],For:[3,5,22,25,34,38,48,50,52,63,65,72,73,76,78],IN:48,If:[3,5,9,15,16,19,20,22,23,25,28,29,33,34,36,38,39,41,48,50,51,53,63,64,66,73,74,78,79,81,82],In:[3,4,34,38,48,50,63,74,76,78,80,81,82],It:[3,5,21,22,30,42,43,48,50,53,74,78,82],NOT:48,No:[3,37,38,44,46,49,51,55,73,79],Not:[5,15,16,25,48,50],OR:5,Of:73,On:[21,48],One:[5,25,50,78],Or:3,That:[48,79],The:[3,5,9,15,16,19,21,23,24,25,26,28,29,30,32,34,36,38,39,41,48,49,50,51,52,53,54,55,63,64,66,73,74,76,77,78,80,81,82],Then:81,There:[3,73,79],These:[3,5,25,38,48,50,79],To:[3,5,48,49,51,53,54,73,79,81],Will:[5,21,34],With:[5,23,74],_:[3,5,22,74],__cmp__:63,__eqhash__:57,__init__:[30,50,74,75,76,82],__len__:35,__main__:[75,82],__name__:[75,82],__repr__:63,__str__:63,__traceback__:[23,48,53],__version__:43,_attr:13,_broker:50,_callback:50,_close:5,_decod:[29,41,48,53],_dump:65,_ensure_connect:[5,25],_get:50,_kombu:51,_load:65,_management_cli:39,_messag:48,_publish:50,_purg:50,_put:50,_pycurl:17,_queue:[7,18],_queue_bind:54,_servicebus_cli:39,_token:30,_trusted_cont:34,_uuid:[22,72],_waiter:19,a_glob:48,aaa:38,abandon:48,abc:[63,71],abcast:31,abil:[3,81],abl:[5,22,76,79],about:[2,5,38,39,40,50,52,74,79],abov:[3,38,50,78,81,82],abstractchannel:53,accept:[5,9,12,15,16,19,23,29,30,31,34,35,41,44,48,50,53,74,75,76,81],access:[5,15,16,19,25,38,39,40,48,50,53,63,66,81],access_key_id:38,accident:[48,50],accomplish:50,accord:[22,50],accordingli:38,account:40,achiev:78,ack:[3,5,29,30,41,44,48,50,51,53,74,75,76,82],ack_emul:51,ack_log_error:[29,48,53],acknowledg:[5,23,25,26,29,30,35,37,38,39,41,48,50,51,53,74],acquir:[5,19,25,33,50,75,79],across:[3,48],action:[5,25,48,50],action_nam:[11,13],activ:[5,14,23,25,48,50,53,74,79],active_queu:51,activest:66,actual:[5,25,36,50,53,78,80],ad:[5,23,25,48,50,74],add:[3,5,7,18,23,27,28,50,66,74,81],add_consum:23,add_consumer_from_dict:23,add_permiss:[11,13],add_queu:[5,23,74],add_read:[7,18],add_request:17,add_writ:[7,18],addit:[5,22,23,25,28,32,35,38,48,50,73,74,80,82],address:[5,25,78],adher:[50,53],adjust:[21,38,50],administr:48,advanc:[3,5,23,48,77],advantag:[5,81],affect:[3,5,23,48,50,74],after:[3,5,6,15,16,21,23,25,30,32,33,38,46,48,49,50,73,74,79,80],after_reply_message_receiv:[46,48,49],afterward:[5,25],again:[63,74,76],against:[76,79],agent:[9,15,16],ago:78,agre:48,aid:48,aim:3,aio:51,algorithm:[3,5,66],alia:[5,9,22,24,26,36,38,51,71],alias:[24,36,64,73],all:[3,5,11,13,15,16,23,25,32,33,38,39,41,44,46,48,49,50,51,53,54,55,59,63,73,74,78,81],allocate_lock:21,allow:[3,5,9,15,16,23,25,38,48,50,53,74],allow_nan:65,almost:81,along:[5,23,32,50,80,81],alphabet:51,alreadi:[3,5,6,20,21,23,26,29,32,38,41,48,50,53,74,80],also:[3,5,9,15,16,19,22,23,25,30,33,38,48,50,51,66,73,74,76,78,79,80,81],alter:38,altern:[5,23,25,48,73,74,81],although:[5,23,48,50,74],alwai:[3,5,22,25,48,50,51,73],amazon:[3,4,11,12,13],amazonaw:38,amount:50,amq:[3,4,48],amq_manag:4,amqp:[3,4,5,6,23,25,32,34,37,38,39,40,41,42,43,44,46,47,49,50,51,52,55,56,74,75,76,77,78,79,80,82],amqplib:3,an:[3,5,6,7,15,16,18,21,22,23,25,28,33,34,36,38,48,49,50,51,53,54,55,63,66,68,74,79,80,81,82],ani:[3,5,19,21,22,23,25,27,32,34,48,50,51,53,54,66,68,71,74,79,80,81],annot:27,announc:48,annoy:3,anonym:50,anoth:[5,39,48,50,78],answer:1,anyon:78,anystr:24,anyth:[79,81],anywai:78,ap:38,apach:[4,55,73],api:[2,5,25,42,43,55,56],app:79,appear:50,append:[50,51,53],appli:[5,7,18,19,23,25,28,38,48,74],applic:[3,5,30,34,48,50,61,74,76,78,79,81],apply_backoff_polici:38,apply_entri:20,apply_glob:[5,23,53,74],appropri:50,approxim:[5,25],approximatenumberofmessag:13,approximatereceivecount:[11,38],ar:[3,5,19,22,23,25,30,38,39,44,48,50,53,54,73,74,76,78,79,80,81],arbitrari:[5,23,32,48,50,65,80],arbitrarili:50,aren:[79,80],arg:[5,6,7,13,18,20,22,23,25,27,32,37,38,39,40,42,43,48,50,51,53,55,61,62,63,75,76,81],argsig:48,argument:[5,7,9,15,16,18,19,22,23,25,28,29,30,31,32,38,41,47,48,50,51,53,54,63,74,77,79,80,81,82],aris:82,arn:38,around:[5,22,25,81],arriv:50,articl:[3,5,79],as_dict:5,as_uri:[5,25,39,79],as_url:71,asap:[7,18],ascii:[34,50],asdf:50,ask:[2,5,23,48,50,74],aspn:66,assert:5,assertionerror:50,assign:[48,50],associ:[5,21,24,48,50,73],assum:[5,29,38,41,48,50],async:[4,9,11,12,13,20,31],async_pool:51,asyncconnect:9,asynchron:[38,43,46,47,48,50,51],asynchttprespons:9,asynchttpsconnect:9,asyncmessag:[12,13],asyncqueu:13,asyncrawmessag:12,asyncsqsconnect:11,asynsq:38,attapattu:5,attempt:[5,23,38,48,50,74],attr:[5,22],attribut:[3,9,11,13,15,16,23,30,38,50,54,74,81],auth_mod:[9,15,16],auth_password:[9,15,16],auth_usernam:[9,15,16],authent:[9,15,16,38,48],authentication_failure_clos:48,authenticationerror:51,authenticationfailur:50,author:3,auto:[5,22,23,25,32,48,50,80,81],auto_declar:[5,23,32,74,80],auto_decod:48,auto_delet:[5,22,23,48,50,53,54],autodetect:50,automat:[2,3,5,23,25,32,38,41,48,50,73,74,77,80,81],autoretri:[5,25,76],avail:[3,5,9,15,16,19,23,24,25,28,33,34,38,48,50,66,73,74,76,78,79],avi:3,avoid:[5,23,48,74,76],aw:[4,38],awai:[78,79],aws_access_key_id:8,aws_account_id:[11,13],aws_secret_access_kei:8,awssimplequeueservic:38,azur:[3,4],azureservicebu:4,azurestoragequeu:4,b:38,back:[29,41,44,48,50,53,73,78,79],backend:[23,46,54],backoff:[38,39],backoff_polici:38,backoff_task:38,backward:[5,25,50,51],bad:78,ban:48,band:48,bank:78,bar:[5,25],base64:[12,50,81],base:[4,12,29,34,44,46,49,50,54,55,65],baseasyncmessag:12,baseexcept:63,basi:81,basic:[1,5,9,15,16,23,30,32,48,77,82],basic_ack:[37,38,39,48,50,53],basic_cancel:[37,38,39,48,50,51,53],basic_consum:[37,38,39,40,48,50,51,53],basic_drain:50,basic_get:[48,50,53],basic_messag:48,basic_publish:[48,50,53],basic_publish_confirm:48,basic_qo:[48,50,53],basic_recov:[48,53],basic_recover_async:48,basic_reject:[48,50,53],bbb:38,beat:31,becaus:[5,48,50],becom:[50,55],been:[3,5,6,9,15,16,23,25,26,29,30,32,33,41,48,50,53,63,74,80],befor:[3,5,9,15,16,21,23,25,32,38,39,40,48,50,63,76,79,80],behalf:48,behavior:[38,50],behaviour:48,being:[29,38,41,48,50,51,53,55],belong:48,below:[50,75,76],benefit:50,best:[3,22,48,69,73,79,81],better:[5,29,41,81],between:[5,21,23,25,32,37,38,39,40,43,46,47,48,50,51,53,55,63,68,80],binari:[5,29,34,41,50,74,81],bind:[3,5,6,22,23,47,48,50,51,53,54,74,80],bind_to:5,binding_argu:[5,22],binding_declar:53,binding_delet:53,bit:[48,81],blank:[5,29,41,48,50],block:[5,7,18,25,33,35,48,50,74,75,76,79,82],blocking_read:48,blog:5,bodi:[3,5,9,12,15,16,23,24,29,30,31,32,34,41,44,48,50,53,74,75,76,80],body_encod:[47,50,51],bool:[5,9,15,16,22,23,25,29,32,33,38,39,41,50,51,66,71,74,80],both:[3,5,22,25,38,44,48,50,80,81,82],botocor:38,botocoreerror:38,bound:[3,5,6,19,22,31,48,50,54],bound_exchang:[3,5],bound_science_new:5,broadcast:[22,31,47,54,78],broadcast_collect:47,broken:76,broker1:[48,76],broker2:[48,76],broker:[3,5,22,23,25,29,39,41,48,49,50,51,53,73,74,75,76,78,79,80,81],broker_address:48,broker_login_method:50,broker_transport_opt:[38,50],brokerag:50,brokerst:[44,46,49,53],brpop:51,bsb:48,bsbb:48,bsbbb:48,bsbbbbbf:48,bsd:3,bssbb:48,bssbbbbbf:48,bssbbbbf:48,bsssbf:48,bsssf:48,bu:[3,4],bucket:66,buffer:[5,9,15,16,23,25,34,50,74,82],bug:2,build:[3,50],built:[3,4,5,7,18,20,21,29,41,50,55,60,65,78,81],builtin:[5,38],bulk:53,bye:75,bytes_recv:48,bytes_s:48,bytes_to_str:61,bytesio:81,bzip2:75,c1:[5,25,79],c2:[5,25,79],c3:[5,25],c:[38,51,73,74,76],ca:[9,15,16],ca_cert:[5,9,15,16,25,48],ca_certfil:48,cach:[5,15,16,22,25,63,67],cached_properti:67,calc_queue_s:47,call:[3,5,6,7,9,15,16,18,21,23,25,26,28,30,31,32,38,46,48,49,50,53,57,59,63,65,66,68,73,74,76,78,79,80,82],call_aft:20,call_at:[7,18,20],call_lat:[7,18],call_repeatedli:[7,18,20],call_soon:[7,18],callabl:[5,9,15,16,19,21,24,25,32,34,48,50,63,68,74,80],callback:[3,5,6,7,9,11,13,14,15,16,18,19,20,22,23,25,30,31,32,38,44,46,48,49,50,53,63,68,74,75,76,80,82],callback_for:14,caller:50,can:[3,5,6,21,22,23,25,30,32,33,36,37,38,40,41,42,43,44,46,47,48,49,50,51,52,53,55,61,63,66,73,74,76,78,79,80,81,82],can_cache_declar:[5,6],can_consum:[50,53,66],can_consume_max_estim:[50,53],can_parse_url:[39,47,52],cancel:[3,5,20,23,30,31,37,38,39,46,48,49,50,51,53,74],cancel_by_queu:[5,23,74],cancer:5,cannot:[5,25,34,38,48,50],canonical_queue_nam:38,capabl:[48,50],capac:[50,66],capped_queue_s:47,care:79,carefulli:81,carrot:[3,4],cast:31,caus:[48,50,81],celeri:[3,38,39,50,64],celerybeat:31,celeryev:50,cellular:79,central:[34,78],cert:[5,25],cert_req:[5,25],cert_requir:[5,25],certain:[50,53],certfil:[5,25,48],certif:[9,15,16,50],chanc:68,chang:[19,23,38,48,50,51,53,74,79,81],change_message_vis:11,change_message_visibility_batch:[11,13],channel1:74,channel2:74,channel:[3,5,6,12,22,23,25,26,29,30,31,32,35,41,54,73,74,75,76,80,81,82],channel_error:[5,25,30,38,41,47,48,50,51,55],channel_id:48,channel_max:48,channel_or_connect:3,channelerror:[38,41,47,48,51,55],channellimitexceed:[5,25,26],channelpool:[5,25],channelt:[5,25,29,32,41,53,54,74,80],charact:[3,5,29,34,41,50,54],characterist:81,check:[5,25,38,48,50,66,73],check_circular:65,choic:[5,81],choos:73,circular:50,cjson:81,cl:65,claim:39,class_id:48,classic:48,classmethod:[5,39],classnam:64,clean:[50,79],clear:[13,19,20,35,50,53],clear_pend:66,clearinghous:78,client:[3,4,5,9,12,23,25,37,39,40,41,44,46,47,48,49,50,51,52,53,55,56,73,74,75],client_cert:[9,15,16],client_heartbeat:48,client_kei:[9,15,16],client_properti:48,clock:[4,31],clone:[5,25],close:[3,5,7,9,17,18,23,25,32,33,35,38,39,41,46,48,49,50,51,53,68,73,74,75,79,82],close_after_fork:[32,33],close_channel:[41,50,53],close_connect:[41,48,50,53],close_resourc:[32,33],cluster:76,cn:50,co:58,code:[15,16,48,50,66,79],codec:[50,61],collect:[4,22,25,32,48,50,53,63,71],collect_repli:22,collect_resourc:33,colon:[5,25],column:52,columndefault:52,com:[3,5,38,39,40,48,50,66,74,76],combin:48,come:[50,51,78,82],command:[22,31,48,49,50],commit:48,common:[3,4,5,30],commun:[50,78],compar:[5,25],comparison:[2,77],compat:[3,4,5,25,50,51,74,81],compil:73,complet:[5,15,16,22,25,38,48,50],completes_cycl:[5,25],compon:71,compress:[3,4,5,9,15,16,23,32,35,74,75,79,80,82],concept:3,conceptu:21,concern:81,concurr:[19,64],condit:48,configur:[3,5,22,23,25,29,32,38,41,48,50,52,80],confirm:48,confirm_publish:48,confirm_select:48,confirm_timeout:48,conn1:79,conn2:79,conn:[3,5,22,25,44,48,74,75,76,79,80,81,82],conn_or_acquir:51,conn_str:[5,25],connect:[2,3,4,6,8,13,15,16,22,23,26,30,31,33,38,41,53,74,75,77,80,82],connect_max_retri:30,connect_sq:8,connect_timeout:[5,9,15,16,25,38,47,48,73],connection_class:51,connection_class_ssl:51,connection_error:[5,25,30,37,38,41,47,48,50,51,52,55],connection_info:31,connection_opt:50,connectionerror:[37,38,41,47,48,50,51,55],connectionfailur:47,connectionforvc:48,connectionlimitexceed:[5,25,26,79],connectionpool:[5,25,79],connectiont:53,conninfo:[37,38,39,40],consid:[5,21,50],consist:[3,5],consolid:[7,18,50],constant:[53,71],constantli:[5,25],constrain:48,constraint:81,constructor:[5,25,31,48,53],consul:4,consul_address:42,consult:[5,25,36,73],consum:[2,3,4,22,25,30,31,35,37,38,39,40,44,46,48,49,50,51,53,55,66,75,77,78,81,82],consumer_argu:[5,22,74],consumer_cancel_notifi:48,consumer_context:30,consumer_count:50,consumer_tag:[5,37,38,39,48,50,51,53],consumermixin:[30,74,75,76],consumerproducermixin:[30,74],consuming_from:[5,23,74],consumpt:55,contact:76,contain:[5,21,34,40,48,50,51,53,64,74,76],content:[2,5,9,15,16,23,32,34,48,50,74,78,80,81],content_encod:[5,12,23,29,32,34,41,48,50,53,80,81],content_typ:[5,12,23,24,29,32,34,41,48,50,53,80,81],contentdisallow:[5,23,34,74],context:[30,31,48,50,58,73,82],contextlib:82,contribut:2,control:[5,23,48,74],conveni:[22,30,34,79,81],convers:54,convert:[5,20,25,48,50,53,61,69,70],convienc:28,cookbook:66,coordin:78,copi:[5,6,25,54,71],coro:58,correct:[48,50],correctli:[48,50],correlation_id:[30,74],correspond:[38,50,53,54],cost:[48,78],could:[48,50,65,78,80,81],count:[13,23,48,50,53,74],count_slow:13,counter:[21,48],courag:78,cours:73,cover:[5,50],coverag:79,craft:81,crash:61,creat:[5,6,15,22,25,32,38,39,44,48,50,62,73,74,76,77,79,80,82],create_channel:[41,48,50,53],create_connect:30,create_engin:52,create_loop:[7,18],create_produc:32,create_queu:11,create_transport:[5,25],createqueu:38,creation:38,creator:50,cred:38,credenti:[38,50],criteria:5,critic:[27,66,78],cross:81,crt:[5,25],cure:5,curl:[4,9,15,16],curlclient:17,current:[5,6,7,18,21,23,25,31,32,35,47,48,50,51,53,55,58,74,76,79,80,82],custom:[3,4,5,7,9,15,16,18,22,25,29,38,41,65,73,77,81],customis:39,cutekitten:82,cycl:[5,25,48,51,53,68,76,81],d:[20,38,53,63],daemon:[39,49],dai:78,data:[5,9,25,28,31,34,48,50,53,74,77,82],data_folder_in:44,data_folder_out:44,data_in:44,data_out:44,databas:[51,52,73],dataerror:51,datastructur:20,date:[4,48,65,77,81,82],datetim:[20,52,65,75,82],db:[3,5,51],dead:[5,48],deadletter_queu:[47,51],deadlock:79,debug:[4,11,27,75],decid:5,decim:[65,81],declar:[3,5,6,22,23,25,32,35,44,48,50,53,73,74,75,76,79,80],declared_ent:[5,25],decod:[5,12,23,29,30,34,41,48,50,53,74,81],decode_bodi:50,decode_byt:65,decoder_funct:81,decompress:[5,23,24,74],decor:[5,25,32,58,63],def:[3,5,22,25,30,31,44,65,74,75,76,81,82],default_channel:[5,25,44,74],default_connection_param:[38,48,50],default_databas:47,default_encod:61,default_encoding_fil:61,default_hostnam:47,default_kwarg:65,default_match:28,default_peek_lock_second:39,default_port:[9,37,38,39,40,41,42,43,44,47,48,49,51,52,53,55],default_region:38,default_retry_backoff_factor:39,default_retry_backoff_max:39,default_retry_tot:39,default_ssl_port:48,default_timezon:20,default_transport:36,default_uamqp_keep_alive_interv:39,default_visibility_timeout:[37,38],default_wait_time_second:[38,39],defect:33,defin:[3,5,6,22,23,30,41,48,50,53,54,58,74,76,78,80,82],defualt:[5,23,32,80],delai:[7,18,38,48],delay_second:[11,13],delet:[3,5,13,22,23,25,38,39,46,47,48,49,50,53,67,74],delete_messag:[11,13,37],delete_message_batch:[11,13],delete_message_from_handl:11,delete_queu:11,delimit:5,deliv:[3,5,23,48,50,54,74,78,80],deliveri:[5,29,41,48,50,78],delivery_info:[12,29,41,48,50,53],delivery_mod:[5,23,29,32,41,80],delivery_tag:[12,29,37,38,39,41,48,50,51,53],delta:63,depend:[3,5,25,26,48,50,73],deploi:78,deprec:48,depth:50,dequ:38,describ:[5,34],descript:[5,14],descriptor:[50,51],deseri:[5,29,34,41,48,53,65,74,81,82],design:[5,48,50],desir:81,despit:22,dest:[5,25,48,76],dest_wild:48,destin:[5,15,16,31,48,80],detail:[3,50,52],detect:[5,23,32,48,58,80,81],detect_environ:58,determin:[5,48,50],develop:3,di:[5,48],dialogu:[5,48],dict:[5,9,15,16,22,23,25,29,32,34,38,39,41,48,50,57,63,64,71,73,80],dictfilt:63,dictionari:[38,50,80,81],did:[1,48],didn:78,differ:[30,38,48,50,51,73,74,75,80,82],digest:[9,15,16],direct:[3,5,23,31,37,38,39,40,42,43,44,46,47,48,49,50,51,52,53,55,73,74,75,78,80],directexchang:[53,54],directli:[19,49,50,53,74,80],directori:[3,44],disabl:[3,5,23,25,32,35,48,50,51,53,73,74,79,80],disable_insecure_seri:5,disable_untrusted_seri:[23,74],disadvantag:81,discard:[29,41,48,53,63],discard_al:23,disconnect:48,discoveri:51,disk:[5,78],dispatch:[5,23,31,74],dispatch_from_messag:31,dispatch_method:48,displai:39,distribut:[3,21,48],div:4,django:65,do_restor:[46,53],doc:[38,55],document:[5,23,25,38,48,50,52,73],doe:[3,5,23,25,36,39,48,50,55,63,64,74],doesn:48,domain:[3,5],domain_format:[37,38,39,40],domest:79,don:[3,5,23,74,80,81],done:[5,23,29,41,50,74],dot:[3,5,51,54,64],doubli:63,down:[5,23,38,48,74],download:3,drag:79,drain:[5,22,30,32,50,53,76,80],drain_consum:22,drain_ev:[3,5,22,25,31,38,41,44,48,50,53,74,76],dramat:38,driver:[38,42,43,44,46,47,48,49,50,51,52,55],driver_nam:[38,42,43,44,46,47,48,49,50,51,52,55],driver_typ:[38,42,43,44,46,47,48,49,50,51,52,55],driver_vers:[42,43,44,46,47,48,49,51,52,55],drop:[5,48,50],due:[37,38,41,47,48,50,51,52,55],dummylock:19,dump:[13,34,60,65,81],dump_entri:82,duplic:48,durabl:[3,5,22,23,25,48,50,53,54,80],durat:5,dure:[5,23,32,38,50,76,80],dynam:51,e:[5,9,15,16,21,25,33,34,36,38,42,43,44,46,47,48,49,50,51,52,55,63,73,74,76],each:[5,21,25,38,48,50,51,53,63,68,74,78,81],earli:79,earlier:[1,50],easi:3,easier:73,easili:[3,81],east:38,easy_instal:3,effect:[48,50],effective_url:[15,16],either:[3,5,25,29,36,41,48,50,51,63,78],element:[21,63],els:[51,65],email:78,emergency_dump_st:60,emit:61,empti:[5,7,13,18,38,48,50,63,80],emul:[48,51],en:[39,40,55,66],en_u:48,enabl:[3,5,9,15,16,23,25,32,35,38,48,51,53,73,74,80,81],enable_callback:23,enable_insecure_seri:5,encapsul:50,encod:[3,4,5,12,23,29,32,34,41,48,50,65,80,81,82],encode_bodi:50,encoder_funct:81,encourag:[3,73],encrypt:[38,48],end:[5,23,38,48,50,68,74],endhead:9,endpoint:50,endpoint_url:38,engin:52,enough:1,ensur:[3,5,6,22,23,25,32,50,53,61,73,76,80],ensure_ascii:65,ensure_byt:61,ensure_connect:[5,25],ensure_opt:[5,25],enter:[20,30],enter_aft:20,enter_at:20,entir:50,entiti:[5,6,22,23,25,26,32,74,80],entity_nam:[37,38,39,40],entityt:[5,23,32,80],entri:[20,55,66,77,82],entry_point:81,entrypoint:[58,81],environ:[22,38,50,58,81],ephemer:[5,25,35],epol:50,eq:57,eqhash:57,equal:[5,23,48,51,68,74],equalitydict:57,equival:[15,16,48,54,82],err:[7,18],errback:[5,9,15,16,22,25,63,76],error:[3,5,7,15,16,18,22,25,27,29,30,37,38,41,47,48,50,51,52,53,55,61,75,76,82],escap:69,escape_regex:69,especi:80,essenti:48,establish:[5,6,25,30,41,48,50,73],establish_connect:[30,41,48,50,53],estim:[50,53,66],eta:20,etc:[3,5,25,38,42,43,44,46,47,48,49,50,51,52,55,57,73,81],etcd:4,eur:[3,5],evalu:[15,16,29,41,48,53,63],even:[3,5,19,22,34,48,50,73],event:[3,4,5,21,22,25,30,32,46,50,51,53,76,80],eventio:4,eventlet:[30,58],eventloop:22,eventu:50,ever:[5,48,50],everi:[3,5,9,15,16,22,25,30,38,63,74,78,79,80,81],exact:54,exactli:50,exampl:[2,3,5,19,22,25,28,30,34,38,44,48,50,51,52,54,64,65,73,74,76,77,78,79,81,82],exc:[5,7,18,23,25,30,52,63,74,75,76],exc_info:[5,20,25,76],exce:[5,80],exceed:[5,25,26,33,50,63],excel:82,except:[3,4,5,15,16,23,25,28,29,30,32,33,37,38,41,47,48,50,51,53,55,61,63,65,68,74,75,76,79,80,81],exchang:[3,4,22,23,25,30,31,32,35,44,46,47,48,50,51,53,73,74,75,78,79,81,82],exchange_bind:48,exchange_declar:[48,50,53],exchange_delet:[48,50,53],exchange_nam:[50,74],exchange_opt:[5,25,35],exchange_typ:[23,25,38,43,46,47,48,50,51,53],exchange_unbind:48,exchangetyp:[53,54],exclud:[51,54],exclus:[5,22,23,48,50],execut:[49,76],exist:[5,33,38,48,50],exit:[7,18,39],expect:[48,50,78],expected_tim:66,experi:50,experienc:39,experiment:[5,25],expir:[5,22,23,32,38,80],expiri:5,explan:50,explicit:[50,51],explicitli:[5,48,50,73,81],exponenti:39,express:[69,81],ext:38,extens:[5,25,48,73,74,77],extern:[5,25,50],extra:[22,30,50],extra_context:30,extract_task_name_and_number_of_retri:38,f:[21,58,63,75],facil:48,fact:79,factor:39,factori:50,fail:[48,50,76],failov:[2,5,25,48,77],failover_strategi:[5,25,76],failur:[5,22,25,30,37,38,41,47,48,50,51,52,55,76,80],failver:76,faircycl:[53,68],fairli:[53,81],fall:[5,23,48,73,74],fallback:73,fals:[5,6,7,11,15,16,18,22,23,25,28,29,30,32,33,34,38,39,41,43,46,47,48,50,51,52,53,63,65,71,73,74,80],famili:78,familiar:3,fan:3,fanout:[3,5,31,37,38,39,40,42,43,44,46,47,48,49,50,51,52,53,55,73,78],fanout_pattern:51,fanout_prefix:51,fanoutexchang:[53,54],far:[48,78],fast:[38,81],faster:78,fastest:78,fd:[7,14,17,18],fdel:67,featur:[2,5,32,80],feet:79,fetch:[21,23,48,50],fget:67,fh:81,fib:74,field:[5,48,50,71,73],fifo:[19,38],file:[3,4,5,9,15,16,25,50,51,58,60,61,81],filenam:[9,15,16,82],fileno:[51,58],filesystem:4,fill:[48,51,53],fill_rat:66,filterfunc:23,find:[5,23,48,69,74],fine:78,finish:[5,23,48,50,74],fire_tim:[7,18],first:[5,13,19,21,25,33,41,50,51,64,80],fit:[78,81],fix:3,flag:[5,6,7,14,18,23,32,35,46,47,48,50,51,53,74,80,81],flow:[5,23,48,53,74],fmatch_best:69,fmatch_it:69,focus:38,follow:[3,5,9,15,16,21,23,32,38,39,40,42,43,44,46,48,50,51,53,63,74,76,80,81],follow_redirect:[9,15,16],foo:[5,25,30,52,73],forc:[5,25,29,32,33,34,41,48,53],force_close_al:[25,33],force_delet:11,forev:[22,25,33,63,79],forget:73,forgotten:50,fork:[25,33,52,79],form:[5,25,49,50,61,74],formal:48,format:[5,22,30,37,38,39,40,42,43,44,46,48,51,72,73,74,76,79,81],former:82,forward:[5,21,30,48],found:[3,5,15,16,28,34,48,50],four:[3,5],frame:48,frame_handl:48,frame_max:48,frame_writ:48,frequent:[2,48],from:[3,5,7,9,15,16,18,21,22,23,25,28,29,33,35,37,38,39,40,41,44,48,50,51,53,55,58,61,63,64,65,66,68,71,73,75,76,78,79,80,81,82],from_dict:[5,23],from_transport_opt:[47,51],from_utf8:61,fromtimestamp:82,front:50,frozenset:[34,38,43,46,47,48,50,51],fset:67,full:[3,5,15,16,25,36,64,74,76],fulli:36,fun:[5,20,22,25,30,31,63,68,75],further:38,fuzzi:69,g:[5,9,15,16,21,25,33,34,36,38,42,43,44,46,47,48,49,50,51,52,55,73,74,76],gain:81,gc:53,gen:58,gener:[4,5,7,18,22,31,33,48,50,57,58,71,72],generate_sts_session_token:38,get:[2,5,7,9,13,15,16,18,22,24,25,27,32,35,36,47,48,50,51,53,54,56,58,61,64,68,75,79,80,82],get_all_queu:11,get_attribut:13,get_bind:48,get_consum:[30,74,75,76],get_dead_letter_source_queu:11,get_decod:24,get_default_encoding_fil:61,get_encod:24,get_event_loop:[7,18],get_heartbeat_interv:[25,48],get_http_connect:9,get_limit:[32,79],get_logg:[27,75],get_loglevel:27,get_manag:[5,25,48,56],get_messag:13,get_now:47,get_nowait:35,get_qpid_connect:50,get_queu:[11,31],get_queue_attribut:11,get_queue_url:11,get_reply_queu:31,get_tabl:[47,51,53,54],get_timeout:13,get_transport_cl:[5,25,36],getfield:[5,25],gethostnam:82,getrequest:9,getrespons:9,getter:50,gevent:[30,58],gimm:38,girlfriend:78,github:[3,74],give:[5,23,25,48,50,63,74,79,80],given:[5,21,25,50,71],glob:28,global:[5,23,34,46,51,74,79,81],global_keyprefix:51,global_st:[44,46,49],globe:78,goal:38,goe:[46,53],good:[80,81],got:[30,75,79],gracefulli:3,grant:48,great:78,greater:[21,53],greenthread:30,group:[32,51,77],grow:[19,79],guarante:[38,48,53],guest:[3,5,25,48,73,75,76,79,82],guid:2,gzip:[9,15,16],h:[14,21],ha:[3,5,6,9,15,16,21,23,25,26,29,33,38,39,40,41,42,43,48,50,51,53,55,63,74,79,81],had:78,hand:78,handl:[3,5,22,23,25,31,48,50,51,74,76,80],handle_cal:31,handle_cast:31,handle_error:20,handle_messag:[30,31],handler:[30,31,50,74],happen:[3,5,23,32,37,38,41,47,48,50,51,52,55,78,80,82],hard:[50,78],harder:73,has_bind:53,hash:[3,5,57],hashedseq:57,hashvalu:57,have:[3,5,15,16,22,23,25,30,32,38,40,48,49,50,73,74,76,78,79,80,81,82],haystack:69,header:[5,9,12,15,16,23,29,32,35,41,46,48,50,53,54,74,80,81],health_check_interv:51,healthi:76,heap:21,heartbeat:[5,25,38,43,46,47,48,50,51],heartbeat_check:[5,25,48],heartbeat_tick:48,held:[5,23,48,50,74],hello:[5,19,25,30,44,76,77,80],hello_consum:75,hello_publish:75,hello_task:75,helloworld:75,help:2,helper:50,henc:[5,76],here:[3,22,50,74,79,81,82],hi:78,high:[3,38,73,75,78],higher:[5,29,41],highest:[5,73],highli:3,hipri:75,hold:[5,48,50,53,63],home:78,host:[5,9,15,16,21,25,48,50,71,73],hostnam:[5,21,25,31,48,49,50,56,71,73,82],how:[5,25,48,50,63],howev:81,html:[5,38,55,74],http:[3,4,5,9,23,38,39,40,42,43,55,66,74],http_client:9,httperror:[15,16],hub:[4,7,14,15,17,50],human:[15,16,78],i:[4,38,48,50,82],iam:38,id:[21,22,48,52,72],ideal:48,idempot:38,ident:[3,5,48,50,59],identifi:[5,24,48,50],idiomat:3,if_empti:[5,48,50,53],if_unus:[5,48,50,53],ignor:[5,22,23,25,48,50,53,74],ignore_error:[30,32,33],ignore_timeout:22,imag:[3,81],image_queu:3,imagin:78,immedi:[5,19,23,25,32,48,50,80],immut:50,imp:64,implement:[1,3,4,5,9,12,13,15,16,20,25,30,33,38,43,46,47,48,50,51,53,55,63,65,66,67,68,73,76],impli:[5,48,50],implicitli:[5,25,50],impos:48,improv:[5,23,48,50,74],inact:48,includ:[21,36,48,50,51,81],include_password:[5,25,39],incom:[5,21,48],inconsistencyerror:51,incorrectli:50,incr:63,increas:[5,23,48,63,74,80],increment:21,indefinit:[50,74],indent:65,index:[2,3,42,43,50,53],indic:[48,50],individu:53,infam:61,infinit:[23,48,76],info:[5,25,27,31,50,69,75,76,82],inform:[5,21,39,40,50,61,80],ingress:79,inherit:[50,53],init:31,initi:[5,23,25,38,50,53,74],initial_valu:21,insert:63,insid:[38,81],insist:[5,25,73],instal:[2,28,34,49,50,73,81],instanc:[5,6,7,9,15,16,18,22,23,25,30,32,33,38,41,50,53,59,62,63,66,74,79,80,81],instanti:[5,23,25,32,50,74,80],instead:[5,23,25,30,48,50,73,74,81,82],instruct:[50,81],insur:22,integ:[5,50,52],intend:48,interchang:82,interest:[50,78],interfac:[2,3,4,5,9,15,23,25,35,38,41,50,53,75,77],intermitt:[22,80],intern:[15,16,48,50],interpret:[3,5,48],interrupt:[48,50],interv:[5,25,30,39,48,51,63,76],interval_max:[5,25,63,80],interval_rang:63,interval_start:[5,25,63,80],interval_step:[5,25,63,80],introduct:[2,3,77],invalid:[48,50],invalidrespons:51,invok:5,io:[3,42,55,81],is_al:48,is_bound:6,is_clos:48,is_enabled_for:27,is_ev:[5,25],is_list:63,is_secur:38,isinst:65,isol:50,issu:[3,39,48,50,79],item:[13,20,21,25,33,34,48,55,63,66,68],itemgett:[5,21,25],iter:[5,22,25,30,63,65,68,69],iterconsum:23,iteritem:63,iterkei:63,itermessag:22,iterqueu:23,itertool:[25,76],itervalu:63,its:[5,21,23,48,50,53,74,81],itself:[5,23,48,50,74],join:[3,30],jpeg:81,jpg:81,json:[3,4,5,23,30,32,34,74,75,76,79,80,81,82],jsonencod:65,just:[3,5,74,79],k:[42,63],kazoo:55,keep:[21,48,63],keep_al:39,keepal:39,kei:[3,5,9,15,16,23,25,32,38,40,42,48,50,51,53,54,57,63,69,80,82],kept:[3,73],key_to_pattern:54,keyboardinterrupt:75,keyerror:[7,18,50,63],keyfil:[5,25,48],keyfun:63,keyprefix:51,keyprefix_fanout:51,keyprefix_queu:51,keyword:[3,5,9,15,16,22,23,25,28,29,30,32,41,48,50,63,77,80],kill:39,kmsmasterkeyid:38,knowledg:51,known:50,kombu:[3,73,74,75,76,79,80,81,82],kombu_default:47,kw:63,kwarg:[5,6,8,9,11,12,13,15,16,20,22,23,25,27,29,30,31,32,35,37,38,39,40,41,42,43,44,46,47,48,49,50,51,52,53,54,55,61,62,63,64,65,68,75,76],l:63,label:[11,13],lack:63,lambda:5,lamport:21,lamportclock:21,languag:81,larg:[38,48,50],larger:81,last:[5,23,25,33,48,50,66,74],last_created_channel:[5,25],last_heartbeat_receiv:48,last_heartbeat_s:48,last_us:68,later:[48,50,73,78],latest:[3,21,38,55],latter:[34,82],launch:49,lax:19,laxboundedsemaphor:19,layer:3,lazi:63,lazili:[5,25,50],lb:48,lbb:48,lead:51,leak:50,least:[5,21,48,50,51,63],leav:[5,29,41],left:[39,50,79],leftmost:51,legal:38,len:35,length:[50,52],less:[19,48],let:[65,79,80,81],letter:[5,48,78],level:[3,5,9,27,48,50,79,82],librabbitmq:[4,25,73],librari:[3,5,29,38,39,41,42,43,44,46,47,48,49,50,51,52,55,73,81,82],library_properti:48,licens:2,life:78,lifetim:[38,76],lifoqueu:33,like:[3,5,38,50,51,53,55,58,63,65,74,78,79,81,82],limit:[4,5,22,23,25,26,30,31,32,33,38,48,53,55,63,74,81],limitexceed:[25,26,33],line:[5,9,15,16,25],linger:50,link:63,list:[5,7,13,18,21,22,23,24,25,30,32,34,38,41,50,51,63,65,68,73,74,76,80,81],list_first:13,listen:[31,39],live:[5,38,48,76],load:[13,34,65,81],load_from_fil:13,load_from_filenam:13,load_from_s3:13,local:[5,23,38,48,74],localhost:[3,5,25,48,49,52,73,75,79,82],localis:48,locat:49,lock:[19,21],lock_nam:42,lock_ttl:43,lock_valu:43,log:[4,9,15,16,30,48,59,75,82],log_messag:82,log_queu:82,logfil:27,logger:[5,25,27,29,48,53,59,75,76,82],logger_nam:27,logic:4,login_method:[5,25,48,50],login_respons:48,loglevel:[27,59,75],logmixin:27,logwrap:59,lolcat1:3,longer:[48,73],longlong:48,look:[49,50,51,64,74,81],lookup:[11,50,54],loop:[4,5,22,25,48,50,51,76],lopri:75,lose:[5,25,48,78,80],loss:[5,23,32,74,80],lost:[5,23,30,32,48,55,80],low:[5,75],lru:63,lrucach:63,m:49,made:50,mai:[5,23,25,38,48,50,53,73,74,78,79,80,81],mail:78,main:[39,74],maintain:[21,50,52,79,81],make:[1,3,5,25,30,48,50,51,57,73,80,81,82],manag:[4,5,25,30,38,39,50,53,58,79],mandatori:[5,23,32,48,80],mani:[5,25,50,53,78,81],manual:[3,5,23,44,50,74],map:[5,15,16,23,31,32,36,38,48,53,54,57,63,64,71,80],mar:[4,77],mark:[39,48,58],marshal:34,mask:[5,25,39,71],master:38,master_nam:51,match:[3,4,5,50,54,69],matcher:4,matcher_kwarg:28,matcher_pattern_first:28,matchernotinstal:28,matcherregistri:28,math:28,mathc:28,max:[5,29,41,63],max_client:17,max_connect:51,max_delai:[7,18],max_interv:20,max_length:[5,22],max_length_byt:[5,22],max_prior:[5,22],max_redirect:[9,15,16],max_retri:[5,25,63,76,80],max_tim:[7,18],maximum:[5,9,15,16,21,23,25,26,30,32,48,53,63,66,80],maxlength:5,maxsiz:[33,63],mayb:78,maybe_bind:[5,6],maybe_close_channel:[5,25],maybe_conn_error:30,maybe_declar:[5,6,22,23,32,80],maybe_evalu:63,maybe_fileno:58,maybe_list:63,maybe_s_to_m:70,maybe_sanitize_url:71,maybe_switch_next:[5,25],maybechannelbound:6,mean:[5,19,21,23,29,41,48,53,73,74,78,79],meaning:[48,50],mechan:[5,23,38,48,50,74,80],media:3,media_exchang:3,member:50,memoiz:[29,41,48,53,63],memori:[3,4,5,50,73,78],mention:[38,76],messag:[3,4,11,13,21,22,23,25,26,30,31,32,37,38,39,42,43,44,46,47,49,51,52,54,60,73,74,75,76,77,79,80,81],message_cl:52,message_class:13,message_cont:11,message_count:50,message_id:37,message_id_sequ:52,message_tablenam:52,message_to_python:[48,53],message_ttl:[5,22],messagenack:48,messages_collect:47,messagestateerror:[26,29,41,48,53],meth:30,method:[9,15,16,23,24,25,26,27,28,29,30,31,32,34,38,41,47,48,50,51,53,54,55,59,63,65,73,74,76,80,81],method_id:48,method_queu:48,method_sig:48,microsoft:[39,40],mid:75,middl:80,midpri:75,million:78,millisecond:70,mime:[24,34,81],mimetyp:81,min:[7,18],min_delai:[7,18],min_other_sentinel:51,min_ratio:69,minimum:[38,48,50],minut:[5,48,78],miss:81,mix:74,mixin:[4,6,27,75,76,77],mixtur:50,mode:[5,29,41,48,78],model:[4,48],modern:81,modifi:[5,48,50],modul:[2,4,5,25,37,38,39,40,42,43,44,46,47,48,49,50,51,52,55,74,76,81],modulenam:64,monei:78,mongodb:[3,4],monitor:[5,25,38,48,50],monoton:[20,21,48],month:78,more:[3,5,19,21,22,23,39,40,48,50,54,66,74,80,81],moreov:[52,76],most:[3,5,25,66,68],mostli:80,move:[21,38,48,68],mpg:82,mq:3,msg:[22,48],msgpack:[5,34,74,81],much:[63,78],multi_cal:31,multipl:[5,23,29,30,38,39,41,48,50,53,57,74,76,79],multithread:66,must:[3,5,9,15,16,21,22,23,25,28,29,30,32,38,41,44,48,50,51,53,63,73,74,78,80,81],mutat:50,mutex:21,my:38,my_callback:3,my_decod:81,my_encod:81,my_modul:81,my_pickl:81,my_pictur:81,my_seri:81,mybuff:82,mydatabas:52,mymast:51,myqueu:82,mysql:52,mysqlclient:52,mysqldb:52,myvhost:73,n:[19,51,68,74,82],name:[3,5,22,23,24,25,27,28,31,34,35,36,37,38,39,40,42,43,44,46,47,48,49,50,51,52,53,54,55,64,71,73,74,80,81,82],namedtupl:50,namespac:[31,39,58],nasdaq:[3,5],nativ:[3,42,48,50,73,81],necessari:[48,50,78],necessarili:[5,48,50],need:[3,5,9,15,16,23,25,30,32,38,41,48,50,54,73,74,76,78,79,80,81,82],needl:69,neg:50,negoti:[48,50],negotiate_cap:48,neither:63,nest:[58,74],network:[9,15,16,50],network_interfac:[9,15,16],never:[5,50,51,66,78],new_channel:[5,25],new_sqs_client:38,newli:[48,50],news_exchang:[5,79],next:[5,7,18,22,25,63,68],no_ack:[5,22,23,25,31,35,37,38,39,40,48,50,53,74],no_ack_consum:48,no_declar:[5,22],no_loc:48,node:[55,76],non:[3,5,48,50,64,80],none:[5,7,8,9,11,12,13,15,16,17,18,20,21,22,23,24,25,27,28,29,30,31,32,33,34,35,36,37,38,39,40,41,42,43,47,48,50,51,52,53,54,56,58,59,60,61,63,64,65,66,67,68,70,71,74,78,80,82],noop:[5,25],nor:5,normal:50,notabl:81,notbounderror:[3,26],note:[5,9,15,16,23,25,32,34,38,39,40,46,48,49,50,74,79,80,81],notfound:50,noth:[5,50,71],notif:50,notifi:50,notimplementederror:[5,23,53,74],now:[5,22,38,48,52,72,81],nowait:[5,48,50,53],nullabl:52,num:51,num_messag:13,number:[5,9,15,16,23,25,26,30,32,37,38,39,40,42,43,44,47,48,49,50,51,52,53,55,63,66,71,73,80],number_messag:11,numer:48,o:[4,50,57,61,65],obj:[5,21,25,57,61,63],object:[3,4,5,6,7,15,16,18,21,23,25,28,30,34,38,41,44,46,48,49,50,53,58,59,63,65,74,79,80],occur:[5,23,25,29,34,41,50,55,66,74,76],octet:[5,23,48,74],offer:55,offlin:80,often:[5,22,25,79],ok:[15,16,48],okta:38,old:[39,81],on_block:48,on_callback_error:[7,18],on_cancel:48,on_clos:[7,18],on_connection_error:30,on_connection_reviv:30,on_consume_end:[30,74],on_consume_readi:30,on_declar:5,on_decode_error:[5,23,30,74],on_error:[20,48],on_head:[9,15,16],on_inbound_fram:48,on_inbound_method:48,on_iter:30,on_messag:[5,23,30,74,76],on_open:48,on_prepar:[9,15,16],on_read:[17,50,51],on_readi:[9,15,16],on_request:74,on_return:[5,23,32,80],on_rev:[5,22,25],on_special_messag:74,on_stream:[9,15,16],on_success:48,on_task:30,on_timeout:[9,15,16],on_tune_ok:48,on_unblock:48,on_writ:17,onc:[5,25,48,50,53,79],one:[3,5,22,25,38,48,50,51,54,63,66,73,78,79,81],onli:[3,5,21,23,25,34,38,46,48,50,51,53,63,66,73,74,76,78,81,82],onto:50,onupd:52,open:[3,5,25,32,48,60,73,81],open_fil:60,oper:[3,5,23,25,50,57,63,74,77],operand:21,operationalerror:52,operationfailur:47,opportun:[50,51],opt:22,optim:[38,78],option:[3,5,9,15,16,21,22,23,25,28,30,31,32,34,35,38,41,53,70,71,73,74,80,81],order:[5,19,21,23,38,48,50,51,68,74],org:[3,23,55,66],organ:50,orient:3,origin:[3,5,22,23,29,30,41,48,50,51,53,74,78],oserror:[37,38,48,50,51],other:[5,21,23,25,48,50,51,55,73,74,78,81],otherwis:[5,19,23,28,38,48,50,74],our:[3,5,29,38,41,51,79],out:[3,9,15,16,19,22,33,46,48,50,53,66],out_of_band:48,output:[48,61],outsid:[3,30,50],outstand:[48,50],over:[22,48,50,63,73,78,81],overflow:[5,23,48,74],overload:63,overrid:[5,23,30,32,38,50,74,80],own:[5,21,29,41,48,73,74,79],p:[32,69],packag:[3,34,38,64,73,81],packet:48,page:2,page_s:13,pair:[5,25,38,50,63],paramet:[5,7,9,15,16,18,19,20,21,22,23,24,25,28,32,33,34,36,48,50,52,53,54,63,68,71,73,74,76,79,80],parent:[25,33],pariti:50,pars:71,parse_ssl_cert_req:71,parse_uri:39,parse_url:71,part:[5,21,50,53,71,73,81],parti:[78,81],partial:[19,48,66],partial_arg:19,partial_kwarg:19,particip:3,particular:48,pass:[5,9,15,16,22,23,25,28,31,32,34,38,39,46,47,48,50,52,63,65,73,76,80,81],passiv:[5,48,50,53],password:[5,9,15,16,25,48,50,51,56,71,73],patch:3,path:[9,36,48,64,71,73,81],pattern:[3,4,5,50,51,54,78],paus:48,payload:[3,29,38,41,48,50,52,53,74,75,81,82],pcre:28,peek_lock_second:39,peer:[5,23,48,74],pend:[14,48,51,53],peopl:78,per:[5,23,25,32,48,50,79,80,81],perform:[3,5,9,15,16,22,23,25,30,38,48,50,73,74],period:[5,25,38,50,78],persist:[5,25,48,50,78,82],persistent_delivery_mod:5,pg8000:52,phone:78,pick:76,pickl:[3,5,34,44,74,75,80],pickle2:81,pickle_protocol:81,pid:21,pidbox:[4,50],pip:[3,50],pipe:[50,51],pipe_or_acquir:51,pki:[5,25],place:50,plain:[50,81],pleas:3,pluggabl:3,point:[48,50,53,77],polici:[39,50,80],poll:[5,14,37,39,40,43,47,51,53,55,62],poller:[7,18,62],polling_interv:[37,38,39,40,43,47,50,51,53,55],pool:[2,4,5,22,33,51,73,75,77,80],poolgroup:32,pop:66,popitem:63,popul:[9,15,16],popular:3,port:[3,5,25,37,38,39,40,41,42,43,44,47,48,49,50,51,52,53,55,56,71,73],portion:50,posit:[5,50,63],possibl:[3,34,48,50,76,79],post:[5,78],postal:78,postencod:[12,29,41],postgresql:52,potenti:[5,23,48,50,74],practic:[3,22,50,73],pre:50,predeclar:48,predefin:74,predefined_queu:38,predic:68,prefer:[38,53],prefetch:[5,23,48,50,53,74],prefetch_count:[5,23,30,38,48,50,53,74],prefetch_s:[5,23,48,53,74],prefetch_valu:50,prefix:[11,39,42,43,51],preload:33,prematur:48,prepar:[32,33,48,50,53,54],prepare_bind:54,prepare_messag:[48,50,53],prepare_queue_argu:[47,48],prepend:[39,51],present:[21,48,50,63],preserv:[5,50],pretend:19,prev:54,prev_recv:48,prev_sent:48,prevent:39,previou:63,previous:[5,24,48,50],price:78,primari:81,primary_kei:52,primit:[3,5,19,75],principl:48,print:[3,19,30,44,74,75,76,78,79,82],prior:[50,55],prioriti:[3,5,20,23,29,32,37,38,39,40,41,42,43,44,46,47,48,49,50,51,52,53,55,73,75,80],priority_cycl:[51,68],priority_step:51,priority_to_routing_kei:75,privat:[19,48],probabl:[48,81],problem:[3,76],process:[3,5,21,23,25,29,31,33,41,44,48,53,55,64,74,79,81,82],process_media:3,process_next:23,process_task:75,processed_fold:44,processid:21,produc:[2,3,4,22,23,25,30,35,44,48,50,73,74,75,77,78,81,82],producer_connect:30,producer_pool:31,producerpool:32,product:48,product_vers:48,program:[30,39,78,81],project:[3,23],promis:[63,65],prop:22,propag:[7,18,22],properli:[5,29,39,41,50],properti:[3,4,5,6,7,12,15,16,18,20,21,22,23,25,27,29,30,32,33,37,38,39,40,41,42,43,44,47,48,49,50,51,52,53,55,74,80],propos:48,protocol:[3,38,42,43,44,46,47,48,49,50,51,52,54,55,74,81],proven:3,provid:[3,5,9,15,16,22,25,48,50,51,63,64,72,73,74,81],provok:48,proxi:[9,15,16],proxy_host:[9,15,16],proxy_password:[9,15,16],proxy_port:[9,15,16],proxy_usernam:[9,15,16],psycopg2:52,pub:[3,51,73,78],publish:[3,5,25,29,30,32,35,41,44,48,50,51,53,74,75,76,78,79,80,81],publish_messag:[5,25],pull:38,pure:[4,73],purg:[5,23,48,50,74],purpos:50,put:[29,35,41,48,53,75,82],puthead:9,putrequest:9,py:[3,5,25,38,42,43,44,46,47,48,49,50,51,52,55,75],pyamqp:[4,25,36,73],pycurl:4,pymongo:47,pymysql:52,pypi:[3,23],pyrabbit:56,pyro4:49,pyro:[3,4,73],python3:50,python:[3,4,5,20,29,34,41,42,43,49,52,53,66,73,81,82],pyyaml:34,q:[38,76],qo:[5,23,30,38,48,50,51,53,74],qos_semantics_matches_spec:[25,48],qpid:[3,4,5,25,73],qpidtoollib:50,qsize:35,qualifi:[36,64],qualiti:[5,23,38,48,74],queri:[71,73],query_valu:71,question:2,queu:3,queue11:74,queue12:74,queue1:74,queue21:74,queue22:74,queue2:74,queue:[3,4,11,20,22,23,25,29,30,33,35,37,39,41,42,43,44,46,47,48,49,50,51,52,53,54,55,73,74,76,77,80,81,82],queue_arg:[5,25,35],queue_argu:[5,22],queue_bind:[5,48,50,53],queue_bindings_delet:53,queue_cl:52,queue_declar:[5,48,50,53],queue_declare_ok_t:50,queue_delet:[47,48,50,53],queue_expir:31,queue_id_sequ:52,queue_index:53,queue_mgmt_servic:39,queue_nam:[11,38,82],queue_name_prefix:[37,38,39,40],queue_opt:[5,25,35],queue_order_strategi:51,queue_purg:[48,50,53],queue_servic:[39,40],queue_tablenam:52,queue_ttl:31,queue_unbind:[5,48,50],queue_url:11,queuea:38,queueb:38,queues1:74,queues2:74,queues_collect:47,quietli:48,r:[5,21,25,30,50,74,75,76,79,82],rabbit:3,rabbitmq:[1,3,4,5,25,48,75],rais:[3,5,9,15,16,23,25,28,29,33,34,38,41,48,50,53,63,65,74,75,79],raise_for_error:[15,16],rajith:5,random:50,rang:19,rapidli:48,rate:[4,5,25,38,48],rather:[5,23,48,53,74,79],ratio:69,raw:[5,12,23,29,34,41,53,74,77],raw_encod:34,raw_messag:[48,53],rb:81,re:[3,5,6,25,29,30,41,48,53,55,63,76],reach:63,react:[48,76],reactiv:[5,23,74],read:[3,5,7,9,13,15,16,18,23,44,48,50,74,81],read_timeout:48,readabl:50,reader:14,readi:[5,23,30,50,53,74],readthedoc:[3,55],real:76,realli:[3,5],reappli:[5,25],reason:[3,48],receipt:50,receipt_handl:11,receiv:[3,5,9,12,15,16,21,22,23,29,35,39,41,46,48,49,50,73,74,75,76,77,78],receive_messag:11,recent:[1,5,25,48,63,68],recip:[55,66],recipi:[5,23,48,74,78],recommend:[5,25,48],reconnect:[5,25,48,76],record:78,recov:[5,23,25,41,48,53,74,78],recover:[5,25,41,50],recoverable_channel_error:[5,25,41,48,50],recoverable_connection_error:[5,25,41,48,50],recoverablechannelerror:48,recoverableconnectionerror:48,recreat:48,recurs:[5,81],redeclar:5,redeliv:[5,23,48,74],redi:[3,4,5,25,38,42,43,44,46,47,48,49,50,52,53,54,55,73,79],redirect:[9,15,16],redis_address:51,rediss:51,refer:[2,21,38,48,50,55,77,81],referenc:50,refil:66,refresh:76,refus:48,regard:41,regardless:[5,25],regener:40,regex:54,region:[11,38],regioninfo:38,regist:[5,23,24,28,32,34,50,74,81],register_arg:81,register_callback:[3,5,23,44,74,76],register_glob:28,register_group:32,register_pcr:28,register_with_event_loop:[5,25,48,50,51],registr:50,registri:[4,53],regular:[3,69,81],regularli:[5,25],reject:[29,38,41,48,50,51,53],reject_log_error:[29,48,53],relat:[5,21,25,41,64],relationship:53,releas:[3,4,5,19,23,25,32,33,73,77,79],release_resourc:33,reli:50,reliabl:[3,38,48,55,77],relic:73,reload_schedul:31,remain:[5,48,50],rememb:[3,5,25],remov:[5,7,18,23,25,28,29,33,38,41,48,50,51,53,55,63,71,74,80,82],remove_permiss:[11,13],remove_read:[7,18],remove_writ:[7,18],repeat:68,replac:[5,23,25,33,50,61],repli:[5,22,31,46,48,49,74,78],reply_cod:48,reply_exchang:31,reply_polici:22,reply_queue_expir:31,reply_queue_ttl:31,reply_text:48,reply_to:[22,30,31,74],report:[3,48],repositori:74,repr:61,repr_act:[7,14,18],repr_ev:[7,14,18],repr_flag:14,repr_read:14,repr_writ:14,reprcal:75,repres:[15,16,21,28,34,50,71],req:22,request:[5,9,15,16,17,22,23,28,34,38,48,50,66,74,78],request_timeout:[9,15,16],requeu:[5,23,29,38,39,41,46,48,49,50,51,53,74],requir:[5,23,25,30,32,38,39,49,50,54,73,78,80,82],resent:[48,78],reserv:48,reset:[7,18,19,32,33],reset_aft:32,resiz:33,resolv:48,resolve_alias:25,resolve_transport:36,resourc:[4,19,25,32,48,68,73,79],respect:[48,50,79],respond:[5,48],respons:[5,9,15,16,50,74],responseerror:51,rest:[51,81],restart:[5,48,50,78,80],restart_limit:30,restor:[46,48,51,53],restore_at_shutdown:[51,53],restore_by_tag:51,restore_unack:[51,53],restore_unacked_onc:53,restore_vis:[51,53],restrict:50,result:[5,15,16,25,48,74],resynchron:21,ret:[5,25],retain:50,retri:[5,22,23,25,30,32,38,39,44,50,63,74,76,80],retro:[5,25],retry_backoff_factor:39,retry_backoff_max:39,retry_on_timeout:51,retry_over_tim:[63,80],retry_polici:[5,22,23,32,80],retry_tot:39,returns_tupl:48,retval:[5,25],reviv:[5,6,23,25,32,74,80],rfc:48,right:74,ring:50,rk:80,rkei:[54,81],robin:[5,25,51,68,76],role:38,role_arn:38,rollback:48,root:[3,75],rotat:68,round:[5,25,51,68,76],round_robin:51,round_robin_cycl:[51,68],rout:[3,5,23,25,32,47,48,50,51,53,54,73,82],routin:58,routing_collect:47,routing_kei:[3,5,22,23,25,30,31,32,35,38,44,48,50,53,54,74,75,76,79,80,81],rpc:[46,48,49,74],rpc_queue:74,rs:13,rule:[21,48],run:[22,30,38,39,49,50,61,73,74,75,76],run_forev:[7,18],run_onc:[7,18],runtim:[50,79],runtimeerror:50,s:[3,5,21,25,37,38,39,40,42,43,48,50,51,61,63,65,69,75,76,78,79,81,82],safe:[50,61,66],safe_repr:61,safe_str:61,safeguard:79,safeti:66,safety_interv:30,sai:80,said:39,same:[3,5,25,48,50,73,74,79,81,82],sanit:71,sanitize_url:71,sas_kei:39,sas_policy_nam:39,sasl:50,sasl_mechan:50,save:[13,50],save_to_fil:13,save_to_filenam:13,save_to_s3:13,sb:48,sc_recipes_queu:55,scalar:[21,63,69],scenario:[76,77],schedul:[4,7,18,20,53],scheme:[3,5,71,81],scienc:5,science_new:5,scope:[46,48,53],scott:52,sdk:39,search:2,sec:20,second:[5,9,15,16,21,23,25,30,32,38,39,48,50,63,66,70,73,74,76,80],secret_access_kei:38,section:66,secur:3,see:[1,3,5,15,16,22,23,32,38,50,51,52,73,74,78,79,80],seem:39,select:[5,25,29,41,48,50,53],selector:4,self:[5,23,25,30,35,48,50,53,65,74,75,76,82],semant:[5,25,46,48,49],semaphor:4,send:[3,5,9,21,22,23,29,31,34,39,41,48,50,73,74,75,77,78,79,80],send_as_task:75,send_heartbeat:48,send_messag:11,send_message_batch:11,send_method:48,send_repli:22,sender:[21,48,50,78],sens:[5,48,50],sent:[3,5,23,29,39,41,48,50,53,74,75,78,81],sent_at:52,sentinel1:[51,73],sentinel2:[51,73],sentinel:[51,73],sentinel_address:51,sentinel_kwarg:51,sentinelmanagedconnect:51,sentinelmanagedsslconnect:51,sep:[51,64],separ:[3,5,25,30,38,42,43,44,46,47,48,49,50,51,52,54,55,64,65,74],seq:57,sequenc:[5,23,24,25,32,52,57,68,69,74,80],serial:[2,3,4,5,12,23,29,31,32,35,41,44,65,74,75,77,79,82],serializ:[50,53,65],serializernotinstal:34,serializerregistri:34,serv:50,server:[3,5,9,15,16,23,25,29,38,41,43,48,49,50,53,55,73,74],server_cap:48,server_heartbeat:48,server_hostnam:48,server_properti:48,servic:[3,4,5,23,38,40,48,49,74,78],service_busnamespac:39,servicebu:39,servicebusadministrationcli:39,servicebuscli:39,session:[5,23,32,50,52,80],session_token:38,session_ttl:[42,43],set:[5,6,7,9,15,16,18,21,22,23,25,29,30,32,34,38,39,41,44,46,47,48,50,51,52,53,54,61,63,68,73,74,79,80,81],set_attribut:13,set_debuglevel:9,set_default_encoding_fil:61,set_event_loop:[7,18],set_limit:[32,79],set_queue_attribut:11,set_timeout:13,setter:67,setup:[3,27,32,33,50,59,75,81],setup_log:[27,59,75],setuptool:[58,77],sever:[3,27,50,73,76,78],sh:21,shamelessli:5,share:[39,48,50,51,54],shared_queu:49,ship:79,shortcut:[25,76,82],shortstr:48,should:[3,5,7,9,15,16,18,23,25,28,29,30,34,39,41,47,48,50,51,52,64,66,73,74,76,79],should_stop:30,shouldn:78,show:50,shrink:[19,79],shuffl:[5,25,76],shufflecycl:[25,76],shut:48,shutdown:[51,53],side:[38,48,50],sig:48,sign:78,signatur:[5,9,15,16,23,32,74,80],silenc:50,silent:[48,50],simpl:[2,4,5,21,23,25,44,46,48,74,75,77],simple_queu:75,simplebuff:[5,25,35,82],simpledb:[3,73],simplejson:81,simplequeu:[5,25,35,75,82],simpli:[3,49],simul:51,simultan:26,sinc:[5,23,39,48,50,51,74,76,80,81],singl:[5,9,15,16,23,25,38,48,50,54,63,78,82],singleton:50,situat:[38,50,78],size:[3,5,19,23,48,74],skip:6,skipkei:65,slash:[40,51],sleep:[5,7,18,25,37,38,39,40,43,47,51,53,55,63],slept:[5,25],slight:81,slightli:82,slmq:[3,4,73],slower:[48,81],slq:37,small:[38,48],smaller:[5,23,48,74,81],smallinteg:52,snapshot:20,so:[1,3,5,21,23,25,30,39,48,50,51,55,73,74,78,79,80,81,82],sock:[48,73],socket:[5,9,15,16,22,25,26,33,48,73,76,82],socket_connect_timeout:51,socket_keepal:51,socket_keepalive_opt:51,socket_set:48,socket_timeout:[25,51],softlay:[3,37],softwar:[3,21],soldier:78,sole:[7,18],solut:3,solv:76,some:[3,5,21,23,38,39,48,63,74,76,78,81],someth:[5,25,51,82],sometim:[50,78],soon:30,sophist:48,sort:[21,51,68],sort_heap:21,sort_kei:65,sorted_cycl:[51,68],sourc:[3,5,6,7,8,9,11,12,13,14,15,16,17,18,19,20,21,22,23,24,25,26,27,28,29,30,31,32,33,34,35,36,37,38,39,40,41,42,43,44,46,47,48,49,50,51,52,53,54,55,56,57,58,59,60,61,62,63,64,65,66,67,68,69,70,71,72,74,80],southeast:38,space:[48,50],spec:[5,23,32,80],special:[3,5,34,79],specif:[5,9,15,16,23,25,38,48,50,54,73,74],specifi:[5,7,9,15,16,18,19,22,23,25,28,32,34,36,37,38,39,40,41,42,43,44,47,48,49,50,51,52,53,55,73,74,80,81,82],speed:38,speedup:81,sphinx:3,sq:[3,4,8,53,73],sql:52,sql_alchemy_connection_str:52,sqla:52,sqlalchemi:4,sqs_base64_encod:38,sqs_connect:[9,11],sqsdeveloperguid:38,ssl:[5,9,15,16,25,47,48,50,71,73],ssl_cert_req:71,sslconnect:51,st:38,stage:48,stai:[3,5,19],stale:80,stamp:21,standard:[3,38,48,54,81,82],standardis:48,star:[3,5],start:[2,5,23,25,39,48,50,51,63,74,79,80],startup:[23,74],state:[5,31,38,46,48,50,51,54,60],statement:3,statu:[15,16],status_cod:[15,16],stdchannel:50,stderr:[53,60],stdin:[5,25],stdout:[59,60],step:[30,50],still:[5,23,25,48,50,74,78],stock:[3,5,78],stolen:[5,66],stop:[5,7,18,20,23,30,48,50,63,74],stopiter:[7,18],storag:[3,4,42,43,48],storage_account_access:40,storage_account_nam:40,store:[3,5,38,42,43,44,46,48,50,52,53,54,73],store_process:44,str:[5,9,15,16,21,22,23,24,25,29,32,34,36,39,41,50,51,54,61,63,65,69,71,80],str_to_byt:61,strategi:[5,25,48,51,76],stream:[34,74],strict:[9,78],string:[4,5,25,28,34,36,50,63,64,65,69,73,76,80,81],structur:[29,34,41,48,50,53,81],sts_role_arn:38,sts_token_timeout:38,ststest:38,stuck:22,stunnel:[5,25],style:[4,51,53,81],sub:[3,51,73,78],subclass:[5,38,53,65,74],subclient:51,submit:50,subscrib:[5,23,48,74,78],subscript:48,subsequ:[15,16,53],success:48,successfulli:[5,25,50],suffix:38,suggest:[3,50],suit:38,suitabl:[34,48],suppli:[22,38],support:[1,3,5,22,23,25,30,32,34,37,39,40,42,43,44,46,47,48,49,50,51,52,53,54,55,59,65,73,74,75,79,80,81],supports_ev:50,supports_exchange_typ:25,supports_fanout:[3,38,46,47,51,54,73],supports_heartbeat:[5,25],suppos:51,sure:[1,3,30,51,57,80,81],surviv:[50,78],suspend:19,svc:38,symbol:[50,64],symbol_by_nam:64,sync:21,synchron:[4,5,48,50,53],syntax:48,system:[4,5,25,48],t:[3,5,23,24,25,48,50,51,53,74,78,79,80,81],tabl:[3,5,36,37,38,39,40,47,48,50,51,52,53,54,73],tag:[5,37,38,39,48,50,51,53],tag_prefix:[5,74],take:[5,22,23,30,50,61,63,74,80,81],taken:[50,66,73],talk:[42,43],tarbal:3,task1:38,task2:38,task:[3,5,25,30,38,77,80],task_exchang:75,task_queu:[30,75,80],taskpool:64,tb:[23,48,53],tcp:50,tear:48,tell:[38,48],term:[5,23,48,74],termin:39,terminolog:2,test:[3,38,44,50,53],test_queu:[44,76],text:[3,4,24,27,34,48,52,61,74],text_t:65,textual:65,than:[3,5,19,21,23,48,50,53,74,78,79,81],thei:[3,5,39,48,50,66,74,78,79,81,82],them:[3,5,38,48,50,73,74,78,81,82],therefor:[5,38],thi:[3,5,6,9,15,16,19,21,22,23,24,25,29,30,31,32,33,34,36,39,41,43,48,49,50,51,53,54,55,61,63,65,66,68,72,73,74,76,78,79,80,81,82],think:50,those:[25,33,38,48,50],though:48,thought:21,thread:[30,39,46,66,79],three:[34,63],throttl:48,through:[48,50,75,78],throughput:78,thu:50,tick:[5,25],ticket:31,tiger:52,time:[4,5,9,15,16,19,20,21,22,23,25,30,37,38,39,40,43,47,48,50,51,53,55,57,63,65,66,74,78,82],timeout:[3,5,9,15,16,22,23,25,26,30,31,32,33,35,38,42,43,44,48,50,53,63,73,74,75,76,79,80,82],timeouterror:[26,51],timer:[4,7,18],timestamp:[20,21,52,66,82],timetupl:21,titl:79,tl:[5,25],tmp:[3,73],to_timestamp:20,todai:[75,78],token:[38,66],token_bucket:66,token_expiry_second:38,tokenbucket:66,told:50,too:[3,30,79],tool:[14,50],top:[3,38],topic:[3,5,37,38,39,40,42,43,44,46,47,48,49,50,51,52,53,55,73,77,78],topicexchang:[53,54],topolog:48,total:[5,39],traceback:[5,25],track:[48,63],tracker:2,trail:51,transact:[38,48,51,53,78],transfer:[48,78,81],transform:50,transient_delivery_mod:5,transit:73,transport:[2,5,25,77],transport_alias:36,transport_opt:[5,25,37,38,39,40,44,50,51,73],treat:[5,48,50],tref:20,tri:[50,73,76,80],trigger:[38,76],ttl:[3,5,23,32,37,38,39,40,42,43,44,46,47,48,49,50,51,52,55,80],tube:79,tupl:[5,21,25,34,37,38,39,41,47,48,50,51,52,54,55,63,69,71,81],turn:[39,49],tut6:74,twice:6,two:[3,5,21,23,38,48,74,78,79,82],tx_commit:48,tx_rollback:48,tx_select:48,type:[3,5,9,15,16,23,24,31,32,34,36,37,38,39,40,42,43,44,46,47,48,49,50,51,52,53,54,55,57,66,68,73,74,75,80,81],typeerror:65,typic:50,uamqp:39,uamqp_keep_alive_interv:39,un:50,unabl:[30,48,50],unack:[38,39,46,49,51,53],unacked_index:51,unacked_index_kei:51,unacked_kei:51,unacked_mutex:51,unacked_mutex_expir:51,unacked_mutex_kei:51,unacked_restore_limit:51,unacknowledg:[5,23,48,51,53,74],unackwnowledg:[51,53],unavail:[30,76],unbind:[5,48,50],unbind_argu:5,unbind_from:5,unbound:[3,5,26,50],unchang:50,uncompress:24,unconsum:5,undefin:71,undeliv:50,undeliver:[5,32,48,80],under:[3,79],underli:[5,20,25,48,50,76],undo:[5,23,48,74],unexpect:76,unicod:[34,61,81],unicodedecodeerror:61,union:[5,36,70],uniqu:[5,22,48,50,72],unit:3,unix:[21,73],unless:[5,34,48,50],unmodifi:[39,47,52],unnecessari:34,unnecessarili:50,unpack:[21,50],unregist:[28,34],unreview:[37,39,40,42,43,47],unrout:48,unsaf:5,unseri:34,unset:50,unsuccess:[37,38,39,40,43,47,51,53,55],until:[5,19,23,25,33,38,48,50,63,74,78,79],untreat:48,untrust:[5,23,74,81],unus:[5,20,25,48,50,68],up:[5,25,30,38,44,48,50,63,64,80],updat:[63,68,78],upon:[5,25,50],uri:[39,48],uri_prefix:[5,25],url:[4,5,9,13,15,16,25,38,39,40,47,48,49,51,52,76,77],url_to_part:71,urlpart:71,us:[3,5,6,9,12,14,15,16,17,20,21,22,23,24,25,28,29,30,32,33,34,35,36,37,38,39,40,41,42,43,44,46,47,49,50,51,52,53,54,55,57,61,63,64,68,69,73,74,75,76,77,78,79,82],usag:21,usd:[3,5],use_default_limit:79,use_gzip:[9,15,16],useful:48,user:[2,3,5,9,15,16,19,25,38,48,50,51,71,73,74,82],user_ag:[9,15,16],userid:[5,25,48,56,73],usernam:[9,15,16,50,71],usual:[21,31,34,53,81],utc:[20,47],utf:[34,61,81],util:[6,24,27,34,53,74,75],utilitit:4,uuid4:[22,72],uuid:[4,22,50,65],v1:38,v:[42,63,70],valid:[37,39,40,48,50,73],validate_cert:[9,15,16],valu:[5,9,11,12,13,19,21,23,25,29,38,41,42,48,50,53,63,73,74,79],valueerror:[9,15,16],varg:47,variabl:81,variou:48,ve:[5,29,41,48],vendor:3,veri:[38,48,75,78,79,81],verif:50,verifi:[9,15,16,43,48,50],verify_connect:[42,43,48],verify_runtime_environ:50,version:[1,3,30,33,43,50,52,69],version_info_t:69,version_string_as_tupl:69,versu:50,vhost:[37,38,39,40,55],via:[3,48,50,73,81],video:[3,82],video_queu:3,view:63,violat:50,virtual:[3,4,5,25,37,38,39,40,43,44,46,47,48,49,50,51,52,55,73],virtual_host:[5,25,48,73],virtualhost:[48,51],visibility_timeout:[5,11,13,25,37,38,51,53],visibilitytimeout:13,visibl:[38,39,52],volum:48,vtimeout:13,wa:[5,19,23,29,30,41,48,50,66,74],wai:[25,50,78,80,81],wait:[3,5,19,23,25,32,33,38,39,48,50,63,74,78,80],wait_time_second:[11,13,38,39],waiter:19,want:[5,9,15,16,23,34,48,50,53,73,74,79,81],war:78,warn:27,warren:3,wast:81,we:[5,21,25,38,48,51,55,63,79],web:3,week:78,welcom:3,well:50,were:[5,48,50],what:[48,50,77],when:[3,5,6,7,9,15,16,18,21,23,25,30,32,36,37,38,39,40,41,42,43,44,46,47,48,49,50,51,52,53,55,63,73,74,76,78,80,81,82],when_bound:[5,6],whenev:[5,23,25,50,74],where:[5,21,22,25,29,30,38,41,44,48,49,50,51,53,63,68,79],whether:[5,6,48,50,73],which:[3,5,19,21,22,23,29,30,38,39,41,42,43,44,48,49,50,51,63,73,74,76,78,79,80,81,82],white:69,who:[50,75],whole:[5,23,48,74],whose:[38,63],why:[21,78],wiki:66,wikipedia:[3,21,66],wildcard:[5,54],window:[5,23,48,74],wipe:19,wish:48,with_traceback:[23,48,53],within:[5,19,23,48,66,69,74],without:[5,25,41,48,50,61,73,77],won:[5,48,50,51,53,78],word:[3,5,54],work:[5,25,38,43,50,73,78,81],workaround:43,worker:[30,38,74,75,80],world:[5,25,44,76,77,80],would:[30,34,38,48,50,78,81],wouldn:78,wrap:[50,59,76,81],wrapper:[22,81],write:[7,13,18,48,50,80],write_batch:13,write_timeout:48,writer:14,written:[44,50,73,78],www:[5,74],x06:51,x16:51,x:[5,19,38,51,74,81],xrang:82,xxx:38,yadda:79,yaml:[5,34,74,81],ye:[3,37,38,42,44,46,47,48,49,50,51,52,55,73],year:78,yet:[48,50,73,80],yield:[5,22,25,69],you:[3,5,9,15,16,22,23,25,29,30,34,38,39,41,48,49,50,51,53,65,73,74,78,79,80,81,82],your:[1,3,5,9,15,16,29,38,41,73,74,78,79,81],yourself:30,zero:[3,5,23,48,53,66,74],zlib:79,znode:55,zookeep:[3,4,73]},titles:["&lt;no title&gt;","Frequently Asked Questions","Kombu Documentation","Getting Started","API Reference","Kombu - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu</span></code>","Abstract Classes - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.abstract</span></code>","Event Loop - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.asynchronous</span></code>","Async Amazon AWS Client - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.asynchronous.aws</span></code>","Amazon AWS Connection - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.asynchronous.aws.connection</span></code>","Async Amazon SQS Client - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.asynchronous.aws.sqs</span></code>","SQS Connection - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.asynchronous.aws.sqs.connection</span></code>","SQS Messages - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.asynchronous.aws.sqs.message</span></code>","SQS Queues - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.asynchronous.aws.sqs.queue</span></code>","Event Loop Debugging Utils - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.asynchronous.debug</span></code>","Async HTTP Client - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.asynchronous.http</span></code>","Async HTTP Client Interface - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.asynchronous.http.base</span></code>","Async pyCurl HTTP Client - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.asynchronous.http.curl</span></code>","Event Loop Implementation - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.asynchronous.hub</span></code>","Semaphores - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.asynchronous.semaphore</span></code>","Timer - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.asynchronous.timer</span></code>","Logical Clocks and Synchronization - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.clocks</span></code>","Common Utilities - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.common</span></code>","Carrot Compatibility - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.compat</span></code>","Message Compression - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.compression</span></code>","Connection - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.connection</span></code>","Exceptions - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.exceptions</span></code>","Logging - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.log</span></code>","Pattern matching registry - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.matcher</span></code>","Message Objects - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.message</span></code>","Mixin Classes - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.mixins</span></code>","Pidbox - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.pidbox</span></code>","Connection/Producer Pools - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.pools</span></code>","Resource Management - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.resource</span></code>","Message Serialization - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.serialization</span></code>","Simple Messaging API - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.simple</span></code>","Built-in Transports - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.transport</span></code>","SLMQ Transport - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.transport.SLMQ</span></code>","Amazon SQS Transport - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.transport.SQS</span></code>","Azure Service Bus Transport - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.transport.azureservicebus</span></code>","Azure Storage Queues Transport - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.transport.azurestoragequeues</span></code>","Transport Base Class - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.transport.base</span></code>","Consul Transport - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.transport.consul</span></code>","Etcd Transport - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.transport.etcd</span></code>","File-system Transport - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.transport.filesystem</span></code>","librabbitmq AMQP transport - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.transport.librabbitmq</span></code>","In-memory Transport - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.transport.memory</span></code>","MongoDB Transport - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.transport.mongodb</span></code>","Pure-python AMQP Transport - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.transport.pyamqp</span></code>","Pyro Transport - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.transport.pyro</span></code>","Apache QPid Transport - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.transport.qpid</span></code>","Redis Transport - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.transport.redis</span></code>","SQLAlchemy Transport Model - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.transport.sqlalchemy</span></code>","Virtual Transport Base Class - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.transport.virtual</span></code>","Virtual AMQ Exchange Implementation - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.transport.virtual.exchange</span></code>","Zookeeper Transport - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.transport.zookeeper</span></code>","Generic RabbitMQ manager - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.utils.amq_manager</span></code>","Custom Collections - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.utils.collections</span></code>","Python Compatibility - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.utils.compat</span></code>","Debugging Utilities - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.utils.debug</span></code>","Div Utilities - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.utils.div</span></code>","String Encoding Utilities - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.utils.encoding</span></code>","Async I/O Selectors - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.utils.eventio</span></code>","Functional-style Utilities - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.utils.functional</span></code>","Module Importing Utilities - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.utils.imports</span></code>","JSON Utilities - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.utils.json</span></code>","Rate limiting - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.utils.limits</span></code>","Object/Property Utilities - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.utils.objects</span></code>","Consumer Scheduling - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.utils.scheduling</span></code>","Text utilitites - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.utils.text</span></code>","Time Utilities - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.utils.time</span></code>","URL Utilities - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.utils.url</span></code>","UUID Utilities - <code class=\"docutils literal notranslate\"><span class=\"pre\">kombu.utils.uuid</span></code>","Connections and transports","Consumers","Examples","Automatic Failover","User Guide","Introduction","Connection and Producer Pools","Producers","Serialization","Simple Interface"],titleterms:{"3":50,"abstract":6,"class":[6,30,41,53,74],"default":79,"function":[36,63],"import":64,"long":38,In:[46,53],Of:53,The:79,about:3,action:38,advanc:74,all:79,amazon:[8,9,10,38],amq:54,amq_manag:56,amqp:[45,48,73],anon:80,apach:50,api:[4,35,38],applic:31,argument:73,ask:1,async:[8,10,15,16,17,62],asynchron:[4,7,8,9,10,11,12,13,14,15,16,17,18,19,20],attribut:5,authent:50,automat:76,aw:[8,9,10,11,12,13],azur:[39,40],azureservicebu:39,azurestoragequeu:40,back:38,base:[16,41,53],basic:[73,74,80],batch:38,bu:39,buffer:[35,81],bug:3,built:36,bypass:80,carrot:23,channel:[37,38,39,40,42,43,44,46,47,48,49,50,51,52,53,55],client:[8,10,15,16,17,31,38],clock:21,collect:57,common:22,comparison:[3,73],compat:[23,58],compress:24,config:38,connect:[5,9,11,25,32,37,39,40,42,43,44,46,47,48,49,50,51,52,55,73,76,79],consul:42,consum:[5,23,68,74,76],consumerset:23,contribut:3,core:4,creat:[31,81],curl:17,custom:[57,79],data:[36,81],debug:[14,59],decod:24,direct:54,div:60,document:[2,3],doesn:1,drain:74,encod:[24,61],entri:81,etcd:43,event:[7,14,18,74],eventio:62,exampl:[31,75],except:[26,34],exchang:[5,54,80],extens:81,failov:76,fanout:54,featur:[3,37,38,39,40,42,43,44,46,47,48,49,50,51,52,55],file:44,filesystem:44,frequent:1,from:74,gener:56,get:3,group:79,guid:77,hello:75,help:3,http:[15,16,17],hub:18,i:62,implement:[18,54],indic:2,instal:3,interfac:[16,54,82],introduct:[31,78],json:65,keyword:73,kombu:[2,4,5,6,7,8,9,10,11,12,13,14,15,16,17,18,19,20,21,22,23,24,25,26,27,28,29,30,31,32,33,34,35,36,37,38,39,40,41,42,43,44,45,46,47,48,49,50,51,52,53,54,55,56,57,58,59,60,61,62,63,64,65,66,67,68,69,70,71,72],kombubrok:49,librabbitmq:45,licens:3,limit:[50,66,79],list:3,log:27,logic:21,loop:[7,14,18],mail:3,mailbox:31,manag:[33,56],match:28,matcher:28,memori:[46,53],messag:[1,5,12,24,29,34,35,41,48,50,53,78,82],method:5,mixin:[30,74],model:52,modul:64,mongodb:47,node:31,o:62,object:[29,67,81],off:38,oper:76,option:[37,39,40,44,47,48,49,50,51,52,55],other:38,overview:[3,34],pattern:28,persist:35,pickl:81,pidbox:31,point:81,polici:38,poll:38,pool:[25,32,79],predefin:38,prioriti:74,produc:[5,32,76,79,80],properti:67,publish:23,pure:48,pyamqp:48,pycurl:17,pypi:50,pyro:49,python:[48,50,58],q:1,qpid:50,qualiti:53,question:1,queue:[5,13,38,40,75],quick:3,rabbitmq:[56,74],rate:66,raw:81,receiv:82,redi:51,refer:[4,74,80],registri:[24,28,34],reject:1,reliabl:78,requeu:1,reset:79,resourc:33,rout:80,scenario:78,schedul:68,secur:81,selector:62,semaphor:19,send:[81,82],sentinelchannel:51,serial:[34,80,81],servic:[39,53],setuptool:81,sever:74,simpl:[35,82],singl:74,slmq:37,sq:[10,11,12,13,38],sqlalchemi:52,start:3,state:53,storag:40,string:[37,39,40,42,43,44,46,47,48,49,51,52,55,61],style:63,support:38,synchron:21,system:44,t:1,tabl:2,task:75,terminolog:3,text:69,thi:38,time:70,timer:20,tl:48,topic:[54,74],tracker:3,transport:[3,4,36,37,38,39,40,41,42,43,44,45,46,47,48,49,50,51,52,53,54,55,73],url:[71,73],us:[48,80,81],user:77,util:[4,14,22,56,57,58,59,60,61,62,63,64,65,66,67,68,69,70,71,72],utilitit:69,uuid:72,virtual:[53,54],what:78,without:81,work:1,world:75,zookeep:55}})