python-kombu-doc 1.4.3-1 / usr / share / doc / python-kombu-doc / html / searchindex.js

Search.setIndex({objects:{"kombu.transport.SQS.Channel":{transport_options:[6,3,1,""],conninfo:[6,3,1,""],exchange_delete:[6,1,1,""],basic_ack:[6,1,1,""],close:[6,1,1,""],sqs:[6,3,1,""],supports_fanout:[6,3,1,""],region:[6,3,1,""],entity_name:[6,1,1,""],basic_cancel:[6,1,1,""],basic_consume:[6,1,1,""],sdb:[6,3,1,""],table:[6,3,1,""],get_table:[6,1,1,""],Table:[6,5,1,""],get_exchanges:[6,1,1,""],visibility_timeout:[6,3,1,""]},"kombu.connection.ChannelPool":{release:[45,1,1,""],acquire:[45,1,1,""],LimitExceeded:[45,3,1,""]},"kombu.transport.virtual.scheduling.FairCycle":{close:[40,1,1,""],get:[40,1,1,""]},"kombu.transport.pycouchdb.Transport":{Channel:[35,5,1,""]},"kombu.transport.SQS.Transport.Channel":{transport_options:[6,3,1,""],conninfo:[6,3,1,""],Table:[6,5,1,""],exchange_delete:[6,1,1,""],basic_ack:[6,1,1,""],entity_name:[6,1,1,""],sqs:[6,3,1,""],supports_fanout:[6,3,1,""],region:[6,3,1,""],basic_cancel:[6,1,1,""],basic_consume:[6,1,1,""],sdb:[6,3,1,""],close:[6,1,1,""],get_table:[6,1,1,""],table:[6,3,1,""],get_exchanges:[6,1,1,""],visibility_timeout:[6,3,1,""]},"kombu.simple.SimpleBuffer":{queue_opts:[42,3,1,""],qsize:[42,1,1,""],producer:[42,3,1,""],get:[42,1,1,""],clear:[42,1,1,""],get_nowait:[42,1,1,""],queue:[42,3,1,""],exchange_opts:[42,3,1,""],channel:[42,3,1,""],put:[42,1,1,""],close:[42,1,1,""],consumer:[42,3,1,""],no_ack:[42,3,1,""],"__len__":[42,1,1,""]},"kombu.transport.virtual.Channel":{do_restore:[2,3,1,""],qos:[2,3,1,""],basic_ack:[2,1,1,""],basic_reject:[2,1,1,""],basic_get:[2,1,1,""],close:[2,1,1,""],basic_recover:[2,1,1,""],exchange_declare:[2,1,1,""],exchange_delete:[2,1,1,""],queue_bind:[2,1,1,""],drain_events:[2,1,1,""],state:[2,3,1,""],basic_publish:[2,1,1,""],basic_consume:[2,1,1,""],queue_delete:[2,1,1,""],queue_declare:[2,1,1,""],queue_purge:[2,1,1,""],basic_qos:[2,1,1,""],basic_cancel:[2,1,1,""],message_to_python:[2,1,1,""],get_table:[2,1,1,""],exchange_types:[2,3,1,""],flow:[2,1,1,""],"typeof":[2,1,1,""],Message:[2,3,1,""],prepare_message:[2,1,1,""]},"kombu.transport.virtual.scheduling":{FairCycle:[40,5,1,""]},"kombu.pidbox.Mailbox":{Node:[34,1,1,""],abcast:[34,1,1,""],get_reply_queue:[34,1,1,""],exchange:[34,3,1,""],multi_call:[34,1,1,""],namespace:[34,3,1,""],cast:[34,1,1,""],connection:[34,3,1,""],call:[34,1,1,""],get_queue:[34,1,1,""],reply_exchange:[34,3,1,""],type:[34,3,1,""]},"kombu.simple.SimpleQueue":{queue_opts:[42,3,1,""],qsize:[42,1,1,""],producer:[42,3,1,""],get:[42,1,1,""],clear:[42,1,1,""],get_nowait:[42,1,1,""],queue:[42,3,1,""],exchange_opts:[42,3,1,""],channel:[42,3,1,""],put:[42,1,1,""],close:[42,1,1,""],consumer:[42,3,1,""],no_ack:[42,3,1,""],"__len__":[42,1,1,""]},"kombu.transport.virtual.exchange.ExchangeType":{equivalent:[37,1,1,""],lookup:[37,1,1,""],prepare_bind:[37,1,1,""]},"kombu.transport.virtual.Message.MessageStateError":{message:[2,3,1,""],args:[2,3,1,""]},"kombu.transport.SQS.Transport":{Channel:[6,5,1,""]},"kombu.transport":{pyamqplib:[4,0,1,""],SQS:[6,0,1,""],mongodb:[5,0,1,""],resolve_transport:[8,4,1,""],pyredis:[32,0,1,""],virtual:[2,0,1,""],TRANSPORT_ALIASES:[8,2,1,""],DEFAULT_TRANSPORT:[8,2,1,""],base:[25,0,1,""],get_transport_cls:[8,4,1,""],memory:[13,0,1,""],pycouchdb:[35,0,1,""]},"kombu.pidbox":{Node:[34,5,1,""],Mailbox:[34,5,1,""]},"kombu.pools":{reset:[30,4,1,""],PoolGroup:[30,5,1,""],ProducerPool:[30,5,1,""],register_group:[30,4,1,""],get_limit:[30,4,1,""],set_limit:[30,4,1,""]},"kombu.transport.base.Message":{body:[25,3,1,""],ack:[25,1,1,""],delivery_info:[25,3,1,""],acknowledged:[25,3,1,""],properties:[25,3,1,""],decode:[25,1,1,""],headers:[25,3,1,""],content_encoding:[25,3,1,""],content_type:[25,3,1,""],reject:[25,1,1,""],delivery_tag:[25,3,1,""],requeue:[25,1,1,""],payload:[25,3,1,""],channel:[25,3,1,""]},"kombu.compat.Publisher":{revive:[44,1,1,""],send:[44,1,1,""],publish:[44,1,1,""],release:[44,1,1,""],close:[44,1,1,""],declare:[44,1,1,""]},"kombu.connection.ConnectionPool":{release:[45,1,1,""],acquire:[45,1,1,""],LimitExceeded:[45,3,1,""]},"kombu.transport.pyredis.Transport":{Channel:[32,5,1,""]},"kombu.transport.pyamqplib.Transport":{verify_connection:[4,1,1,""],drain_events:[4,1,1,""],establish_connection:[4,1,1,""],default_connection_params:[4,3,1,""],Connection:[4,5,1,""],create_channel:[4,1,1,""],close_connection:[4,1,1,""]},"kombu.utils.log.NullHandler":{emit:[1,1,1,""]},"kombu.transport.pycouchdb.Transport.Channel":{client:[35,3,1,""]},"kombu.connection.BrokerConnection":{SimpleBuffer:[45,1,1,""],info:[45,1,1,""],create_transport:[45,1,1,""],SimpleQueue:[45,1,1,""],get_transport_cls:[45,1,1,""],channel_errors:[45,3,1,""],drain_events:[45,1,1,""],transport:[45,3,1,""],host:[45,3,1,""],ChannelPool:[45,1,1,""],connection:[45,3,1,""],connection_errors:[45,3,1,""],ensure:[45,1,1,""],Pool:[45,1,1,""],ensure_connection:[45,1,1,""],release:[45,1,1,""],clone:[45,1,1,""],channel:[45,1,1,""],connect:[45,1,1,""]},"kombu.entity":{Queue:[21,5,1,""],Exchange:[21,5,1,""]},"kombu.transport.SQS":{Channel:[6,5,1,""],Transport:[6,5,1,""]},"kombu.transport.SQS.Channel.Table":{routes_for:[6,1,1,""],queue_bind:[6,1,1,""],create_binding:[6,1,1,""],select:[6,1,1,""],queue_delete:[6,1,1,""],exchange_delete:[6,1,1,""],get_exchanges:[6,1,1,""],get_item:[6,1,1,""],get_queue:[6,1,1,""]},"kombu.transport.pyamqplib":{Transport:[4,5,1,""],Connection:[4,5,1,""],Message:[4,5,1,""],Channel:[4,5,1,""]},"kombu.utils.finalize.Finalize":{cancel:[26,1,1,""],still_active:[26,1,1,""]},"kombu.serialization":{register:[9,4,1,""],decode:[9,4,1,""],registry:[9,2,1,""],encode:[9,4,1,""],raw_encode:[9,4,1,""],SerializerNotInstalled:[9,6,1,""]},"kombu.transport.mongodb.Transport":{Channel:[5,5,1,""]},"kombu.utils.limits.TokenBucket":{timestamp:[47,3,1,""],fill_rate:[47,3,1,""],capacity:[47,3,1,""],can_consume:[47,1,1,""],expected_time:[47,1,1,""]},"kombu.transport.pyamqplib.Message":{body:[4,3,1,""],delivery_tag:[4,3,1,""],channel:[4,3,1,""]},"kombu.transport.virtual.Transport":{close_channel:[2,1,1,""],drain_events:[2,1,1,""],interval:[2,3,1,""],establish_connection:[2,1,1,""],close_connection:[2,1,1,""],state:[2,3,1,""],create_channel:[2,1,1,""],default_port:[2,3,1,""],cycle:[2,3,1,""],Channel:[2,3,1,""],Cycle:[2,3,1,""]},"kombu.compat":{Publisher:[44,5,1,""],Consumer:[44,5,1,""],ConsumerSet:[44,5,1,""]},"kombu.transport.virtual.exchange.FanoutExchange":{deliver:[37,1,1,""],lookup:[37,1,1,""]},"kombu.utils.limits":{TokenBucket:[47,5,1,""]},"kombu.transport.mongodb.Transport.Channel":{close:[5,1,1,""],client:[5,3,1,""]},"kombu.transport.memory.Transport":{state:[13,3,1,""],Channel:[13,5,1,""]},"kombu.messaging.Producer":{compression:[24,3,1,""],exchange:[24,3,1,""],serializer:[24,3,1,""],revive:[24,1,1,""],publish:[24,1,1,""],routing_key:[24,3,1,""],auto_declare:[24,3,1,""],on_return:[24,3,1,""],declare:[24,1,1,""],channel:[24,3,1,""]},"kombu.transport.SQS.Transport.Channel.Table":{routes_for:[6,1,1,""],queue_bind:[6,1,1,""],create_binding:[6,1,1,""],queue_delete:[6,1,1,""],get_item:[6,1,1,""],exchange_delete:[6,1,1,""],get_exchanges:[6,1,1,""],select:[6,1,1,""],get_queue:[6,1,1,""]},"kombu.common":{Broadcast:[10,5,1,""],maybe_declare:[10,4,1,""],entry_to_queue:[10,4,1,""]},"kombu.transport.pyamqplib.Connection":{dispatch_method:[4,1,1,""],drain_events:[4,1,1,""],wait_multi:[4,1,1,""],read_timeout:[4,1,1,""],close:[4,1,1,""],channel:[4,1,1,""],wait:[4,1,1,""]},"kombu.transport.virtual.QoS":{get:[2,1,1,""],ack:[2,1,1,""],restore_unacked:[2,1,1,""],restore_unacked_once:[2,1,1,""],prefetch_count:[2,3,1,""],can_consume:[2,1,1,""],reject:[2,1,1,""],append:[2,1,1,""]},"kombu.transport.pyredis":{Channel:[32,5,1,""],Transport:[32,5,1,""]},"kombu.transport.virtual.Message":{ack:[2,1,1,""],MessageStateError:[2,6,1,""],acknowledged:[2,3,1,""],serializable:[2,1,1,""],decode:[2,1,1,""],reject:[2,1,1,""],requeue:[2,1,1,""],payload:[2,3,1,""]},"kombu.pidbox.Node":{handle:[34,1,1,""],handlers:[34,3,1,""],dispatch_from_message:[34,1,1,""],hostname:[34,3,1,""],handle_call:[34,1,1,""],dispatch:[34,1,1,""],mailbox:[34,3,1,""],state:[34,3,1,""],handler:[34,1,1,""],handle_cast:[34,1,1,""],handle_message:[34,1,1,""],reply:[34,1,1,""],Consumer:[34,1,1,""],channel:[34,3,1,""],listen:[34,1,1,""]},"kombu.exceptions":{TimeoutError:[0,6,1,""],MessageStateError:[0,6,1,""],ConnectionLimitExceeded:[0,6,1,""],LimitExceeded:[0,6,1,""],ChannelLimitExceeded:[0,6,1,""],NotBoundError:[0,6,1,""]},"kombu.transport.memory":{Transport:[13,5,1,""],Channel:[13,5,1,""]},"kombu.utils.finalize":{Finalize:[26,5,1,""]},"kombu.pools.ProducerPool":{prepare:[30,1,1,""],Producer:[30,1,1,""],setup:[30,1,1,""],release:[30,1,1,""],"new":[30,1,1,""],create_producer:[30,1,1,""]},"kombu.transport.base.Transport":{close_channel:[25,1,1,""],channel_errors:[25,3,1,""],drain_events:[25,1,1,""],establish_connection:[25,1,1,""],client:[25,3,1,""],connection_errors:[25,3,1,""],create_channel:[25,1,1,""],default_port:[25,3,1,""],close_connection:[25,1,1,""]},"kombu.clocks":{LamportClock:[22,5,1,""]},"kombu.transport.memory.Transport.Channel":{after_reply_message_received:[13,1,1,""]},"kombu.pools.PoolGroup":{create:[30,1,1,""]},"kombu.transport.pycouchdb":{create_message_view:[35,4,1,""],Channel:[35,5,1,""],Transport:[35,5,1,""]},"kombu.transport.pyamqplib.Channel.Message":{body:[4,3,1,""],delivery_tag:[4,3,1,""],channel:[4,3,1,""]},"kombu.transport.virtual.exchange.TopicExchange":{wildcards:[37,3,1,""],deliver:[37,1,1,""],lookup:[37,1,1,""],prepare_bind:[37,1,1,""],key_to_pattern:[37,1,1,""]},"kombu.messaging.Consumer":{qos:[24,1,1,""],consume:[24,1,1,""],register_callback:[24,1,1,""],callbacks:[24,3,1,""],receive:[24,1,1,""],queues:[24,3,1,""],cancel_by_queue:[24,1,1,""],flow:[24,1,1,""],revive:[24,1,1,""],declare:[24,1,1,""],purge:[24,1,1,""],cancel:[24,1,1,""],auto_declare:[24,3,1,""],on_decode_error:[24,3,1,""],recover:[24,1,1,""],no_ack:[24,3,1,""],channel:[24,3,1,""]},"kombu.transport.mongodb.Channel":{close:[5,1,1,""],client:[5,3,1,""]},"kombu.transport.pyamqplib.Channel":{basic_cancel:[4,1,1,""],basic_consume:[4,1,1,""],message_to_python:[4,1,1,""],close:[4,1,1,""],Message:[4,5,1,""],prepare_message:[4,1,1,""]},"kombu.utils.compat.CompatOrderedDict":{fromkeys:[16,7,1,""],setdefault:[16,1,1,""],keys:[16,1,1,""],items:[16,1,1,""],clear:[16,1,1,""],popitem:[16,1,1,""],update:[16,1,1,""],pop:[16,1,1,""],values:[16,1,1,""],itervalues:[16,1,1,""],iteritems:[16,1,1,""],copy:[16,1,1,""],iterkeys:[16,1,1,""]},"kombu.transport.virtual.BrokerState":{bindings:[2,3,1,""],exchanges:[2,3,1,""]},"kombu.transport.virtual.exchange.DirectExchange":{lookup:[37,1,1,""],deliver:[37,1,1,""]},"kombu.connection":{ChannelPool:[45,5,1,""],ConnectionPool:[45,5,1,""],BrokerConnection:[45,5,1,""]},"kombu.transport.pycouchdb.Channel":{client:[35,3,1,""]},"kombu.compat.ConsumerSet":{add_queue:[44,1,1,""],add_consumer_from_dict:[44,1,1,""],iterconsume:[44,1,1,""],add_consumer:[44,1,1,""],consume:[44,1,1,""],register_callback:[44,1,1,""],receive:[44,1,1,""],flow:[44,1,1,""],revive:[44,1,1,""],cancel_by_queue:[44,1,1,""],purge:[44,1,1,""],consuming_from:[44,1,1,""],discard_all:[44,1,1,""],cancel:[44,1,1,""],close:[44,1,1,""],recover:[44,1,1,""],declare:[44,1,1,""],qos:[44,1,1,""]},"kombu.abstract.MaybeChannelBound":{is_bound:[19,3,1,""],when_bound:[19,1,1,""],bind:[19,1,1,""],revive:[19,1,1,""],maybe_bind:[19,1,1,""],channel:[19,3,1,""]},"kombu.entity.Queue":{queue_bind:[21,1,1,""],unbind:[21,1,1,""],when_bound:[21,1,1,""],consume:[21,1,1,""],name:[21,3,1,""],get:[21,1,1,""],auto_delete:[21,3,1,""],durable:[21,3,1,""],routing_key:[21,3,1,""],exclusive:[21,3,1,""],purge:[21,1,1,""],alias:[21,3,1,""],queue_arguments:[21,3,1,""],maybe_bind:[21,1,1,""],channel:[21,3,1,""],binding_arguments:[21,3,1,""],cancel:[21,1,1,""],queue_declare:[21,1,1,""],declare:[21,1,1,""],exchange:[21,3,1,""],"delete":[21,1,1,""]},"kombu.transport.pyredis.Transport.Channel":{client:[32,3,1,""],active_queues:[32,3,1,""],subclient:[32,3,1,""],basic_cancel:[32,1,1,""],basic_consume:[32,1,1,""],get_table:[32,1,1,""],close:[32,1,1,""]},"kombu.entity.Exchange":{name:[21,3,1,""],auto_delete:[21,3,1,""],delivery_mode:[21,3,1,""],publish:[21,1,1,""],declare:[21,1,1,""],maybe_bind:[21,1,1,""],arguments:[21,3,1,""],Message:[21,1,1,""],type:[21,3,1,""],durable:[21,3,1,""],channel:[21,3,1,""],"delete":[21,1,1,""]},"kombu.utils.log":{get_logger:[1,4,1,""],NullHandler:[1,5,1,""]},"kombu.abstract":{MaybeChannelBound:[19,5,1,""]},"kombu.mixins.ConsumerMixin":{info:[20,1,1,""],run:[20,1,1,""],consume:[20,1,1,""],on_iteration:[20,1,1,""],restart_limit:[20,3,1,""],get_consumers:[20,1,1,""],on_consume_ready:[20,1,1,""],on_connection_error:[20,1,1,""],on_connection_revived:[20,1,1,""],error:[20,1,1,""],extra_context:[20,1,1,""],Consumer:[20,1,1,""]},"kombu.simple":{SimpleBuffer:[42,5,1,""],SimpleQueue:[42,5,1,""]},"kombu.transport.memory.Channel":{after_reply_message_received:[13,1,1,""]},"kombu.transport.virtual.exchange":{DirectExchange:[37,5,1,""],ExchangeType:[37,5,1,""],FanoutExchange:[37,5,1,""],TopicExchange:[37,5,1,""]},"kombu.compression":{encoders:[36,4,1,""],get_encoder:[36,4,1,""],register:[36,4,1,""],compress:[36,4,1,""],decompress:[36,4,1,""],get_decoder:[36,4,1,""]},kombu:{compat:[44,0,1,""],compression:[36,0,1,""],simple:[42,0,1,""],pools:[30,0,1,""],"abstract":[19,0,1,""],mixins:[20,0,1,""],syn:[7,0,1,""],entity:[21,0,1,""],exceptions:[0,0,1,""],connection:[45,0,1,""],clocks:[22,0,1,""],common:[10,0,1,""],messaging:[24,0,1,""],pidbox:[34,0,1,""],serialization:[9,0,1,""],utils:[31,0,1,""],transport:[8,0,1,""]},"kombu.utils.debug":{setup_logging:[41,4,1,""],Logwrapped:[41,5,1,""]},"kombu.clocks.LamportClock":{forward:[22,1,1,""],adjust:[22,1,1,""],value:[22,3,1,""]},"kombu.transport.pyamqplib.Transport.Connection":{read_timeout:[4,1,1,""],drain_events:[4,1,1,""],wait_multi:[4,1,1,""],channel:[4,1,1,""]},"kombu.transport.virtual":{QoS:[2,5,1,""],exchange:[37,0,1,""],BrokerState:[2,5,1,""],Transport:[2,5,1,""],scheduling:[40,0,1,""],AbstractChannel:[2,5,1,""],Message:[2,5,1,""],Channel:[2,5,1,""]},"kombu.syn":{select_blocking_method:[7,4,1,""],detect_environment:[7,4,1,""],blocking:[7,4,1,""]},"kombu.transport.mongodb":{Channel:[5,5,1,""],Transport:[5,5,1,""]},"kombu.compat.Consumer":{add_queue:[44,1,1,""],iterconsume:[44,1,1,""],qos:[44,1,1,""],process_next:[44,1,1,""],register_callback:[44,1,1,""],receive:[44,1,1,""],consume:[44,1,1,""],flow:[44,1,1,""],cancel_by_queue:[44,1,1,""],revive:[44,1,1,""],purge:[44,1,1,""],consuming_from:[44,1,1,""],discard_all:[44,1,1,""],fetch:[44,1,1,""],cancel:[44,1,1,""],close:[44,1,1,""],iterqueue:[44,1,1,""],recover:[44,1,1,""],declare:[44,1,1,""],wait:[44,1,1,""]},"kombu.messaging":{Consumer:[24,5,1,""],Producer:[24,5,1,""]},"kombu.utils":{reprcall:[31,4,1,""],kwdict:[31,4,1,""],maybe_list:[31,4,1,""],encoding:[3,0,1,""],functional:[11,0,1,""],rpartition:[31,4,1,""],uuid4:[31,4,1,""],HashingDict:[31,5,1,""],compat:[16,0,1,""],log:[1,0,1,""],gen_unique_id:[31,4,1,""],emergency_dump_state:[31,4,1,""],cached_property:[31,3,1,""],finalize:[26,0,1,""],fxrange:[31,4,1,""],retry_over_time:[31,4,1,""],reprkwargs:[31,4,1,""],uuid:[31,4,1,""],limits:[47,0,1,""],partition:[31,4,1,""],say:[31,4,1,""],debug:[41,0,1,""],fxrangemax:[31,4,1,""]},"kombu.utils.encoding":{safe_repr:[3,4,1,""],safe_str:[3,4,1,""],default_encoding:[3,4,1,""],str_to_bytes:[3,4,1,""],bytes_to_str:[3,4,1,""]},"kombu.transport.pyredis.Channel":{client:[32,3,1,""],active_queues:[32,3,1,""],subclient:[32,3,1,""],basic_cancel:[32,1,1,""],basic_consume:[32,1,1,""],get_table:[32,1,1,""],close:[32,1,1,""]},"kombu.mixins":{ConsumerMixin:[20,5,1,""]},"kombu.utils.compat":{LifoQueue:[16,5,1,""],CompatOrderedDict:[16,5,1,""]},"kombu.transport.base":{Message:[25,5,1,""],Transport:[25,5,1,""]}},terms:{fanoutexchang:37,represent:24,all:[24,39,14,2,4,15,17,6,21,44,37,46,16],concept:14,broke:39,snif:39,selinux:39,get_reply_queu:34,consum:[23,24,34,39,14,2,40,15,28,42,18,20,21,44,10,47],pluggabl:14,interchang:23,four:[14,21],unseri:9,overrid:[44,24],code:[4,46,47],sleep:[31,45,39],video_queu:14,abil:14,follow:[24,39,14,15,44,22],disk:21,forget:17,content:[39,12,25,9,4,15,24,44],typeerror:31,depend:[0,39,14,17,21,45],aspn:47,base64:[15,39],descript:21,send:[23,24,34,9,14,46,4,15,29,17,21,44,22,39],articl:[14,46,21],dispatch_from_messag:34,init:34,program:15,certain:39,body_encod:39,under:[14,46],sens:21,midpri:28,spec:[44,24],movsisyan:39,suitabl:9,passiv:[2,39,21],mpg:23,global:[44,24,46,13,39],everi:[39,14,15,31,46,10],string:[12,24,3,39,15,17,18,8,21,45,9],fals:[30,24,2,39,17,31,21,44,45,16],register_group:30,later:[17,39],none:[23,24,25,26,2,4,41,34,16,30,31,6,20,8,21,44,42,45,9,39,10],forker:39,util:[11,12,36,9,26,3,40,28,16,18,19,7,1,47,31,10,41],wikipedia:[14,22,47],fan:14,cellular:46,failur:[25,4,39],drain_ev:[34,25,39,14,2,4,45],affect:[14,24,44,39],ticket:34,exact:37,recip:47,on_connection_reviv:20,iterconsum:44,level:[14,23,46,1],did:39,exchange_opt:[42,45],basic_qo:2,messagestateerror:[0,2,25],list:[39,24,9,14,27,15,36,17,45,10],exchangetyp:37,rabbitmq:[24,39,14,27,21,44],"try":[0,24,31,34,39],item:[9,45,6,16],entity_nam:6,race:39,maxsiz:16,default_port:[2,25],quick:14,use_default_limit:46,"__copy__":39,prepar:[30,2,31],pleas:[14,39],experienc:39,impli:21,when_bound:[19,21],slower:15,skvazh:39,still_act:26,sync:[14,22],second:[17,31,47,45,39],video:[14,23],pass:[34,24,9,39,15,17,31,44,45],download:14,run:[20,28,39],port:[25,39,14,2,17,45],append:2,compat:[11,12,39,14,15,18,44,16],index:[14,12],what:[46,39],establish_connect:[2,25,4],routes_for:6,sub:[14,17],rate:[12,47,18],eventlet:[7,39],repli:[34,4,21],get_logg:1,connection_error:[25,45,39],abl:[46,39],brief:27,access:[2,39,21],delet:[24,39,14,2,4,31,6,21,44,45,10],version:[14,31,16,39],key_to_pattern:37,"new":[24,9,14,2,39,36,30,21,44,45,46,16,47],ever:[39,21],method:[0,24,25,9,2,4,15,36,17,7,21,44,34,37,39,45],requeu:[44,2,25,27,24],transport_alias:8,full:[14,8],hash:[14,21],timeouterror:0,iteritem:16,join:14,gener:[34,12,39,30,18,31,21],error:[23,25,39,3,4,20,21,45],onli:[23,9,39,14,2,17,21,22],here:[23,46,10],behaviour:39,unstabl:39,let:46,pub:[14,17],address:45,path:[17,8,39],along:[44,24],becom:39,modifi:21,hipri:28,valu:[24,39,2,4,17,31,21,22,46,16],wait:[24,14,4,7,21,44,45],convert:[2,4,39],produc:[23,12,29,24,14,39,28,15,17,18,30,44,42,45,46],sender:[4,22],configuar:14,serializat:39,host:[17,45,39],delivery_tag:[2,25,4,6],queue:[23,24,25,13,39,14,2,28,32,29,17,18,6,21,44,42,45,37,10],jame:39,chauvet:39,base:[9,25,12,2,39,18,37],def:[23,34,14,28,31,45],within:[44,24],action:[31,39,21],implement:[39,14,2,27,17,45,37,47],fxrangemax:31,rafael:39,chanc:[31,40],amqplain:39,semant:[45,39],via:[14,17,39],regardless:45,str_to_byt:3,reiniti:39,modul:[12,45,15,39],aquir:39,layer:14,put:[23,2,25,42],beanstalk:[14,17,39],api:[2,39,18,12],celerybeat:34,token_bucket:47,suddenli:39,instal:[14,12,39,9],redi:[39,14,32,17,37,46],simultaen:[0,45],establish:[17,19,4,45,39],"byte":39,select:[2,25,6,7,39],highli:14,regex:37,usd:[14,21],from:[23,24,25,26,14,2,46,4,40,28,17,6,21,44,42,45,22,39,16,47],login_method:[45,39],would:[9,39],memori:[12,13,39,14,2,17,18,21],eletzhof:39,method_sig:4,regist:[44,24,9,15,36],upgrad:39,coverag:46,next:[31,39],handler:[34,26],call:[0,23,24,14,39,34,17,19,7,21,44,45,46],until:[24,31,21,44,45,46],header:[24,25,39,2,4,15,42,21,44,37],criteria:21,msg:[4,20],"_queue_bind":37,prev:37,type:[34,24,25,9,14,2,39,40,15,28,17,44,7,21,36,37],forcefulli:39,science_new:21,more:[0,1,2,3,4,5,6,7,8,9,16,13,14,15,10,19,20,21,22,24,25,26,36,30,31,32,34,35,37,39,40,41,42,44,45,47],prefetch_s:[44,2,24],desir:15,classmethod:16,reprkwarg:31,faircycl:[2,40],get_exchang:6,treat:21,relat:[22,39],pyyaml:[9,39],ctype:39,simplebuff:[23,42,45,39],warn:[44,24,45,47,39],seral:39,flag:[42,2,19,24,21],"transient":[23,45,39,21],message_to_python:[2,4,39],rabbit:14,aris:23,known:39,obj:[45,26],hold:21,arg:[31,26,2,4,28,32,30,19,6,20,7,44,16],set_limit:[30,46,39],content_typ:[24,25,9,2,4,15,36,21,44],must:[24,25,39,14,2,4,17,31,21,44,45],annoy:14,topic:[14,17,21,37,18],account:39,word:[14,37,21],aws_secret_access_kei:39,restor:2,alia:[39,36,8,21],setup:[14,30],work:[17,27,15,39],uniqu:[39,31,4,10,21],histori:[12,39],default_transport:8,conceptu:22,remain:21,kwarg:[2,4,5,6,7,10,13,19,20,21,37,25,26,28,30,31,32,34,35,39,40,42,44,45],del:31,can:[23,24,25,9,14,2,46,4,15,17,19,45,21,44,31,22,39,10,47],pidbox:[34,12,18],root:[14,39],fetch:44,maybe_declar:[39,46,10,28],control:[44,24,39],close_channel:[2,25],stream:9,give:[24,39,31,6,21,44,45,46],process:[23,24,25,39,14,2,15,44,34,22,46],autodetect:[44,24],share:[17,37],dump_entri:23,accept:[44,24,39],high:[14,28],tag:[39,2,25,4,21],exchange_delet:[2,6],want:[39,9,24,2,4,15,17,46],tarbal:14,"__exit__":39,serial:[23,12,25,29,24,14,39,28,15,42,18,21,44,9,46],occur:[24,45,9,21],solem:[0,1,2,3,4,32,6,7,8,16,13,10,19,20,21,22,24,25,26,36,30,31,34,9,37,39,40,41,42,44,45,47],alwai:[14,17,45,39,21],cours:17,end:[44,24],unacknowledg:[44,2,24],secur:14,rather:[44,2,39,46,24],anoth:45,interval_step:[31,45],how:[31,45],purg:[44,24,21],"__init__":[23,28],conn:[23,39,14,28,45,46],reject:[2,25,27],answer:27,instead:[17,2,25,23,39],reviv:[44,24,19,39],simpl:[23,12,24,39,28,29,42,18,44,22],connect_timeout:[17,45],updat:[16,39],map:[34,24,2,8,44,37],product:39,subsecond:39,resourc:[30,39,4,40,17,45,46],reply_cod:4,librabbitmq:39,initial_valu:22,clone:[45,39],after:[24,39,14,4,17,46],constraint:15,befor:[14,31,22,46,45],wrong:39,wait_multi:4,known_host:39,reply_exchang:34,acquire_channel:39,date:[23,18,39,15,29],drastic:39,associ:[17,4,39,36,21],grow:46,demonstr:39,consistent_read:6,transist:17,github:14,attempt:[44,24],practic:17,ssl:[17,45,39],encapsul:4,seriou:39,counter:[4,22],credenti:39,correspond:[2,37,39],django:[14,39],issu:[14,4,46,39],callback:[23,24,34,26,14,2,39,28,19,21,44,45,31],maintain:[22,46,15],environ:[7,39],allow:[14,39],media:14,exclus:[44,21],mechan:[44,24],order:[24,16],queue_delet:[2,6],producerpool:[30,39],origin:[14,2,25,44,24],ingress:46,method_id:4,help:[14,12,16],media_exchang:14,queue_opt:[42,45],fall:[44,24],becaus:21,jpeg:15,handle_cal:34,image_queu:14,report:[14,39],hashingdict:31,reconnect:4,menual:14,undeliver:24,brokerconnect:[23,34,25,39,14,2,28,17,45,46],still:[44,24,39],warren:14,on_rev:[45,39],group:[30,46,29],uuid:[31,39],fit:15,itervalu:16,amqplib:[14,17,4,39],fix:[14,31,39],clymer:35,deliv:[44,24,37,21],reprcal:31,afer:19,window:[44,24],"_0123456789_______abcdefghijklmnopqrstuvwxyz______abcdefghijklmnopqrstuvwxyz____x7fx80x81x82x83x84x85x86x87x88x89x8ax8bx8cx8dx8ex8fx90x91x92x93x94x95x96x97x98x99x9ax9bx9cx9dx9ex9fxa0xa1xa2xa3xa4xa5xa6xa7xa8xa9xaaxabxacxadxaexafxb0xb1xb2xb3xb4xb5xb6xb7xb8xb9xbaxbbxbcxbdxbexbfxc0xc1xc2xc3xc4xc5xc6xc7xc8xc9xcaxcbxccxcdxcexcfxd0xd1xd2xd3xd4xd5xd6xd7xd8xd9xdaxdbxdcxddxdexdfxe0xe1xe2xe3xe4xe5xe6xe7xe8xe9xeaxebxecxedxeexefxf0xf1xf2xf3xf4xf5xf6xf7xf8xf9xfaxfbxfcxfdxfexff":6,requir:[23,37,39],persist:[23,39,42,18,21,45],python:[11,12,25,23,9,14,2,4,15,31,44,39,16,47],mail:[14,27],therefor:21,consumerset:[44,18,39],easier:17,epol:39,eur:[14,21],non:[14,2,21],good:15,"return":[34,24,25,9,2,39,28,15,31,36,21,37,16,47],greater:22,thei:[14,23,46,15,21],reveal:27,handl:[14,24,4,34,39],timestamp:[23,22,47],safe:47,as_dict:39,abcast:34,auth:39,detect_environ:[7,39],synopsi:[14,12],framework:[14,12],cet:39,automat:[24,39,14,21,44,45],restore_unacked_onc:2,now:[31,39,15,21],discuss:27,oper:[0,24,39,14,21,44,45],introduct:[14,18,34],interval_max:[31,45],multiprocess:26,document:[14,12,45,17,44],name:[23,24,34,9,14,39,36,42,31,6,8,21,44,45,10],anyth:[46,39],get_consum:[20,28],didn:39,userid:[17,45,39],authent:39,separ:[14,45,37,21],easili:[14,39],localis:4,reactiv:[44,24],mode:[39,21],timeout:[23,34,39,14,2,4,17,20,42,45,46],each:[2,40,15,31,21,45,22],debug:[12,41,39,28,18],found:21,unicod:[31,9,3,15],stock:[14,21],attributeerror:39,side:4,mean:[24,25,39,2,4,17,21,44,22,46],recommend:[45,39,21],memoryerror:39,send_as_task:28,redeliv:[44,24],replac:[44,3],individu:39,multipl:[17,46,39],discard_al:44,ensur:[14,2,19,45,39],realli:14,wrap:39,autent:39,default_connection_param:[4,39],expect:47,urlpars:39,our:[14,4,46,39,21],happen:[14,23,25,39],patch:[14,7,39],errror:14,orient:14,special:[14,9,46,21],out:[0,26,14,2,39,47],variabl:39,given:39,msgpack:[9,15],unbound:[0,14,21],emul:2,goe:2,open:[39,14,15,17,31,45],invaliddata:39,pika:[14,17,39],ret:39,payload:[14,2,25,23,28],max_retri:[31,45],adjust:22,cest:39,max:31,print:[23,14,28,31,45,46],gen_unique_id:31,correct:39,qualifi:8,directexchang:37,insid:15,advanc:[14,24,44],publish:[24,25,39,14,2,28,15,42,18,21,44,45,46],bound_sicence_new:21,domest:46,kilobyt:39,differ:[17,23,28,39],undo:[44,24],standard:[14,23,37,15,39],small:31,reason:[14,27],orm:14,mime:[9,36],process_task:28,dictionari:[9,15,16],latest:[14,39],ask:[0,1,2,3,4,32,6,7,8,16,12,13,14,10,19,20,21,22,24,25,26,27,36,30,31,34,9,37,39,40,41,42,44,45,47],org:[44,31,47,39],close_connect:[2,25,4],decompress:36,guest:[23,39,14,28,17,46],reset_aft:30,bound_exchang:[14,21],add_queue_from_dict:39,couldn:45,thread:[45,47,46,7,39],forc:[30,45,4,39],unwant:39,could:39,traceback:45,synchron:[12,2,18,7,21,22],fromtimestamp:23,david:[35,39],select_blocking_method:7,turn:39,channel_error:[25,45],turk:39,issue10272:39,outsid:14,log_messag:23,top:[14,39],frequent:[12,27],first:39,add_consumer_from_dict:44,softwar:[14,22],create_transport:45,slept:45,mixin:[12,39,28,18,19,20],directli:[2,39],christoph:39,exchange_declar:2,simple_task_queu:39,qualiti:[44,2,24,18],number:[0,24,39,2,17,31,44,45,47],basic_get:2,ziegler:39,feet:46,mai:[24,25,4,15,17,21,44,45,46,47],instruct:15,alreadi:[0,24,25,14,2,19,21,44,46],done:[44,2,45,24,21],messag:[0,2,4,6,12,14,15,17,18,21,37,23,24,25,27,29,28,34,9,22,39,42,44,45,46],blank:21,miss:15,primari:15,cutekitten:23,size:[14,24,44,39],prioriti:[24,2,4,28,21,44],is_bound:19,sourc:14,"long":[31,39,21],smaller:[44,24,15],castaneda:39,queue_bind:[2,6,21],restart_limit:20,unknown:39,licens:[0,1,2,3,4,5,6,7,8,9,16,12,13,14,10,19,20,21,22,24,25,26,36,30,31,32,34,35,37,40,41,42,44,45,47],safe_str:3,system:39,least:21,silenc:39,necessarili:21,just:[14,46,21],monkei:[7,39],statement:14,pavel:39,show:39,scheme:[14,15,21],"final":[34,12,39,18,26],store:[39,14,17,31,21,37],too:[14,46,39],premoli:5,option:[34,24,9,14,39,15,17,21,44,42,45,10],auto_delet:[39,2,37,44,21],bytes_to_str:3,namespac:34,detail:[0,1,2,3,4,5,6,7,8,9,16,13,14,10,19,20,21,22,24,25,26,36,30,31,32,34,35,37,40,41,42,44,45,47],eventio:39,message_data:[2,4],lower:39,specifi:[23,24,25,9,2,39,15,17,8,21,44,45,10],direct:[34,14,2,28,17,18,21,37],broadcast:[34,37,10],forward:[39,22,21],"short":4,consult:[17,45,8],basic_publish:2,than:[24,39,14,15,21,44,22,46],send_messag:39,conveni:[9,46,10],keyword:[39,29,17,31,45,10],cyclic:39,provid:[39,14,4,17,31,21,45,46],remov:[23,25,39,2,21,16],connectionpool:[45,46,39],uuid4:31,structur:[2,25,15,9],routing_kei:[34,24,14,2,28,15,42,6,21,44,45,37,46],project:14,loglevel:[28,41],info:[23,34,39,28,20,45],mongod:39,str:[24,39,9],were:[39,21],posit:31,design:21,minut:21,listen:[34,39],no_ack:[24,39,2,42,6,21,44,45],transport:[39,35,25,13,12,14,2,4,40,29,5,17,18,6,32,8,45,37],simpledb:[14,17,6,39],deliveri:[25,4,21],sai:31,stdin:45,kwdict:[31,28],abov:[23,15],enable_callback:44,januari:27,py2:39,modern:15,add_queu:44,argument:[23,24,34,39,2,29,17,31,21,44,45,37,46,10],raw:[9,25,2,15,29,21],pip:14,binding_argu:21,have:[23,24,39,14,15,17,31,21,44,45,46,10],"__main__":[23,28],need:[23,24,39,14,15,17,44,45,37,46],notimplementederror:[44,2,24],predic:40,contribut:[14,12,39],next_token:6,caus:[4,15,39],built:[14,31,15,8,21],zero:[14,24,44,21],inform:[25,21],destroi:39,latter:[23,9],mid:28,client:[34,35,25,13,24,14,2,4,28,5,17,6,32,21,44,39],note:[24,39,15,21,44,45,9,46],also:[24,39,14,15,17,21,44,45,22,46],without:[17,39,15,29,21],get_tabl:[37,2,6,32],take:[24,31,21],indic:[12,4],fmt:31,properti:[24,25,39,14,2,4,31,21,44],codec:39,channel:[0,2,4,5,6,10,13,14,15,17,18,19,20,21,37,23,24,25,28,32,34,35,39,41,42,44,45],even:[9,39,14,17,7,21],copi:[45,19,37,16],unless:9,distribut:[14,22,39],kombu_log_channel:39,usernam:[17,45],who:28,compress:[23,12,24,14,28,36,42,18,19,44,46],deleg:39,keyerror:39,priority_to_routing_kei:28,most:[14,45,47,21],beta:39,regular:14,brpop:39,pop:16,bsd:[0,1,2,3,4,5,6,7,8,9,16,13,14,10,19,20,21,22,24,25,26,36,30,31,32,34,35,37,40,41,42,44,45,47],process_media:14,"class":[1,2,4,5,6,8,10,12,13,15,16,17,18,19,20,21,22,23,24,25,26,28,30,31,32,34,35,37,39,40,41,42,44,45,47],often:46,lazili:45,on_consume_readi:20,bound:[34,39,14,19,21,37],marshal:9,don:[14,46,15,39],exc:[24,31,20,45],url:[17,45,29,39],entry_to_queu:[10,39],clock:[39,12,22,18],request:[44,24,45,4,9],dialogu:21,doe:[24,39,14,8,21,44],which:[23,24,39,4,15,17,21,44,46,16],basic_cancel:[2,4,6,32,39],runtim:46,determin:21,pattern:[14,6,21],usual:[34,2,45,9],gracefulli:14,translat:39,recipi:[44,24],type_to_nam:39,serializ:2,stefan:39,multi_cal:34,text:[14,25,4,36],handle_cast:34,speedup:15,syntax:39,after_reply_message_receiv:13,create_bind:6,identifi:[39,25,4,36,21],resolve_transport:8,data:[23,34,9,2,4,15,29,18,8,39],find:[44,24],setter:31,current:[23,24,39,2,34,42,19,7,21,44,45,22,46],fxrang:31,explicitli:[17,21],locat:39,acquir:[45,46,28,39],copyright:[0,1,2,3,4,5,6,7,8,9,16,13,10,19,20,21,22,24,25,26,36,30,31,32,34,35,37,39,40,41,42,44,45,47],kombu_log_connect:39,transact:2,configur:[14,17,45,39],releas:[30,39,29,17,18,44,45,46],forev:[31,46,45,39],should:[24,39,14,31,44,9,46,47],x00x01x02x03x04x05x06x07x08tnx0bx0crx0ex0fx10x11x12x13x14x15x16x17x18x19x1ax1bx1cx1dx1ex1f:6,latenc:39,dict:[17,45],"0x101805650":46,extra_context:20,local:[44,24,21],over:[31,15],pyredi:[12,32,18],reset:[30,46,39],move:[22,39],adher:2,unus:21,get:[23,12,14,2,40,36,42,31,6,8,21,45,37,46],kombu_log_debug:39,familiar:14,express:[15,39],lifoqueu:[16,39],nativ:[14,17,15],amazon:[14,6,39],cannot:4,fifo:[16,39],popitem:16,increas:[31,39],pipermail:27,get_queu:[34,6],event:[24,14,2,4,45,22],restart:21,dispatch_method:4,bound_science_new:21,item_nam:6,enabl:[24,39,2,42,44,45],held:[44,24],ack:[23,25,39,14,2,28],whenev:39,"public":30,rfc:4,channel_id:[4,39],cach:31,common:[12,39,14,28,18,21,46,10],partit:31,contain:[39,2,9,21],clean:46,where:[39,40,31,7,21,46],attapattu:21,wiki:47,set:[31,24,25,37,9,14,2,39,40,15,17,19,21,44,45,22,46],basic_ack:[2,6],allowed_method:4,sep:31,basic_reject:2,around:15,get_decod:36,nasdaq:[14,21],get_limit:30,see:[0,1,2,3,4,5,6,7,8,9,16,13,14,10,17,19,20,21,22,24,25,26,27,36,30,31,32,34,35,37,40,41,42,44,45,46,47],fanout:[34,39,14,17,18,21,37],mandatori:[44,24,39,21],result:[45,7,39],respons:[45,21],fail:4,close:[23,42,39,14,2,4,40,5,17,6,32,21,44,45,46],channel_or_connect:14,serializernotinstal:9,retriev:6,if_unus:[2,21],onc:[2,46],infinit:44,"____________":6,can_consum:[2,47],detect:[4,15],correctli:[4,39],hopefulli:31,databas:17,someth:[23,39],easi:14,particip:14,aws_access_key_id:39,unack:2,state:[34,13,2,18,31,21,37],won:21,mutex:22,logwrap:41,prefetch_count:[44,2,24],between:[24,39,2,31,21,44,45,22],register_callback:[14,24,44],"import":[23,39,14,28,17,21,46],awai:46,entiti:[0,12,24,39,18,21,46,10],across:14,attribut:[39,14,15,21,45,37],altern:[24,15,17,21,44,45],signatur:[44,24,39],limitexceed:[0,45],nowait:[2,21],pylibrabbitmq:39,kei:[23,24,39,14,2,21,44,45,37,16],as_uri:[46,39],default_seri:9,xrang:23,lamport:[22,39],flow:[44,2,24],mailbox:[34,18],pypi:[14,44,39],cycl:[2,15],prepare_messag:[2,4],len:42,conn2:46,distinguish:39,come:[23,39],conn1:46,alias:[17,36,8,39],both:[14,23,39,10,21],consumermixin:[20,28,39],last:[45,39,47,16,21],execed:45,tokensin:47,supports_fanout:[14,17,6,37,39],region:[6,39],equal:[44,24,40,16],against:46,emit:[1,39],connection_info:34,etc:[14,15],shortstr:4,instanc:[31,24,25,39,2,4,15,41,19,21,44,45,46,10],default_channel:39,context:[17,23,4,34,39],logic:[22,39],mani:[45,15,39],iterqueu:44,repeatlast:31,com:[14,27,47],scope:[2,26],simplequeu:[23,42,45,39],load:17,simpli:14,kwd:[20,16],cancer:21,point:2,instanti:[44,24,45,39],overview:[14,18,9],carrot:[14,44,15,39],insist:[17,45],solv:39,dispatch:[34,24,4,44],colon:45,provok:4,poolgroup:30,linux:39,on_decode_error:[24,39],respect:[46,39],poll:[2,39,21],assum:21,backend:[37,13,39],resynchron:22,ensure_connect:[45,39],creat:[23,30,39,34,17,19,6,21,45,46],why:27,yaml:[9,15],stamp:22,receiv:[23,24,25,14,4,29,17,21,44,42,22],due:[25,4],been:[0,24,25,39,14,2,44,45,46],sinc:15,compon:39,json:[23,9,39,14,15,24,46],much:31,autoretri:39,interpret:[14,21],basic:[17,23,39,29,24],raw_encod:9,queue_declar:[2,39,21],yadda:46,addit:[23,24,25,39,17,31,21,44,42,45,10],tokenbucket:47,ghettoq:39,"__len__":42,unregist:[9,39],field:[17,21],if_empti:[2,21],errno:39,get_transport_cl:[45,8],fill_rat:47,lifo:[16,39],duran:39,imag:[14,15],worker:28,search:12,mher:39,ani:[24,39,14,4,15,21,44,45,37,46],decim:15,doesn:[27,6],rememb:[14,45,16],uncknowledg:2,repres:9,former:23,convers:37,"case":[9,46,15,21],exchange_typ:[44,2],stolen:[47,21],queue_argu:21,process_next:44,packag:[14,9,44],plain:15,servic:[44,2,24,18],zlib:[46,28],harder:17,hello_task:28,aim:14,defin:[23,14,2,4,21,37,10],"while":[23,34,39,14,24,31],suport:[17,45],"typeof":2,create_channel:[2,25,4],eintr:39,fun:[34,40,28,31,7,45],aid:4,expected_tim:47,howev:[15,39],loop:45,transport_opt:[17,45,6,39],kombu:[0,1,2,3,4,5,6,7,8,9,16,11,12,13,14,10,17,18,19,20,21,22,23,24,25,26,28,36,30,31,32,34,35,37,39,40,41,42,44,45,46,47],conninfo:6,parse_qsl:39,ordereddict:39,increment:22,advantag:[15,21],cast:34,readi:[44,2,24],tabl:[12,39,14,2,17,6,8,21,37],henc:21,them:[14,17,23,21],jpg:15,destin:[34,21],notbounderror:[0,14],"default":[39,24,25,29,9,14,2,4,15,16,17,6,7,8,21,44,45,37,46,10],itself:[44,24,39],consuming_from:[44,39],avi:14,apply_glob:[44,2,24],incom:22,ascii:9,ship:[46,39],sever:[14,17],scienc:21,issue4978:31,weakref:26,incompat:39,develop:[14,39],welcom:14,author:[14,39],perform:[14,24,39,44,21],suggest:14,make:[23,39,14,17,31,7,21],couchdb:[14,35,17,39],exchang:[23,12,34,24,14,2,39,28,32,15,17,18,6,21,44,42,45,37,46,10],cross:15,same:[23,24,39,14,15,17,21,45,46],binari:[9,39,15,21],when:[23,24,25,26,14,2,4,15,17,19,8,21,44,31,22,39,45,47],html:27,decod:[24,25,9,2,39,36,15,18,44],capac:47,auto:[45,21,10,15],algorithm:[14,47,21],task_queu:28,start:[39,14,31,21,45,46],complet:45,iterkei:16,clear:[42,16],finish:[44,24,21],http:[39,14,27,31,44,47],hostnam:[17,23,45,34,39],charact:[14,9,37,21],hang:39,syn:[12,39,7,18],solut:14,fairli:[2,15],rais:[24,25,9,14,2,39,31,21,44,45,46],max_item:6,initi:[2,39],never:45,improv:[44,24],chang:[2,39,46,12],recent:[45,39],fromkei:16,drain:[2,24],kept:[14,17],equival:[23,37],polling_interv:39,older:[16,39],cjson:[15,39],whole:[44,24],reload_schedul:34,inherit:[2,39],thought:22,exampl:[23,12,34,9,14,39,28,29,17,31,21,45,37,46],command:[34,39],thi:[23,24,25,37,9,14,2,46,4,36,17,31,45,21,44,34,22,39,10,47],choos:17,queue_purg:2,loss:24,rout:[23,24,39,14,2,17,6,21,44,45,37],left:46,protocol:[14,37],basi:15,execut:26,object:[23,24,26,14,39,15,19,21,45,9,46,16],maybe_list:31,entri:[23,47],exclud:37,on_return:24,activ:[24,2,21,44,45,46],findandmodifi:39,percoco:5,part:[17,2,15,21],safety_interv:20,task_exchang:28,simultan:[0,45],yet:[17,27,39],languag:15,wether:17,task:[14,39,28,29],password:[17,45,39],emergency_dump_st:31,got:46,rpartit:31,consumer_tag:[39,2,4,32,6,21],raw_messag:[2,4],had:39,except:[0,12,24,14,2,4,40,15,18,31,45,9,39,46],shortcut:[23,45,39],blog:21,add:[14,39],cleanup:26,primit:[14,28,21],schedul:[12,40,18],sslerror:39,logger:[23,41,1,39],match:[14,37,4,39,21],app:46,default_encod:3,build:14,earli:46,applic:[34,9,25,14,21,46],dataerror:39,pyamqplib:[17,12,4,8,18],maybechannelbound:19,format:[17,6,39],preserv:21,term:[44,24],channelpool:[45,39],lolcat1:14,respond:[4,21],recov:[44,2,24],include_password:39,know:46,amq:[37,2,4],world:[28,39],bit:15,characterist:15,recurs:15,get_item:6,like:[14,23,46,15,21],insert:16,retry_over_tim:31,nice:24,paramet:[39,24,9,2,4,36,17,31,21,44,45,37,46,10],specif:[24,4,17,21,44,45,37],deprec:[45,39],rajith:21,arbitrari:[44,24,39],manual:[14,24,39,21],resolv:4,integ:[39,21],server:[24,25,39,14,2,4,17,21,44,45],basic_recov:2,from_dict:44,"boolean":15,necessari:39,either:[14,31,21],if_unusu:2,choic:15,popular:14,async:[34,12,39,14,18,7],unnecessari:9,manag:[2,46,39],two:[23,24,39,14,31,21,44,46],underli:[45,39],node:[34,18],exceed:[0,31,45,39],queue_nam:23,easy_instal:14,shutdown:2,acknowledg:[0,24,25,2,42,21,45],interv:[2,31,20,45],anyjson:39,some:[14,22,15,39],back:[2,25,4,46],self:[23,9,28,42,31,45],abstractchannel:2,shallow:16,intern:[31,4],sure:[31,7],with_stat:[23,28],restore_unack:2,read:[14,15,21],guarante:2,delivery_info:25,drop:39,log_queu:23,librari:[23,15,21],registri:[18,39,36,9],tmp:14,"__future__":[23,28],guid:[12,29],lead:39,collect:2,"function":[11,35,12,39,36,18,31,7,8,21,45,46],leak:39,tube:46,amqp_protocol_head:39,octet:[44,24],token:47,subclass:[44,2,24],subscrib:[44,24],bst:39,retri:[31,45],leav:[39,21],unit:14,slash:39,unbind:21,condit:[4,39],postencod:25,foo:17,notabl:15,overflow:[44,24],localhost:[23,39,14,28,17,45,46],refer:[12,39,15,18],preload:45,encourag:[14,17],previou:39,idiomat:14,uncompress:36,reach:31,ident:[14,41,21],usag:[45,22,39],broker:[24,39,2,4,21,44,45,46],properli:[39,21],do_restor:2,prefetch:[44,2,24],maybe_bind:[19,21],pickl:[14,9,28,15],although:[44,24,21],lamportclock:[22,39],peer:[44,24,4],"__name__":[23,28],post:21,appli:[44,24,45,39],sphinx:14,pycouchdb:[35,18,12],describ:[9,6,21],plug:14,comparison:[14,12,17,29],about:[14,27,46,21],nullhandl:1,central:9,socket:[23,45,39],valid:17,class_id:4,connectionlimitexceed:[0,45,46],verify_connect:4,slightli:23,delivery_mod:[44,24,39,21],page:12,create_message_view:35,includ:[22,15,8,39],disadvantag:15,constructor:[34,2,45],own:[25,39,17,21,22,46],discard:[2,25,4,45],errback:[31,45],disabl:[42,39,14,2,24,17,44,45,46],block:[23,39,28,42,7,45,46],topicexchang:37,qsize:42,activest:47,"float":15,encod:[23,12,25,24,14,3,4,15,36,18,21,44,9,39],domain:[14,6,21],terminolog:[14,12],three:9,down:[44,24,4],pair:[45,16,21],read_timeout:4,cancel_by_queu:[44,24,39],slight:15,empti:[39,21],contrib:39,dot:[14,37,21],your:[39,14,15,17,21,46],durabl:[14,2,21,44,45,37],per:[46,15,39],rkei:[37,15],on_iter:20,log:[23,12,39,4,18,1],wai:45,compatordereddict:16,transfer:15,refil:47,support:[24,41,9,14,2,39,15,28,17,21,44,45,37,46,10],question:[12,27],iter:[6,16],fast:15,custom:[39,14,29,15,21,46,10],avail:[9,24,14,39,36,17,21,44,45,46,47],lost:[39,21],singl:[23,24,39,31,21,45,37],setdefault:16,interfac:[23,12,25,39,14,29,42,18,44,45,37],low:28,myqueu:23,safe_repr:3,stai:14,myvhost:17,cancel:[34,24,26,14,2,39,21,44],record:1,fork:[46,39],sdb:6,monoton:22,tracker:[14,12],simplejson:15,auto_declar:[44,24,39],channellimitexceed:[0,45],tupl:[9,25,37,31],establis:39,colliss:31,taken:[17,47,26],aren:46,bodi:[34,24,25,9,14,2,4,28,36,21,44,39],link:46,gain:15,newer:31,larger:15,beat:34,shamelessli:21,line:45,safeguard:46,"true":[23,24,25,45,39,14,2,28,17,6,21,44,42,34,37,46,16,47],bug:[14,12,31,39],sent:[24,25,39,14,2,15,21,44],count:2,reappli:45,immedi:[44,24,45,21],utf:9,attr:31,consist:[14,21],possibl:[14,9,46,39],whether:21,best:[17,46,15],caller:45,bucket:47,maximum:[0,31,22,45,47],tell:17,on_connection_error:20,other:[24,4,15,17,44,22,16],gevent:[7,39],limit:[0,12,34,24,2,39,15,30,18,20,44,45,46,47],virtual_host:[17,45,39],basic_consum:[2,4,6,32],step:31,problem:[14,39],deadlock:46,delimit:21,care:46,connect:[0,2,4,5,6,12,13,14,17,18,19,20,21,23,24,25,28,29,30,31,34,35,39,41,44,45,46],"catch":31,featur:[14,12,39,24],add_consum:44,bind:[24,14,2,19,6,21,44,37],create_produc:30,myq:39,cover:21,"abstract":[2,19],filenam:23,proven:14,descriptor:31,novemb:[18,29],cure:21,contextlib:23,file:[14,45,15],behavior:39,shut:4,exist:[14,6,39,21],check:[17,39,21],probabl:15,otherwis:[44,24,21],again:[31,45],active_queu:32,wast:15,amqp:[23,12,24,14,46,4,28,17,19,6,21,44,9,39],content_encod:[24,25,9,2,4,15,21,44],buffer:[23,18,45,42],titl:[38,43,46,33],user:[14,12,23,29,39],excel:23,exitprior:26,virtual:[12,39,14,2,40,17,18,45,37],flavio:5,vendor:14,my_pictur:15,subclient:32,declar:[24,39,14,2,17,21,44,42,46],lookup:[37,39],get_encod:36,my_callback:14,better:15,test:[14,39],you:[23,24,25,9,14,2,39,15,17,21,45,46,10],visibility_timeout:6,reply_text:4,shrink:46,queu:14,deseri:[23,2,25,15,9],news_exchang:[46,21],star:[14,21],wildcard:[37,21],handle_messag:34,fulli:8,mongodb:[12,39,14,5,17,18],stop:[44,24,31],introduc:39,sqlalchemi:[14,39],setup_log:[28,41],datetim:23,drag:46,queri:[17,6],consid:22,previous:[36,39],safeti:47,lopri:28,configu:10,pool:[30,12,39,28,29,17,18,45,46],legal:6,prepare_bind:37,veri:[31,46,28],open_fil:31,longer:39,filterfunc:44,directori:[14,39],reliabl:14,crash:39,gethostnam:23,rule:[4,22],hello:[28,39],interval_start:[31,45],brokerst:2,get_nowait:42,ignor:[44,24,39],fact:46,potenti:[44,24,39],time:[0,23,39,31,45,22,46,47],reply_to:34,"0x89f0940":16,cookbook:47,dump:31,avoid:[44,24,39],cached_properti:31},objtypes:{"0":"py:module","1":"py:method","2":"py:data","3":"py:attribute","4":"py:function","5":"py:class","6":"py:exception","7":"py:classmethod"},titles:["kombu.exceptions","Logging - kombu.utils.log","kombu.transport.virtual","String Encoding - kombu.utils.encoding","kombu.transport.pyamqplib","kombu.transport.mongodb","kombu.transport.SQS","Async Utilities - kombu.syn","kombu.transport","kombu.serialization","Common Utilities - kombu.common","kombu.utils.functional","Kombu Documentation","kombu.transport.memory","kombu - AMQP Messaging Framework for Python","Serialization","Compat. utilities - kombu.utils.compat","Connections and transports","API Reference","kombu.compression","Mixin Classes - kombu.mixins","kombu.entity","Clocks and Synchronization - kombu.clocks","Simple Interface","kombu.messaging","kombu.transport.base","Finalize - kombu.utils.finalize","Frequently Asked Questions","Examples","User Guide","General Pools - kombu.pools","Utilities - kombu.utils","kombu.transport.pyredis","<no title>","kombu.pidbox","kombu.transport.pycouchdb","kombu.compression","kombu.transport.virtual.exchange","<no title>","Change history","kombu.transport.virtual.scheduling","Debugging - kombu.utils.debug","kombu.simple","<no title>","kombu.compat","kombu.connection","Connection and Producer Pools","Rate limiting - kombu.utils.limits"],objnames:{"0":["py","module","Python module"],"1":["py","method","Python method"],"2":["py","data","Python data"],"3":["py","attribute","Python attribute"],"4":["py","function","Python function"],"5":["py","class","Python class"],"6":["py","exception","Python exception"],"7":["py","classmethod","Python class method"]},filenames:["reference/kombu.exceptions","reference/kombu.utils.log","reference/kombu.transport.virtual","reference/kombu.utils.encoding","reference/kombu.transport.pyamqplib","reference/kombu.transport.mongodb","reference/kombu.transport.SQS","reference/kombu.syn","reference/kombu.transport","reference/kombu.serialization","reference/kombu.common","reference/kombu.utils.functional","index","reference/kombu.transport.memory","introduction","userguide/serialization","reference/kombu.utils.compat","userguide/connections","reference/index","reference/kombu.abstract","reference/kombu.mixins","reference/kombu.entity","reference/kombu.clocks","userguide/simple","reference/kombu.messaging","reference/kombu.transport.base","reference/kombu.utils.finalize","faq","userguide/examples","userguide/index","reference/kombu.pools","reference/kombu.utils","reference/kombu.transport.pyredis","reference/kombu.transport.pypika","reference/kombu.pidbox","reference/kombu.transport.pycouchdb","reference/kombu.compression","reference/kombu.transport.virtual.exchange","reference/kombu.transport.beanstalk","changelog","reference/kombu.transport.virtual.scheduling","reference/kombu.utils.debug","reference/kombu.simple","reference/kombu.transport.librabbitmq","reference/kombu.compat","reference/kombu.connection","userguide/pools","reference/kombu.utils.limits"]})