diff options
| -rw-r--r-- | faq.html | 10 | ||||
| -rw-r--r-- | genindex.html | 121 | ||||
| -rw-r--r-- | index.html | 26 | ||||
| -rw-r--r-- | introduction.html | 10 | ||||
| -rw-r--r-- | objects.inv | bin | 2198 -> 2672 bytes | |||
| -rw-r--r-- | py-modindex.html | 5 | ||||
| -rw-r--r-- | reference/index.html | 1 | ||||
| -rw-r--r-- | reference/kombu.connection.html | 2 | ||||
| -rw-r--r-- | reference/kombu.messaging.html | 2 | ||||
| -rw-r--r-- | reference/kombu.serialization.html | 10 | ||||
| -rw-r--r-- | searchindex.js | 2 | ||||
| -rw-r--r-- | sources/index.txt | 3 |
12 files changed, 146 insertions, 46 deletions
@@ -23,7 +23,7 @@ <script type="text/javascript" src="static/doctools.js"></script> <link rel="top" title="Kombu v0.1.0 documentation" href="index.html" /> <link rel="next" title="API Reference" href="reference/index.html" /> - <link rel="prev" title="kombu - AMQP Messaging Framework for Python" href="introduction.html" /> + <link rel="prev" title="Simple Interface" href="userguide/simple.html" /> </head> <body> <div class="related"> @@ -39,7 +39,7 @@ <a href="reference/index.html" title="API Reference" accesskey="N">next</a> |</li> <li class="right" > - <a href="introduction.html" title="kombu - AMQP Messaging Framework for Python" + <a href="userguide/simple.html" title="Simple Interface" accesskey="P">previous</a> |</li> <li><a href="index.html">Kombu v0.1.0 documentation</a> »</li> </ul> @@ -89,8 +89,8 @@ why it’s not implemented yet is revealed:</p> </ul> <h4>Previous topic</h4> - <p class="topless"><a href="introduction.html" - title="previous chapter">kombu - AMQP Messaging Framework for Python</a></p> + <p class="topless"><a href="userguide/simple.html" + title="previous chapter">Simple Interface</a></p> <h4>Next topic</h4> <p class="topless"><a href="reference/index.html" title="next chapter">API Reference</a></p> @@ -129,7 +129,7 @@ why it’s not implemented yet is revealed:</p> <a href="reference/index.html" title="API Reference" >next</a> |</li> <li class="right" > - <a href="introduction.html" title="kombu - AMQP Messaging Framework for Python" + <a href="userguide/simple.html" title="Simple Interface" >previous</a> |</li> <li><a href="index.html">Kombu v0.1.0 documentation</a> »</li> </ul> diff --git a/genindex.html b/genindex.html index 13f432b7..3c44b9b3 100644 --- a/genindex.html +++ b/genindex.html @@ -52,15 +52,19 @@ <table width="100%" class="indextable genindextable"><tr> <td width="33%" valign="top"><dl> <dt><a href="reference/kombu.transport.base.html#kombu.transport.base.Message.ack">ack() (kombu.transport.base.Message method)</a></dt> + <dd><dl> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.QualityOfService.ack">(kombu.transport.virtual.QualityOfService method)</a></dt> + </dl></dd> <dt><a href="reference/kombu.transport.base.html#kombu.transport.base.Message.acknowledged">acknowledged (kombu.transport.base.Message attribute)</a></dt> <dt><a href="reference/kombu.connection.html#kombu.connection.BrokerConnection.acquire">acquire() (kombu.connection.BrokerConnection method)</a></dt> <dd><dl> <dt><a href="reference/kombu.connection.html#kombu.connection.BrokerConnectionPool.acquire">(kombu.connection.BrokerConnectionPool method)</a></dt> </dl></dd> <dt><a href="reference/kombu.connection.html#kombu.connection.BrokerConnectionPool.active">active (kombu.connection.BrokerConnectionPool attribute)</a></dt> - <dt><a href="reference/kombu.entity.html#kombu.entity.Exchange.arguments">arguments (kombu.entity.Exchange attribute)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.QualityOfService.append">append() (kombu.transport.virtual.QualityOfService method)</a></dt> </dl></td> <td width="33%" valign="top"><dl> + <dt><a href="reference/kombu.entity.html#kombu.entity.Exchange.arguments">arguments (kombu.entity.Exchange attribute)</a></dt> <dt><a href="reference/kombu.transport.pypika.html#kombu.transport.pypika.AsyncoreConnection">AsyncoreConnection (class in kombu.transport.pypika)</a></dt> <dt><a href="reference/kombu.transport.pypika.html#kombu.transport.pypika.AsyncoreTransport">AsyncoreTransport (class in kombu.transport.pypika)</a></dt> <dt><a href="reference/kombu.messaging.html#kombu.messaging.Consumer.auto_declare">auto_declare (kombu.messaging.Consumer attribute)</a></dt> @@ -78,13 +82,45 @@ <table width="100%" class="indextable genindextable"><tr> <td width="33%" valign="top"><dl> <dt><a href="reference/kombu.transport.pypika.html#kombu.transport.pypika.Channel.basic_ack">basic_ack() (kombu.transport.pypika.Channel method)</a></dt> + <dd><dl> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Channel.basic_ack">(kombu.transport.virtual.Channel method)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.Channel.basic_ack">(kombu.transport.virtual.Transport.Channel method)</a></dt> + </dl></dd> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Channel.basic_cancel">basic_cancel() (kombu.transport.virtual.Channel method)</a></dt> + <dd><dl> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.Channel.basic_cancel">(kombu.transport.virtual.Transport.Channel method)</a></dt> + </dl></dd> <dt><a href="reference/kombu.transport.pypika.html#kombu.transport.pypika.Channel.basic_consume">basic_consume() (kombu.transport.pypika.Channel method)</a></dt> + <dd><dl> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Channel.basic_consume">(kombu.transport.virtual.Channel method)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.Channel.basic_consume">(kombu.transport.virtual.Transport.Channel method)</a></dt> + </dl></dd> <dt><a href="reference/kombu.transport.pypika.html#kombu.transport.pypika.Channel.basic_get">basic_get() (kombu.transport.pypika.Channel method)</a></dt> + <dd><dl> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Channel.basic_get">(kombu.transport.virtual.Channel method)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.Channel.basic_get">(kombu.transport.virtual.Transport.Channel method)</a></dt> + </dl></dd> <dt><a href="reference/kombu.transport.pypika.html#kombu.transport.pypika.Channel.basic_publish">basic_publish() (kombu.transport.pypika.Channel method)</a></dt> - <dt><a href="reference/kombu.abstract.html#kombu.abstract.MaybeChannelBound.bind">bind() (kombu.abstract.MaybeChannelBound method)</a></dt> - <dt><a href="reference/kombu.entity.html#kombu.entity.Binding">Binding (in module kombu.entity)</a></dt> + <dd><dl> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Channel.basic_publish">(kombu.transport.virtual.Channel method)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.Channel.basic_publish">(kombu.transport.virtual.Transport.Channel method)</a></dt> + </dl></dd> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Channel.basic_qos">basic_qos() (kombu.transport.virtual.Channel method)</a></dt> + <dd><dl> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.Channel.basic_qos">(kombu.transport.virtual.Transport.Channel method)</a></dt> + </dl></dd> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Channel.basic_recover">basic_recover() (kombu.transport.virtual.Channel method)</a></dt> + <dd><dl> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.Channel.basic_recover">(kombu.transport.virtual.Transport.Channel method)</a></dt> + </dl></dd> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Channel.basic_reject">basic_reject() (kombu.transport.virtual.Channel method)</a></dt> + <dd><dl> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.Channel.basic_reject">(kombu.transport.virtual.Transport.Channel method)</a></dt> + </dl></dd> </dl></td> <td width="33%" valign="top"><dl> + <dt><a href="reference/kombu.abstract.html#kombu.abstract.MaybeChannelBound.bind">bind() (kombu.abstract.MaybeChannelBound method)</a></dt> + <dt><a href="reference/kombu.entity.html#kombu.entity.Binding">Binding (in module kombu.entity)</a></dt> <dt><a href="reference/kombu.entity.html#kombu.entity.Queue.binding_arguments">binding_arguments (kombu.entity.Queue attribute)</a></dt> <dt><a href="reference/kombu.transport.pypika.html#kombu.transport.pypika.BlockingConnection">BlockingConnection (class in kombu.transport.pypika)</a></dt> <dt><a href="reference/kombu.transport.pyamqplib.html#kombu.transport.pyamqplib.Channel.Message.body">body (kombu.transport.pyamqplib.Channel.Message attribute)</a></dt> @@ -100,6 +136,7 @@ <table width="100%" class="indextable genindextable"><tr> <td width="33%" valign="top"><dl> <dt><a href="reference/kombu.messaging.html#kombu.messaging.Consumer.callbacks">callbacks (kombu.messaging.Consumer attribute)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.QualityOfService.can_consume">can_consume() (kombu.transport.virtual.QualityOfService method)</a></dt> <dt><a href="reference/kombu.entity.html#kombu.entity.Queue.cancel">cancel() (kombu.entity.Queue method)</a></dt> <dd><dl> <dt><a href="reference/kombu.messaging.html#kombu.messaging.Consumer.cancel">(kombu.messaging.Consumer method)</a></dt> @@ -109,6 +146,7 @@ <dt><a href="reference/kombu.transport.pyamqplib.html#kombu.transport.pyamqplib.Channel">(class in kombu.transport.pyamqplib)</a></dt> <dt><a href="reference/kombu.transport.pypika.html#kombu.transport.pypika.Channel">(class in kombu.transport.pypika)</a></dt> <dt><a href="reference/kombu.transport.pyredis.html#kombu.transport.pyredis.Channel">(class in kombu.transport.pyredis)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Channel">(class in kombu.transport.virtual)</a></dt> </dl></dd> <dt><a href="reference/kombu.abstract.html#kombu.abstract.MaybeChannelBound.channel">channel (kombu.abstract.MaybeChannelBound attribute)</a></dt> <dd><dl> @@ -128,6 +166,7 @@ <dt><a href="reference/kombu.transport.pyamqplib.html#kombu.transport.pyamqplib.Channel.Message">Channel.Message (class in kombu.transport.pyamqplib)</a></dt> <dd><dl> <dt><a href="reference/kombu.transport.pypika.html#kombu.transport.pypika.Channel.Message">(class in kombu.transport.pypika)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Channel.Message">(class in kombu.transport.virtual)</a></dt> </dl></dd> <dt><a href="reference/kombu.connection.html#kombu.connection.BrokerConnection.channel_errors">channel_errors (kombu.connection.BrokerConnection attribute)</a></dt> <dt><a href="reference/kombu.utils.html#kombu.utils.OrderedDict.clear">clear() (kombu.utils.OrderedDict method)</a></dt> @@ -143,11 +182,15 @@ <dt><a href="reference/kombu.connection.html#kombu.connection.BrokerConnectionPool.close">(kombu.connection.BrokerConnectionPool method)</a></dt> <dt><a href="reference/kombu.transport.pyredis.html#kombu.transport.pyredis.Channel.close">(kombu.transport.pyredis.Channel method)</a></dt> <dt><a href="reference/kombu.transport.pyredis.html#kombu.transport.pyredis.Transport.Channel.close">(kombu.transport.pyredis.Transport.Channel method)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Channel.close">(kombu.transport.virtual.Channel method)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.Channel.close">(kombu.transport.virtual.Transport.Channel method)</a></dt> </dl></dd> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.close_channel">close_channel() (kombu.transport.virtual.Transport method)</a></dt> <dt><a href="reference/kombu.transport.base.html#kombu.transport.base.Transport.close_connection">close_connection() (kombu.transport.base.Transport method)</a></dt> <dd><dl> <dt><a href="reference/kombu.transport.pyamqplib.html#kombu.transport.pyamqplib.Transport.close_connection">(kombu.transport.pyamqplib.Transport method)</a></dt> <dt><a href="reference/kombu.transport.pypika.html#kombu.transport.pypika.SyncTransport.close_connection">(kombu.transport.pypika.SyncTransport method)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.close_connection">(kombu.transport.virtual.Transport method)</a></dt> </dl></dd> </dl></td> <td width="33%" valign="top"><dl> @@ -174,8 +217,10 @@ <dd><dl> <dt><a href="reference/kombu.transport.pyamqplib.html#kombu.transport.pyamqplib.Transport.create_channel">(kombu.transport.pyamqplib.Transport method)</a></dt> <dt><a href="reference/kombu.transport.pypika.html#kombu.transport.pypika.SyncTransport.create_channel">(kombu.transport.pypika.SyncTransport method)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.create_channel">(kombu.transport.virtual.Transport method)</a></dt> </dl></dd> <dt><a href="reference/kombu.connection.html#kombu.connection.BrokerConnection.create_transport">create_transport() (kombu.connection.BrokerConnection method)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.Cycle">Cycle (kombu.transport.virtual.Transport attribute)</a></dt> </dl></td> </tr></table> @@ -207,6 +252,9 @@ <dt><a href="reference/kombu.transport.pyamqplib.html#kombu.transport.pyamqplib.Connection.drain_events">(kombu.transport.pyamqplib.Connection method)</a></dt> <dt><a href="reference/kombu.transport.pyamqplib.html#kombu.transport.pyamqplib.Transport.drain_events">(kombu.transport.pyamqplib.Transport method)</a></dt> <dt><a href="reference/kombu.transport.pypika.html#kombu.transport.pypika.SyncTransport.drain_events">(kombu.transport.pypika.SyncTransport method)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Channel.drain_events">(kombu.transport.virtual.Channel method)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.drain_events">(kombu.transport.virtual.Transport method)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.Channel.drain_events">(kombu.transport.virtual.Transport.Channel method)</a></dt> </dl></dd> <dt><a href="reference/kombu.entity.html#kombu.entity.Exchange.durable">durable (kombu.entity.Exchange attribute)</a></dt> <dd><dl> @@ -226,18 +274,27 @@ <dt><a href="reference/kombu.connection.html#kombu.connection.BrokerConnection.ensure_connection">ensure_connection() (kombu.connection.BrokerConnection method)</a></dt> <dt><a href="reference/kombu.exceptions.html#kombu.exceptions.EnsureExhausted">EnsureExhausted</a></dt> <dt><a href="reference/kombu.compat.html#kombu.compat.entry_to_queue">entry_to_queue() (in module kombu.compat)</a></dt> -</dl></td> - <td width="33%" valign="top"><dl> <dt><a href="reference/kombu.transport.base.html#kombu.transport.base.Transport.establish_connection">establish_connection() (kombu.transport.base.Transport method)</a></dt> <dd><dl> <dt><a href="reference/kombu.transport.pyamqplib.html#kombu.transport.pyamqplib.Transport.establish_connection">(kombu.transport.pyamqplib.Transport method)</a></dt> <dt><a href="reference/kombu.transport.pypika.html#kombu.transport.pypika.SyncTransport.establish_connection">(kombu.transport.pypika.SyncTransport method)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.establish_connection">(kombu.transport.virtual.Transport method)</a></dt> </dl></dd> +</dl></td> + <td width="33%" valign="top"><dl> <dt><a href="reference/kombu.entity.html#kombu.entity.Exchange">Exchange (class in kombu.entity)</a></dt> <dt><a href="reference/kombu.entity.html#kombu.entity.Queue.exchange">exchange (kombu.entity.Queue attribute)</a></dt> <dd><dl> <dt><a href="reference/kombu.messaging.html#kombu.messaging.Producer.exchange">(kombu.messaging.Producer attribute)</a></dt> </dl></dd> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Channel.exchange_declare">exchange_declare() (kombu.transport.virtual.Channel method)</a></dt> + <dd><dl> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.Channel.exchange_declare">(kombu.transport.virtual.Transport.Channel method)</a></dt> + </dl></dd> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Channel.exchange_delete">exchange_delete() (kombu.transport.virtual.Channel method)</a></dt> + <dd><dl> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.Channel.exchange_delete">(kombu.transport.virtual.Transport.Channel method)</a></dt> + </dl></dd> <dt><a href="reference/kombu.entity.html#kombu.entity.Queue.exclusive">exclusive (kombu.entity.Queue attribute)</a></dt> </dl></td> </tr></table> @@ -245,10 +302,15 @@ <h2 id="F">F</h2> <table width="100%" class="indextable genindextable"><tr> <td width="33%" valign="top"><dl> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.FairCycle">FairCycle (class in kombu.transport.virtual)</a></dt> <dt><a href="reference/kombu.compat.html#kombu.compat.Consumer.fetch">fetch() (kombu.compat.Consumer method)</a></dt> - <dt><a href="reference/kombu.messaging.html#kombu.messaging.Consumer.flow">flow() (kombu.messaging.Consumer method)</a></dt> </dl></td> <td width="33%" valign="top"><dl> + <dt><a href="reference/kombu.messaging.html#kombu.messaging.Consumer.flow">flow() (kombu.messaging.Consumer method)</a></dt> + <dd><dl> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Channel.flow">(kombu.transport.virtual.Channel method)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.Channel.flow">(kombu.transport.virtual.Transport.Channel method)</a></dt> + </dl></dd> <dt><a href="reference/kombu.utils.html#kombu.utils.OrderedDict.fromkeys">fromkeys() (kombu.utils.OrderedDict class method)</a></dt> </dl></td> </tr></table> @@ -257,6 +319,9 @@ <table width="100%" class="indextable genindextable"><tr> <td width="33%" valign="top"><dl> <dt><a href="reference/kombu.entity.html#kombu.entity.Queue.get">get() (kombu.entity.Queue method)</a></dt> + <dd><dl> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.FairCycle.get">(kombu.transport.virtual.FairCycle method)</a></dt> + </dl></dd> <dt><a href="reference/kombu.transport.html#kombu.transport.get_transport_cls">get_transport_cls() (in module kombu.transport)</a></dt> <dd><dl> <dt><a href="reference/kombu.connection.html#kombu.connection.BrokerConnection.get_transport_cls">(kombu.connection.BrokerConnection method)</a></dt> @@ -312,6 +377,7 @@ <dt><a href="reference/kombu.transport.pyamqplib.html#module-kombu.transport.pyamqplib">kombu.transport.pyamqplib (module)</a></dt> <dt><a href="reference/kombu.transport.pypika.html#module-kombu.transport.pypika">kombu.transport.pypika (module)</a></dt> <dt><a href="reference/kombu.transport.pyredis.html#module-kombu.transport.pyredis">kombu.transport.pyredis (module)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#module-kombu.transport.virtual">kombu.transport.virtual (module)</a></dt> <dt><a href="reference/kombu.utils.html#module-kombu.utils">kombu.utils (module)</a></dt> </dl></td> </tr></table> @@ -326,6 +392,7 @@ <dd><dl> <dt><a href="reference/kombu.transport.pyamqplib.html#kombu.transport.pyamqplib.Message">(class in kombu.transport.pyamqplib)</a></dt> <dt><a href="reference/kombu.transport.pypika.html#kombu.transport.pypika.Message">(class in kombu.transport.pypika)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Message">(class in kombu.transport.virtual)</a></dt> </dl></dd> </dl></td> <td width="33%" valign="top"><dl> @@ -334,6 +401,8 @@ <dt><a href="reference/kombu.transport.pyamqplib.html#kombu.transport.pyamqplib.Channel.message_to_python">message_to_python() (kombu.transport.pyamqplib.Channel method)</a></dt> <dd><dl> <dt><a href="reference/kombu.transport.pypika.html#kombu.transport.pypika.Channel.message_to_python">(kombu.transport.pypika.Channel method)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Channel.message_to_python">(kombu.transport.virtual.Channel method)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.Channel.message_to_python">(kombu.transport.virtual.Transport.Channel method)</a></dt> </dl></dd> <dt><a href="reference/kombu.exceptions.html#kombu.exceptions.MessageStateError">MessageStateError</a></dt> </dl></td> @@ -377,6 +446,8 @@ <dt><a href="reference/kombu.transport.pyamqplib.html#kombu.transport.pyamqplib.Channel.prepare_message">prepare_message() (kombu.transport.pyamqplib.Channel method)</a></dt> <dd><dl> <dt><a href="reference/kombu.transport.pypika.html#kombu.transport.pypika.Channel.prepare_message">(kombu.transport.pypika.Channel method)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Channel.prepare_message">(kombu.transport.virtual.Channel method)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.Channel.prepare_message">(kombu.transport.virtual.Transport.Channel method)</a></dt> </dl></dd> <dt><a href="reference/kombu.compat.html#kombu.compat.Consumer.process_next">process_next() (kombu.compat.Consumer method)</a></dt> <dt><a href="reference/kombu.messaging.html#kombu.messaging.Producer">Producer (class in kombu.messaging)</a></dt> @@ -396,12 +467,33 @@ <table width="100%" class="indextable genindextable"><tr> <td width="33%" valign="top"><dl> <dt><a href="reference/kombu.messaging.html#kombu.messaging.Consumer.qos">qos() (kombu.messaging.Consumer method)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Channel.qos_manager">qos_manager (kombu.transport.virtual.Channel attribute)</a></dt> + <dd><dl> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.Channel.qos_manager">(kombu.transport.virtual.Transport.Channel attribute)</a></dt> + </dl></dd> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.QualityOfService">QualityOfService (class in kombu.transport.virtual)</a></dt> <dt><a href="reference/kombu.entity.html#kombu.entity.Queue">Queue (class in kombu.entity)</a></dt> <dt><a href="reference/kombu.entity.html#kombu.entity.Queue.queue_arguments">queue_arguments (kombu.entity.Queue attribute)</a></dt> </dl></td> <td width="33%" valign="top"><dl> <dt><a href="reference/kombu.entity.html#kombu.entity.Queue.queue_bind">queue_bind() (kombu.entity.Queue method)</a></dt> + <dd><dl> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Channel.queue_bind">(kombu.transport.virtual.Channel method)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.Channel.queue_bind">(kombu.transport.virtual.Transport.Channel method)</a></dt> + </dl></dd> <dt><a href="reference/kombu.entity.html#kombu.entity.Queue.queue_declare">queue_declare() (kombu.entity.Queue method)</a></dt> + <dd><dl> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Channel.queue_declare">(kombu.transport.virtual.Channel method)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.Channel.queue_declare">(kombu.transport.virtual.Transport.Channel method)</a></dt> + </dl></dd> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Channel.queue_delete">queue_delete() (kombu.transport.virtual.Channel method)</a></dt> + <dd><dl> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.Channel.queue_delete">(kombu.transport.virtual.Transport.Channel method)</a></dt> + </dl></dd> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Channel.queue_purge">queue_purge() (kombu.transport.virtual.Channel method)</a></dt> + <dd><dl> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.Channel.queue_purge">(kombu.transport.virtual.Transport.Channel method)</a></dt> + </dl></dd> <dt><a href="reference/kombu.messaging.html#kombu.messaging.Consumer.queues">queues (kombu.messaging.Consumer attribute)</a></dt> </dl></td> </tr></table> @@ -415,16 +507,26 @@ <dt><a href="reference/kombu.messaging.html#kombu.messaging.Consumer.register_callback">register_callback() (kombu.messaging.Consumer method)</a></dt> <dt><a href="reference/kombu.serialization.html#kombu.serialization.registry">registry (in module kombu.serialization)</a></dt> <dt><a href="reference/kombu.transport.base.html#kombu.transport.base.Message.reject">reject() (kombu.transport.base.Message method)</a></dt> + <dd><dl> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Channel.Message.reject">(kombu.transport.virtual.Channel.Message method)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Message.reject">(kombu.transport.virtual.Message method)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.Channel.Message.reject">(kombu.transport.virtual.Transport.Channel.Message method)</a></dt> + </dl></dd> <dt><a href="reference/kombu.connection.html#kombu.connection.BrokerConnection.release">release() (kombu.connection.BrokerConnection method)</a></dt> <dd><dl> <dt><a href="reference/kombu.connection.html#kombu.connection.BrokerConnectionPool.release">(kombu.connection.BrokerConnectionPool method)</a></dt> </dl></dd> + <dt><a href="reference/kombu.utils.html#kombu.utils.repeatlast">repeatlast() (in module kombu.utils)</a></dt> </dl></td> <td width="33%" valign="top"><dl> - <dt><a href="reference/kombu.utils.html#kombu.utils.repeatlast">repeatlast() (in module kombu.utils)</a></dt> <dt><a href="reference/kombu.connection.html#kombu.connection.BrokerConnectionPool.replace">replace() (kombu.connection.BrokerConnectionPool method)</a></dt> <dt><a href="reference/kombu.transport.base.html#kombu.transport.base.Message.requeue">requeue() (kombu.transport.base.Message method)</a></dt> + <dd><dl> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.QualityOfService.requeue">(kombu.transport.virtual.QualityOfService method)</a></dt> + </dl></dd> <dt><a href="reference/kombu.transport.html#kombu.transport.resolve_transport">resolve_transport() (in module kombu.transport)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.QualityOfService.restore_unacked">restore_unacked() (kombu.transport.virtual.QualityOfService method)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.QualityOfService.restore_unacked_once">restore_unacked_once() (kombu.transport.virtual.QualityOfService method)</a></dt> <dt><a href="reference/kombu.utils.html#kombu.utils.retry_over_time">retry_over_time() (in module kombu.utils)</a></dt> <dt><a href="reference/kombu.entity.html#kombu.entity.Queue.routing_key">routing_key (kombu.entity.Queue attribute)</a></dt> <dd><dl> @@ -460,14 +562,17 @@ <dt><a href="reference/kombu.transport.memory.html#kombu.transport.memory.Transport">(class in kombu.transport.memory)</a></dt> <dt><a href="reference/kombu.transport.pyamqplib.html#kombu.transport.pyamqplib.Transport">(class in kombu.transport.pyamqplib)</a></dt> <dt><a href="reference/kombu.transport.pyredis.html#kombu.transport.pyredis.Transport">(class in kombu.transport.pyredis)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport">(class in kombu.transport.virtual)</a></dt> </dl></dd> + <dt><a href="reference/kombu.connection.html#kombu.connection.BrokerConnection.transport">transport (kombu.connection.BrokerConnection attribute)</a></dt> </dl></td> <td width="33%" valign="top"><dl> - <dt><a href="reference/kombu.connection.html#kombu.connection.BrokerConnection.transport">transport (kombu.connection.BrokerConnection attribute)</a></dt> <dt><a href="reference/kombu.transport.memory.html#kombu.transport.memory.Transport.Channel">Transport.Channel (class in kombu.transport.memory)</a></dt> <dd><dl> <dt><a href="reference/kombu.transport.pyredis.html#kombu.transport.pyredis.Transport.Channel">(class in kombu.transport.pyredis)</a></dt> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.Channel">(class in kombu.transport.virtual)</a></dt> </dl></dd> + <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Transport.Channel.Message">Transport.Channel.Message (class in kombu.transport.virtual)</a></dt> <dt><a href="reference/kombu.entity.html#kombu.entity.Exchange.type">type (kombu.entity.Exchange attribute)</a></dt> </dl></td> </tr></table> @@ -53,36 +53,23 @@ <ul> <li class="toctree-l1"><a class="reference internal" href="introduction.html">kombu - AMQP Messaging Framework for Python</a><ul> <li class="toctree-l2"><a class="reference internal" href="introduction.html#introduction">Introduction</a></li> -<li class="toctree-l2"><a class="reference internal" href="introduction.html#documentation">Documentation</a><ul> -<li class="toctree-l3"><a class="reference internal" href="introduction.html#installation">Installation</a></li> -<li class="toctree-l3"><a class="reference internal" href="introduction.html#terminology">Terminology</a></li> -<li class="toctree-l3"><a class="reference internal" href="introduction.html#examples">Examples</a></li> -</ul> -</li> +<li class="toctree-l2"><a class="reference internal" href="introduction.html#documentation">Documentation</a></li> <li class="toctree-l2"><a class="reference internal" href="introduction.html#creating-a-connection">Creating a connection</a></li> <li class="toctree-l2"><a class="reference internal" href="introduction.html#receiving-messages-using-a-consumer">Receiving messages using a Consumer</a></li> <li class="toctree-l2"><a class="reference internal" href="introduction.html#sending-messages-using-a-producer">Sending messages using a Producer</a></li> <li class="toctree-l2"><a class="reference internal" href="introduction.html#serialization-of-data">Serialization of Data</a></li> <li class="toctree-l2"><a class="reference internal" href="introduction.html#sending-raw-data-without-serialization">Sending raw data without Serialization</a></li> <li class="toctree-l2"><a class="reference internal" href="introduction.html#receiving-messages-without-a-callback">Receiving messages without a callback</a></li> -<li class="toctree-l2"><a class="reference internal" href="introduction.html#sub-classing-the-messaging-classes">Sub-classing the messaging classes</a><ul> -<li class="toctree-l3"><a class="reference internal" href="introduction.html#getting-help">Getting Help</a></li> -</ul> -</li> -<li class="toctree-l2"><a class="reference internal" href="introduction.html#mailing-list">Mailing list</a><ul> -<li class="toctree-l3"><a class="reference internal" href="introduction.html#bug-tracker">Bug tracker</a></li> -<li class="toctree-l3"><a class="reference internal" href="introduction.html#contributing">Contributing</a></li> -<li class="toctree-l3"><a class="reference internal" href="introduction.html#license">License</a></li> +<li class="toctree-l2"><a class="reference internal" href="introduction.html#sub-classing-the-messaging-classes">Sub-classing the messaging classes</a></li> +<li class="toctree-l2"><a class="reference internal" href="introduction.html#mailing-list">Mailing list</a></li> </ul> </li> +<li class="toctree-l1"><a class="reference internal" href="userguide/index.html">User Guide</a><ul> +<li class="toctree-l2"><a class="reference internal" href="userguide/simple.html">Simple Interface</a></li> </ul> </li> <li class="toctree-l1"><a class="reference internal" href="faq.html">Frequently Asked Questions</a><ul> -<li class="toctree-l2"><a class="reference internal" href="faq.html#questions">Questions</a><ul> -<li class="toctree-l3"><a class="reference internal" href="faq.html#q-message-reject-doesn-t-work">Q: Message.reject doesn’t work?</a></li> -<li class="toctree-l3"><a class="reference internal" href="faq.html#q-message-requeue-doesn-t-work">Q: Message.requeue doesn’t work?</a></li> -</ul> -</li> +<li class="toctree-l2"><a class="reference internal" href="faq.html#questions">Questions</a></li> </ul> </li> <li class="toctree-l1"><a class="reference internal" href="reference/index.html">API Reference</a><ul> @@ -97,6 +84,7 @@ <li class="toctree-l2"><a class="reference internal" href="reference/kombu.transport.pyredis.html">Redis Transport - kombu.transport.pyredis</a></li> <li class="toctree-l2"><a class="reference internal" href="reference/kombu.transport.memory.html">In-memory Transport - kombu.transport.memory</a></li> <li class="toctree-l2"><a class="reference internal" href="reference/kombu.transport.base.html">Base Transport Interface - kombu.transport.base</a></li> +<li class="toctree-l2"><a class="reference internal" href="reference/kombu.transport.virtual.html">Virtual Transport Interface - kombu.transport.virtual</a></li> <li class="toctree-l2"><a class="reference internal" href="reference/kombu.serialization.html">Serialization - kombu.serialization</a></li> <li class="toctree-l2"><a class="reference internal" href="reference/kombu.abstract.html">Object Utilities - kombu.abstract</a></li> <li class="toctree-l2"><a class="reference internal" href="reference/kombu.utils.html">Utilities - kombu.utils</a></li> diff --git a/introduction.html b/introduction.html index a5ab8c53..5b141c53 100644 --- a/introduction.html +++ b/introduction.html @@ -22,7 +22,7 @@ <script type="text/javascript" src="static/underscore.js"></script> <script type="text/javascript" src="static/doctools.js"></script> <link rel="top" title="Kombu v0.1.0 documentation" href="index.html" /> - <link rel="next" title="Frequently Asked Questions" href="faq.html" /> + <link rel="next" title="User Guide" href="userguide/index.html" /> <link rel="prev" title="Kombu Documentation" href="index.html" /> </head> <body> @@ -36,7 +36,7 @@ <a href="py-modindex.html" title="Python Module Index" >modules</a> |</li> <li class="right" > - <a href="faq.html" title="Frequently Asked Questions" + <a href="userguide/index.html" title="User Guide" accesskey="N">next</a> |</li> <li class="right" > <a href="index.html" title="Kombu Documentation" @@ -498,8 +498,8 @@ file in the top distribution directory for the full license text.</p> <p class="topless"><a href="index.html" title="previous chapter">Kombu Documentation</a></p> <h4>Next topic</h4> - <p class="topless"><a href="faq.html" - title="next chapter">Frequently Asked Questions</a></p> + <p class="topless"><a href="userguide/index.html" + title="next chapter">User Guide</a></p> <h3>This Page</h3> <ul class="this-page-menu"> <li><a href="sources/introduction.txt" @@ -532,7 +532,7 @@ file in the top distribution directory for the full license text.</p> <a href="py-modindex.html" title="Python Module Index" >modules</a> |</li> <li class="right" > - <a href="faq.html" title="Frequently Asked Questions" + <a href="userguide/index.html" title="User Guide" >next</a> |</li> <li class="right" > <a href="index.html" title="Kombu Documentation" diff --git a/objects.inv b/objects.inv Binary files differindex c3503f79..95c70000 100644 --- a/objects.inv +++ b/objects.inv diff --git a/py-modindex.html b/py-modindex.html index 138be2af..29c2e6c6 100644 --- a/py-modindex.html +++ b/py-modindex.html @@ -130,6 +130,11 @@ <tr class="cg-1"> <td></td> <td> + <a href="reference/kombu.transport.virtual.html#module-kombu.transport.virtual"><tt class="xref">kombu.transport.virtual</tt></a></td><td> + <em></em></td></tr> + <tr class="cg-1"> + <td></td> + <td> <a href="reference/kombu.utils.html#module-kombu.utils"><tt class="xref">kombu.utils</tt></a></td><td> <em></em></td></tr> </table> diff --git a/reference/index.html b/reference/index.html index 789cd70a..a5894231 100644 --- a/reference/index.html +++ b/reference/index.html @@ -75,6 +75,7 @@ <li class="toctree-l1"><a class="reference internal" href="kombu.transport.pyredis.html">Redis Transport - kombu.transport.pyredis</a></li> <li class="toctree-l1"><a class="reference internal" href="kombu.transport.memory.html">In-memory Transport - kombu.transport.memory</a></li> <li class="toctree-l1"><a class="reference internal" href="kombu.transport.base.html">Base Transport Interface - kombu.transport.base</a></li> +<li class="toctree-l1"><a class="reference internal" href="kombu.transport.virtual.html">Virtual Transport Interface - kombu.transport.virtual</a></li> <li class="toctree-l1"><a class="reference internal" href="kombu.serialization.html">Serialization - kombu.serialization</a></li> <li class="toctree-l1"><a class="reference internal" href="kombu.abstract.html">Object Utilities - kombu.abstract</a></li> <li class="toctree-l1"><a class="reference internal" href="kombu.utils.html">Utilities - kombu.utils</a></li> diff --git a/reference/kombu.connection.html b/reference/kombu.connection.html index 351d9375..25561297 100644 --- a/reference/kombu.connection.html +++ b/reference/kombu.connection.html @@ -130,7 +130,7 @@ constructor of the automatically created <a class="reference internal" href="kombu.entity.html#kombu.entity.Queue" title="kombu.entity.Queue"><tt class="xref py py-class docutils literal"><span class="pre">Queue</span></tt></a>.</li> <li><strong>exchange_opts</strong> – Additional keyword arguments passed to the constructor of the automatically created -:class:<a href="#id1"><span class="problematic" id="id2">`</span></a>~kombu.entity.Exchange.</li> +<a class="reference internal" href="kombu.entity.html#kombu.entity.Exchange" title="kombu.entity.Exchange"><tt class="xref py py-class docutils literal"><span class="pre">Exchange</span></tt></a>.</li> <li><strong>channel</strong> – Channel to use. If not specified a new channel from the current connection will be used. Remember to call <tt class="xref py py-meth docutils literal"><span class="pre">close()</span></tt> when done with the diff --git a/reference/kombu.messaging.html b/reference/kombu.messaging.html index 636f6431..5bd21dba 100644 --- a/reference/kombu.messaging.html +++ b/reference/kombu.messaging.html @@ -275,7 +275,7 @@ at instantiation. Default is <tt class="xref docutils literal"><span class="pre" <li><strong>on_return</strong> – Callback to call for undeliverable messages, when <tt class="docutils literal"><span class="pre">mandatory</span></tt> or <tt class="docutils literal"><span class="pre">imediate</span></tt> is used. This callback needs the following signature: -<a href="#id1"><span class="problematic" id="id2">``</span></a>(exception, exchange, routing_key, message).</li> +<tt class="docutils literal"><span class="pre">(exception,</span> <span class="pre">exchange,</span> <span class="pre">routing_key,</span> <span class="pre">message)</span></tt>.</li> </ul> </td> </tr> diff --git a/reference/kombu.serialization.html b/reference/kombu.serialization.html index ad735886..5906901c 100644 --- a/reference/kombu.serialization.html +++ b/reference/kombu.serialization.html @@ -24,7 +24,7 @@ <link rel="top" title="Kombu v0.1.0 documentation" href="../index.html" /> <link rel="up" title="API Reference" href="index.html" /> <link rel="next" title="Object Utilities - kombu.abstract" href="kombu.abstract.html" /> - <link rel="prev" title="Base Transport Interface - kombu.transport.base" href="kombu.transport.base.html" /> + <link rel="prev" title="Virtual Transport Interface - kombu.transport.virtual" href="kombu.transport.virtual.html" /> </head> <body> <div class="related"> @@ -40,7 +40,7 @@ <a href="kombu.abstract.html" title="Object Utilities - kombu.abstract" accesskey="N">next</a> |</li> <li class="right" > - <a href="kombu.transport.base.html" title="Base Transport Interface - kombu.transport.base" + <a href="kombu.transport.virtual.html" title="Virtual Transport Interface - kombu.transport.virtual" accesskey="P">previous</a> |</li> <li><a href="../index.html">Kombu v0.1.0 documentation</a> »</li> <li><a href="index.html" accesskey="U">API Reference</a> »</li> @@ -89,8 +89,8 @@ package is installed.</p> <img class="logo" width="128" height="128" src="http://cloud.github.com/downloads/ask/kombu/kombusmall.jpg" alt="Logo"/> </a></p> <h4>Previous topic</h4> - <p class="topless"><a href="kombu.transport.base.html" - title="previous chapter">Base Transport Interface - kombu.transport.base</a></p> + <p class="topless"><a href="kombu.transport.virtual.html" + title="previous chapter">Virtual Transport Interface - kombu.transport.virtual</a></p> <h4>Next topic</h4> <p class="topless"><a href="kombu.abstract.html" title="next chapter">Object Utilities - kombu.abstract</a></p> @@ -129,7 +129,7 @@ package is installed.</p> <a href="kombu.abstract.html" title="Object Utilities - kombu.abstract" >next</a> |</li> <li class="right" > - <a href="kombu.transport.base.html" title="Base Transport Interface - kombu.transport.base" + <a href="kombu.transport.virtual.html" title="Virtual Transport Interface - kombu.transport.virtual" >previous</a> |</li> <li><a href="../index.html">Kombu v0.1.0 documentation</a> »</li> <li><a href="index.html" >API Reference</a> »</li> diff --git a/searchindex.js b/searchindex.js index 647b5caa..70704c45 100644 --- a/searchindex.js +++ b/searchindex.js @@ -1 +1 @@ -Search.setIndex({objects:{"kombu.transport.pyamqplib.Transport":{drain_events:[7,3,1],establish_connection:[7,3,1],create_channel:[7,3,1],close_connection:[7,3,1]},"kombu.transport.memory.Transport":{Channel:[4,1,1]},"kombu.messaging.Producer":{exchange:[9,2,1],auto_declare:[9,2,1],routing_key:[9,2,1],publish:[9,3,1],serializer:[9,2,1],declare:[9,3,1],channel:[9,2,1]},"kombu.abstract.MaybeChannelBound":{bind:[8,3,1],when_bound:[8,3,1],maybe_bind:[8,3,1],channel:[8,2,1],is_bound:[8,2,1]},"kombu.transport.pypika.BlockingConnection":{channel:[10,3,1]},"kombu.entity.Queue":{exclusive:[15,2,1],unbind:[15,3,1],when_bound:[15,3,1],name:[15,2,1],exchange:[15,2,1],auto_delete:[15,2,1],durable:[15,2,1],routing_key:[15,2,1],purge:[15,3,1],queue_bind:[15,3,1],queue_arguments:[15,2,1],get:[15,3,1],binding_arguments:[15,2,1],cancel:[15,3,1],queue_declare:[15,3,1],"delete":[15,3,1],declare:[15,3,1],channel:[15,2,1],consume:[15,3,1]},"kombu.transport.pypika.AsyncoreTransport":{Connection:[10,2,1]},"kombu.connection.BrokerConnection":{SimpleBuffer:[17,3,1],info:[17,3,1],create_transport:[17,3,1],SimpleQueue:[17,3,1],channel_errors:[17,2,1],clone:[17,3,1],acquire:[17,3,1],channel:[17,3,1],host:[17,2,1],ensure_connection:[17,3,1],connection:[17,2,1],connection_errors:[17,2,1],ensure:[17,3,1],connect:[17,3,1],get_transport_cls:[17,3,1],create_backend:[17,3,1],release:[17,3,1],close:[17,3,1],drain_events:[17,3,1],transport:[17,2,1]},"kombu.entity":{Queue:[15,1,1],Binding:[15,2,1],Exchange:[15,1,1]},"kombu.transport.pyamqplib.Connection":{read_timeout:[7,3,1],drain_events:[7,3,1],wait_multi:[7,3,1],channel:[7,3,1]},"kombu.transport.pyredis.Transport.Channel":{close:[13,3,1],client:[13,2,1]},"kombu.entity.Exchange":{name:[15,2,1],auto_delete:[15,2,1],delivery_mode:[15,2,1],publish:[15,3,1],declare:[15,3,1],arguments:[15,2,1],Message:[15,3,1],type:[15,2,1],durable:[15,2,1],channel:[15,2,1],"delete":[15,3,1]},"kombu.connection.BrokerConnectionPool":{acquire:[17,3,1],replace:[17,3,1],release:[17,3,1],ensure:[17,3,1],active:[17,2,1],close:[17,3,1],total:[17,2,1],grow:[17,3,1]},"kombu.abstract":{Object:[8,1,1],MaybeChannelBound:[8,1,1]},"kombu.exceptions":{TimeoutError:[0,4,1],MessageStateError:[0,4,1],EnsureExhausted:[0,4,1],NotBoundError:[0,4,1],PoolExhausted:[0,4,1],PoolLimitExceeded:[0,4,1]},"kombu.transport.memory":{Channel:[4,1,1],Transport:[4,1,1]},"kombu.transport.pypika":{SyncTransport:[10,1,1],Channel:[10,1,1],Message:[10,1,1],AsyncoreTransport:[10,1,1],AsyncoreConnection:[10,1,1],BlockingConnection:[10,1,1]},"kombu.transport.pypika.Channel":{basic_ack:[10,3,1],basic_get:[10,3,1],basic_publish:[10,3,1],basic_consume:[10,3,1],message_to_python:[10,3,1],Message:[10,1,1],prepare_message:[10,3,1]},"kombu.transport.pyredis":{Channel:[13,1,1],Transport:[13,1,1]},"kombu.serialization":{encode:[18,5,1],registry:[18,6,1],SerializerNotInstalled:[18,4,1]},kombu:{compat:[16,0,0],utils:[12,0,0],entity:[15,0,0],connection:[17,0,0],messaging:[9,0,0],exceptions:[0,0,0],serialization:[18,0,0],"abstract":[8,0,0],transport:[14,0,0]},"kombu.transport.base.Transport":{drain_events:[2,3,1],establish_connection:[2,3,1],create_channel:[2,3,1],close_connection:[2,3,1]},"kombu.transport.pyamqplib":{Message:[7,1,1],Channel:[7,1,1],Connection:[7,1,1],Transport:[7,1,1]},"kombu.transport.pypika.SyncTransport":{drain_events:[10,3,1],establish_connection:[10,3,1],Connection:[10,2,1],create_channel:[10,3,1],Message:[10,1,1],close_connection:[10,3,1]},"kombu.transport.pyamqplib.Channel.Message":{body:[7,2,1],delivery_tag:[7,2,1],channel:[7,2,1]},"kombu.transport.pyamqplib.Message":{body:[7,2,1],delivery_tag:[7,2,1],channel:[7,2,1]},"kombu.compat.Consumer":{iterconsume:[16,3,1],process_next:[16,3,1],discard_all:[16,3,1],close:[16,3,1],iterqueue:[16,3,1],fetch:[16,3,1],wait:[16,3,1]},"kombu.compat":{Publisher:[16,1,1],iterconsume:[16,5,1],Consumer:[16,1,1],entry_to_queue:[16,5,1],ConsumerSet:[16,5,1]},"kombu.transport.pyamqplib.Channel":{Message:[7,1,1],message_to_python:[7,3,1],prepare_message:[7,3,1]},"kombu.transport":{pyamqplib:[7,0,0],resolve_transport:[14,5,1],pyredis:[13,0,0],base:[2,0,0],get_transport_cls:[14,5,1],memory:[4,0,0],pypika:[10,0,0]},"kombu.messaging.Consumer":{qos:[9,3,1],consume:[9,3,1],on_decode_error:[9,2,1],receive:[9,3,1],queues:[9,2,1],flow:[9,3,1],purge:[9,3,1],callbacks:[9,2,1],register_callback:[9,3,1],auto_declare:[9,2,1],cancel:[9,3,1],recover:[9,3,1],declare:[9,3,1],channel:[9,2,1]},"kombu.transport.pypika.AsyncoreConnection":{channel:[10,3,1]},"kombu.utils":{OrderedDict:[12,1,1],maybe_list:[12,5,1],partition:[12,5,1],rpartition:[12,5,1],retry_over_time:[12,5,1],repeatlast:[12,5,1]},"kombu.connection":{BrokerConnectionPool:[17,1,1],BrokerConnection:[17,1,1]},"kombu.utils.OrderedDict":{fromkeys:[12,7,1],setdefault:[12,3,1],keys:[12,3,1],items:[12,3,1],clear:[12,3,1],iteritems:[12,3,1],update:[12,3,1],pop:[12,3,1],values:[12,3,1],itervalues:[12,3,1],popitem:[12,3,1],copy:[12,3,1],iterkeys:[12,3,1]},"kombu.transport.base.Message":{ack:[2,3,1],MessageStateError:[2,4,1],acknowledged:[2,2,1],decode:[2,3,1],reject:[2,3,1],requeue:[2,3,1],payload:[2,2,1]},"kombu.transport.pyredis.Channel":{close:[13,3,1],client:[13,2,1]},"kombu.messaging":{Consumer:[9,1,1],Producer:[9,1,1]},"kombu.compat.Publisher":{close:[16,3,1],send:[16,3,1]},"kombu.transport.base":{Message:[2,1,1],Transport:[2,1,1]},"kombu.transport.pyredis.Transport":{Channel:[13,1,1]}},terms:{"default":[9,18,6,12,15,17],pluggabl:6,concept:6,consum:[6,1,15,16,9],all:[0,9,6,12,15,17],four:[6,15],sleep:[12,17],per:6,follow:[6,9],disk:15,content:[6,1,9],depend:[0,6,15],base64:6,specif:[9,17,15],send:[6,1,15,16,9],articl:[6,15],program:6,content_typ:[9,2,6,7,10,15],under:6,sens:15,discontinu:6,sent:[6,9,2,15],passiv:15,sourc:6,everi:[6,12],string:[6,17,14],fals:[9,10,12,15,16,17],unacknowledg:9,util:[1,12,8,11],wikipedia:6,fan:6,fall:9,drain_ev:[6,2,7,17,10],affect:[6,9],implement:[6,3],look:6,iterconsum:16,level:6,exchange_opt:17,messagestateerror:[0,2],list:[6,1,17,3,9],rabbitmq:[6,9,3,15],"try":[0,9,12],asyncoreconnect:10,pypika:[1,11,10],warren:6,refer:[6,1,11],localhost:[6,17],pleas:6,stompi:6,impli:15,smaller:[6,9],slower:6,maybe_list:12,direct:[6,15],zero:[6,9,15],video:6,pass:[6,9,12,17],download:6,port:[6,17],compat:[6,1,17,16,11],index:[6,1],what:6,establish_connect:[2,7,10],sub:[6,1],repli:15,section:6,connection_error:17,abl:17,brief:3,current:[6,9,17,15],delet:[6,9,17,15],version:6,"new":[6,9,12,17,15],ever:15,method:[0,9,2,6,15,17],requeu:[1,2,3,9],full:[6,14],hash:[6,15],timeouterror:0,iteritem:12,join:6,gener:[9,15],never:17,here:17,bodi:[9,2,6,7,10,15],address:17,path:[17,14],along:9,ensure_connect:17,modifi:15,sinc:6,valu:[12,7,15,10],wait:[9,6,7,15,16,17],search:1,produc:[6,1,17,9],larger:6,delivery_tag:[9,2,7,10],queue:[9,2,6,10,15,16,17],prefetch_count:9,action:[6,15],bound_exchang:[6,15],semant:17,via:6,regardless:17,primit:[6,15],modul:[6,1],releas:[11,17,5],"boolean":6,instal:[6,1,18],redi:[1,17,13,11],total:17,establish:[17,7,10],select:2,highli:6,usd:[6,15],from:[9,2,6,12,15,17],describ:15,memori:[1,4,6,11,15,17],regist:[6,9],two:[6,9,12,15],next:12,readi:9,handler:10,call:[0,9,6,8,15,17],criteria:15,msg:7,type:[6,9,18,15],tell:17,science_new:15,more:[0,6,17,15,9],prefetch_s:9,desir:6,readm:6,simplebuff:17,warn:9,flag:15,"transient":[17,15],accept:9,rabbit:[6,17],hold:15,origin:[6,9,2],must:[17,9,2,12,15],annoy:6,high:6,none:[9,2,7,10,12,14,15,16,17],word:[6,15],my_pictur:6,alia:[15,14,10],setup:6,work:[6,1,3],uniqu:[9,7,15],histori:[1,5],remain:15,tag:[9,7,15],can:[0,9,6,8,12,15,17],create_backend:17,purpos:6,root:6,fetch:16,def:[6,17],control:9,encapsul:[7,10],give:[9,12,17],process:[6,9,2],autodetect:9,share:17,indic:1,topic:[6,15],carrot:[6,1,16,11,5],want:[6,9],tarbal:6,serial:[1,18,6,9,11,15],occur:[9,17,15],alwai:[6,17,15],multipl:17,goal:6,feed_url:6,secur:6,rather:9,anoth:6,interval_step:[12,17],how:[12,17],purg:[9,15],sever:6,reject:[6,1,2,3],answer:3,simpl:9,connect_timeout:17,updat:12,map:9,max:[12,17],clone:17,befor:[6,12,17],wait_multi:7,mixin:8,mai:[6,9,17,15],end:9,data:[6,1,7,18,10],grow:17,github:6,attempt:9,nativ:6,classmethod:12,bind:[6,9,8,15],element:12,caus:6,inform:[6,15],maintain:6,media:6,exclus:[16,15],mechan:9,order:[9,12],feed:6,help:[6,1],media_exchang:6,over:[6,12],becaus:15,jpeg:6,image_queu:6,held:9,undeliver:9,brokerconnect:[6,17],still:9,paramet:[9,12,15,17,10],fit:6,binari:[6,15],itervalu:12,amqplib:[6,1,17,7,11],better:6,yaml:[6,18],window:9,restart:15,persist:[17,15],mail:[6,1,3],therefor:15,consumerset:[6,16],eur:[6,15],them:[6,15],good:6,"return":[6,2,8,12,15],thei:[6,15],reveal:3,python:[1,2,18,6,7,10],auto:[6,17,15],cover:15,initi:[17,5],bound:[6,8,15],framework:[6,1],terminolog:[6,1],amqp_messag:10,now:[6,15],discuss:3,introduct:[6,1],choic:6,term:9,name:[6,17,14,15],edit:6,close:[6,7,13,10,15,16,17],userid:[6,17],video_queu:6,separ:[6,17,15],reactiv:9,mode:15,timeout:[6,17,7],each:[6,12,17,15],januari:3,unicod:6,stock:[6,15],errback:[12,17],domain:[6,15],redeliv:9,replac:17,discard_al:16,connect:[0,1,2,4,9,6,7,13,10,11,15,16,17],our:[6,15],happen:6,orient:6,special:[6,15],out:[0,6],msgpack:[6,18],unbound:[0,6,15],item:12,miss:6,publish:[9,2,6,15,16,17],payload:[6,2],max_retri:[12,17],rewrit:[6,5],cest:5,print:[6,17],got:6,qualifi:14,insid:6,advanc:[6,9],bound_sicence_new:15,undo:9,standard:6,reason:[6,3],base:[1,2,11],dictionari:[6,12],latest:6,ask:[6,1,3,9],close_connect:[2,7,10],interval_max:[12,17],basi:6,pyyaml:18,couldn:17,could:6,synchron:15,recov:9,channel_error:17,prefetch:9,licens:[6,1],frequent:[1,3],first:6,oper:[0,9,17,15],softwar:6,create_transport:17,attapattu:15,exchang:[9,6,10,15,16,17],qualiti:9,wast:6,basic_get:10,date:[6,11,5],instruct:6,alreadi:[0,9,2,6,8,17],done:[9,17,15],messag:[0,1,2,3,9,6,7,10,11,15,17],blank:15,open:[6,17],primari:6,retry_over_tim:12,size:[6,9],prioriti:[9,7,15,10],is_bound:8,when_bound:[8,15],guest:[6,17],queue_bind:15,unknown:6,top:6,slept:17,system:6,least:15,necessarili:15,scheme:[6,15],routing_kei:[9,6,10,15,16,17],store:15,includ:[6,14],shell:6,option:[9,18,6,15,16,17],auto_delet:[16,15],signatur:9,copi:[17,12,8],message_data:[6,7,10],specifi:[6,9,17,15],process_media:6,part:[6,15],consult:14,number:[9,12,17],than:[6,9,17,15],rss:6,keyword:[9,12,17],provid:[6,17,15],remov:[2,12,15],second:[12,17],structur:[6,18,2],charact:[6,15],reus:17,were:15,posit:12,design:15,minut:15,no_ack:[16,9,17,15,10],transport:[1,2,4,6,7,13,10,11,14,17],"function":[12,17,15],abov:6,enable_callback:16,modern:6,ani:[6,9,17,7,15],raw:[6,1,15],pip:6,binding_argu:15,have:[6,9,17,15],deliv:[9,15],notbounderror:[0,6],notimplementederror:9,issu:6,built:[6,18,15],callback:[1,9,6,8,10,12,15,16,17],rout:[6,9,17,15],note:[6,17,15],rpartit:12,without:[6,1,15],read:[6,15],take:[9,12,17],which:[6,9,12,15],channel:[0,9,2,4,6,7,13,10,8,15,17],even:[6,15],shallow:12,distribut:6,usernam:17,object:[1,6,8,11,12,15,17],compress:9,dialogu:15,most:15,plai:6,regular:6,bsd:6,rkei:6,"class":[1,2,4,9,6,7,8,13,10,12,14,15,16,17],lazili:17,don:6,exc:[9,12,17],url:6,entry_to_queu:16,flow:9,doe:[6,9,14,15],declar:[6,9,15],wildcard:15,propos:6,dot:[6,15],recipi:9,imemedi:17,text:6,speedup:6,nasdaq:[6,15],protocol:6,feed_queu:6,resolve_transport:14,find:9,access:15,onli:[17,15],explicitli:15,acquir:[0,17],activemq:6,configur:[6,17],apach:6,forev:12,should:[6,9],queu:6,local:[9,15],queue_opt:17,pika:[6,1,17,11,10],info:17,contribut:[6,1],get:[6,1,17,14,15],familiar:6,stomp:6,express:6,pypi:6,synctransport:10,ssl:17,fifo:12,popitem:12,report:6,pipermail:3,requir:18,bound_science_new:15,enabl:[9,17],yield:12,patch:6,channel_id:7,common:15,partit:12,contain:15,asyncoretransport:10,where:[6,12,15],respond:15,set:[6,9,12,17,15],basic_ack:10,allowed_method:7,sep:12,"float":6,around:6,see:[6,9,17,3,15],fanout:15,mandatori:[9,15,10],result:17,arg:[16,12,7,8],disadvantag:6,serializernotinstal:18,if_unus:15,infinit:[16,12],detect:6,preconnect:17,pattern:[6,15],someth:6,particip:6,favor:6,state:15,won:15,pyredi:[1,13,11],between:[9,12,17,15],"import":[6,15],entiti:[0,1,9,11,8,15,17],attribut:[6,15],altern:[6,9],default_seri:18,auto_decod:7,nowait:[15,10],august:11,kei:[6,9,12,17,15],screen:6,brokerconnectionpool:17,cycl:6,prepare_messag:[7,10],wait_for_open:10,addit:[17,15],both:15,last:[6,12,15],execed:17,howev:6,equal:[9,12],etc:6,instanc:[9,6,7,8,12,15],mani:[6,17],iterqueu:16,feedconsum:6,com:[6,17,3],simplequeu:17,load:17,kwd:12,cancer:15,instanti:[9,17],delivery_info:2,pop:12,feed_exchang:6,header:[9,2,6,7,10,15],dispatch:9,colon:17,cancel:[9,15],poll:[6,15],assum:15,been:[0,6,2,17,9],json:[6,9,18],much:[6,12],interpret:[6,15],subscrib:9,queue_declar:15,immedi:[9,17,15,10],if_empti:15,lifo:12,imag:6,convert:[7,10],argument:[9,12,17,15],decim:6,"catch":12,delimit:15,"case":[6,15],exchange_typ:16,stolen:15,queue_argu:15,process_next:16,packag:[6,18],plain:6,servic:9,properti:[6,2,7,15,10],import_fe:6,aim:6,defin:[6,15],"while":[6,9,12],suport:17,create_channel:[2,7,10],error:[17,15],fun:[12,17],loop:[6,17],import_feed_callback:6,stop:9,ordereddict:12,advantag:6,best:6,tabl:[1,14,15],henc:15,non:15,jpg:6,destin:15,need:[6,9,17],kwarg:[2,4,7,12,13,10,8,15,16,17],avi:6,apply_glob:9,pyamqplib:[1,17,7,14,11],conn:[6,17],scienc:15,develop:6,welcom:6,perform:[9,17,15],suggest:6,make:[6,15],cross:6,same:[6,17,15],handl:9,html:3,decod:[6,9,2,18],document:[6,1],complet:17,exhaust:12,finish:[9,15],http:[6,3],hostnam:[6,17],fairli:6,rais:[9,2,6,12,15,17],user:6,improv:9,respons:15,chang:[1,5],fromkei:12,appropri:6,cjson:[6,18],whole:9,thu:6,itself:9,pickl:[6,18],person:6,client:[9,2,4,7,13,10,15,17],thi:[9,2,6,7,12,15,17],news_exchang:15,self:6,usual:17,identifi:[7,15],just:15,when:[9,6,8,12,15,17],on_return:9,activ:[9,17,15],yet:3,languag:6,task:6,password:[6,17],easi:6,also:[6,9,17,15],consumer_tag:[15,10],raw_messag:[7,10],except:[0,1,2,9,6,11,12,17,18],param:9,blog:15,poollimitexceed:[0,17],add:[0,17],simplejson:[6,18],appli:[9,17],els:6,determin:15,match:[6,15],build:6,applic:15,vendor:6,auto_declar:9,preserv:15,lolcat1:6,alias:17,insist:17,basic_publish:10,bit:6,characterist:6,recurs:6,insert:12,like:[6,15],lost:15,arbitrari:9,rajith:15,manual:[6,9,15],integ:15,server:[9,2,17,15],from_dict:16,api:[6,1,17,16,11],singl:[9,12,17,15],page:1,exceed:[0,12,17],poolexhaust:[0,17],easy_instal:6,acknowledg:[0,6,2,17,15],interv:[12,17],some:6,back:[2,7,10],global:9,on_decode_error:9,librari:[6,18,15],tmp:6,expliclti:17,"0x1002aa4c0":12,avoid:9,octet:9,subclass:9,buffer:17,imedi:9,retri:[12,17],leav:15,cnn:6,notabl:6,blockingconnect:10,either:[6,12,15],encourag:6,run:6,slight:6,reach:12,ident:[6,15],usag:[17,15],broker:[1,9,6,7,10,11,15,17],broken:17,host:17,maybe_bind:8,although:[9,15],found:15,peer:9,post:15,about:[6,3,15],central:18,socket:17,constraint:6,ack:[6,2],delivery_mod:[9,15],manag:17,exampl:[6,1,17,15],constructor:17,discard:2,mean:[9,2,15],disabl:[9,17],block:17,associ:15,own:15,reconnection_strategi:10,within:9,encod:[9,18,6,7,10,15],feedproduc:6,automat:[9,17],down:9,pair:[12,17,15],empti:15,ensur:[0,17],your:[6,15],durabl:[6,16,17,15],fast:6,transfer:6,support:[6,9,18,15],question:[1,3],iter:12,"long":[12,15],custom:[6,15],avail:[6,9,17,15],start:[6,12,17,15],setdefault:12,interfac:[6,1,2,11],tracker:[6,1],forward:15,treat:15,deliveri:[9,7,15],properli:15,register_callback:[6,9],tupl:12,recommend:15,gain:6,shamelessli:15,overflow:9,"true":[9,6,7,8,10,12,15,17],bug:[6,1],iterkei:12,reappli:17,algorithm:[6,15],consist:[6,15],possibl:6,whether:15,maximum:[12,17],until:[9,12,15],below:6,limit:[0,6,17,16,9],virtual_host:[6,17],basic_consum:10,otherwis:[9,15],clear:12,repeatlast:12,creat:[6,1,8,17,15],request:[9,17,18],"abstract":[1,8,11],doesn:[1,3],cure:15,exist:[6,15],file:6,read_timeout:7,check:15,probabl:6,again:[6,12],amqp:[1,6,7,10,11,8,15],content_encod:[9,2,6,7,10,15],excel:6,detail:6,virtual:17,event:[17,7],field:15,other:[6,9,12,17],kombu:[0,1,2,4,9,6,7,8,13,10,11,12,14,15,16,17,18],rememb:[12,17],test:6,you:[6,9,2,17,15],deseri:[6,2],star:[6,15],registri:18,fulli:14,put:2,why:3,time:[0,6,12,17],get_transport_cl:[17,14],increas:12,backend_cl:17,pool:[0,17],stai:6,unbind:15,receiv:[1,2,9,6,7,15],sphinx:6,filterfunc:16,directori:6,reliabl:6,descript:15,interval_start:[12,17],ignor:9,potenti:9,maybechannelbound:8,ensureexhaust:0,message_to_python:[7,10]},objtypes:{"0":"py:module","1":"py:class","2":"py:attribute","3":"py:method","4":"py:exception","5":"py:function","6":"py:data","7":"py:classmethod"},titles:["Exceptions - kombu.exceptions","Kombu Documentation","Base Transport Interface - kombu.transport.base","Frequently Asked Questions","In-memory Transport - kombu.transport.memory","Change history","kombu - AMQP Messaging Framework for Python","amqplib Transport - kombu.transport.pyamqplib","Object Utilities - kombu.abstract","Messaging - kombu.messaging","pika Transport - kombu.transport.pypika","API Reference","Utilities - kombu.utils","Redis Transport - kombu.transport.pyredis","Transports - kombu.transport","AMQP Entities - kombu.entity","Carrot Compatible API - kombu.compat","Broker Connections - kombu.connection","Serialization - kombu.serialization"],objnames:{"0":"Python module","1":"Python class","2":"Python attribute","3":"Python method","4":"Python exception","5":"Python function","6":"Python data","7":"Python class method"},filenames:["reference/kombu.exceptions","index","reference/kombu.transport.base","faq","reference/kombu.transport.memory","changelog","introduction","reference/kombu.transport.pyamqplib","reference/kombu.abstract","reference/kombu.messaging","reference/kombu.transport.pypika","reference/index","reference/kombu.utils","reference/kombu.transport.pyredis","reference/kombu.transport","reference/kombu.entity","reference/kombu.compat","reference/kombu.connection","reference/kombu.serialization"]})
\ No newline at end of file +Search.setIndex({objects:{"kombu.transport.pyamqplib.Transport":{drain_events:[2,3,1],establish_connection:[2,3,1],create_channel:[2,3,1],close_connection:[2,3,1]},"kombu.transport.pypika.BlockingConnection":{channel:[16,3,1]},"kombu.messaging.Producer":{channel:[12,2,1],exchange:[12,2,1],routing_key:[12,2,1],publish:[12,3,1],auto_declare:[12,2,1],declare:[12,3,1],serializer:[12,2,1]},"kombu.abstract.MaybeChannelBound":{bind:[9,3,1],when_bound:[9,3,1],maybe_bind:[9,3,1],channel:[9,2,1],is_bound:[9,2,1]},"kombu.transport.memory.Transport":{Channel:[6,1,1]},"kombu.entity.Queue":{exclusive:[10,2,1],unbind:[10,3,1],when_bound:[10,3,1],name:[10,2,1],exchange:[10,2,1],auto_delete:[10,2,1],durable:[10,2,1],routing_key:[10,2,1],purge:[10,3,1],queue_bind:[10,3,1],queue_arguments:[10,2,1],get:[10,3,1],binding_arguments:[10,2,1],cancel:[10,3,1],queue_declare:[10,3,1],"delete":[10,3,1],declare:[10,3,1],channel:[10,2,1],consume:[10,3,1]},"kombu.transport.pypika.AsyncoreTransport":{Connection:[16,2,1]},"kombu.connection.BrokerConnection":{SimpleBuffer:[21,3,1],info:[21,3,1],create_transport:[21,3,1],SimpleQueue:[21,3,1],channel_errors:[21,2,1],drain_events:[21,3,1],acquire:[21,3,1],channel:[21,3,1],host:[21,2,1],ensure_connection:[21,3,1],connection:[21,2,1],connection_errors:[21,2,1],ensure:[21,3,1],connect:[21,3,1],get_transport_cls:[21,3,1],create_backend:[21,3,1],release:[21,3,1],close:[21,3,1],clone:[21,3,1],transport:[21,2,1]},"kombu.entity":{Queue:[10,1,1],Binding:[10,2,1],Exchange:[10,1,1]},"kombu.transport.pyamqplib.Connection":{read_timeout:[2,3,1],drain_events:[2,3,1],wait_multi:[2,3,1],channel:[2,3,1]},"kombu.transport.pyredis.Transport.Channel":{close:[3,3,1],client:[3,2,1]},"kombu.entity.Exchange":{name:[10,2,1],auto_delete:[10,2,1],delivery_mode:[10,2,1],publish:[10,3,1],declare:[10,3,1],arguments:[10,2,1],Message:[10,3,1],type:[10,2,1],durable:[10,2,1],channel:[10,2,1],"delete":[10,3,1]},"kombu.transport.virtual.Message":{reject:[1,3,1]},"kombu.connection.BrokerConnectionPool":{acquire:[21,3,1],replace:[21,3,1],release:[21,3,1],ensure:[21,3,1],active:[21,2,1],close:[21,3,1],total:[21,2,1],grow:[21,3,1]},"kombu.transport.virtual.Transport.Channel.Message":{reject:[1,3,1]},"kombu.abstract":{Object:[9,1,1],MaybeChannelBound:[9,1,1]},"kombu.transport.virtual.Channel.Message":{reject:[1,3,1]},"kombu.exceptions":{TimeoutError:[0,6,1],MessageStateError:[0,6,1],EnsureExhausted:[0,6,1],NotBoundError:[0,6,1],PoolExhausted:[0,6,1],PoolLimitExceeded:[0,6,1]},"kombu.transport.memory":{Channel:[6,1,1],Transport:[6,1,1]},"kombu.transport.pypika":{SyncTransport:[16,1,1],Channel:[16,1,1],Message:[16,1,1],AsyncoreTransport:[16,1,1],AsyncoreConnection:[16,1,1],BlockingConnection:[16,1,1]},"kombu.transport.pyamqplib.Channel.Message":{body:[2,2,1],delivery_tag:[2,2,1],channel:[2,2,1]},"kombu.transport.pypika.Channel":{basic_ack:[16,3,1],basic_get:[16,3,1],basic_publish:[16,3,1],basic_consume:[16,3,1],message_to_python:[16,3,1],Message:[16,1,1],prepare_message:[16,3,1]},"kombu.transport.virtual.Channel":{exchange_declare:[1,3,1],qos_manager:[1,2,1],basic_ack:[1,3,1],queue_purge:[1,3,1],exchange_delete:[1,3,1],basic_qos:[1,3,1],drain_events:[1,3,1],queue_bind:[1,3,1],basic_reject:[1,3,1],flow:[1,3,1],basic_get:[1,3,1],basic_recover:[1,3,1],basic_cancel:[1,3,1],basic_consume:[1,3,1],queue_delete:[1,3,1],queue_declare:[1,3,1],basic_publish:[1,3,1],close:[1,3,1],Message:[1,1,1],prepare_message:[1,3,1],message_to_python:[1,3,1]},"kombu.serialization":{encode:[18,4,1],registry:[18,7,1],SerializerNotInstalled:[18,6,1]},kombu:{compat:[20,0,0],utils:[17,0,0],entity:[10,0,0],connection:[21,0,0],messaging:[12,0,0],exceptions:[0,0,0],serialization:[18,0,0],"abstract":[9,0,0],transport:[4,0,0]},"kombu.transport.base.Transport":{drain_events:[13,3,1],establish_connection:[13,3,1],create_channel:[13,3,1],close_connection:[13,3,1]},"kombu.transport.pyamqplib":{Message:[2,1,1],Channel:[2,1,1],Connection:[2,1,1],Transport:[2,1,1]},"kombu.transport.pyredis.Channel":{close:[3,3,1],client:[3,2,1]},"kombu.transport.pypika.SyncTransport":{drain_events:[16,3,1],establish_connection:[16,3,1],Connection:[16,2,1],create_channel:[16,3,1],Message:[16,1,1],close_connection:[16,3,1]},"kombu.transport.base.Message":{ack:[13,3,1],MessageStateError:[13,6,1],acknowledged:[13,2,1],decode:[13,3,1],reject:[13,3,1],requeue:[13,3,1],payload:[13,2,1]},"kombu.transport.pyamqplib.Message":{body:[2,2,1],delivery_tag:[2,2,1],channel:[2,2,1]},"kombu.transport.virtual.Transport":{close_channel:[1,3,1],drain_events:[1,3,1],establish_connection:[1,3,1],create_channel:[1,3,1],close_connection:[1,3,1],Channel:[1,1,1],Cycle:[1,2,1]},"kombu.compat.Consumer":{iterconsume:[20,3,1],process_next:[20,3,1],discard_all:[20,3,1],close:[20,3,1],iterqueue:[20,3,1],fetch:[20,3,1],wait:[20,3,1]},"kombu.messaging.Consumer":{qos:[12,3,1],register_callback:[12,3,1],on_decode_error:[12,2,1],receive:[12,3,1],queues:[12,2,1],flow:[12,3,1],purge:[12,3,1],callbacks:[12,2,1],auto_declare:[12,2,1],cancel:[12,3,1],recover:[12,3,1],declare:[12,3,1],channel:[12,2,1],consume:[12,3,1]},"kombu.transport.pyamqplib.Channel":{Message:[2,1,1],message_to_python:[2,3,1],prepare_message:[2,3,1]},"kombu.messaging":{Consumer:[12,1,1],Producer:[12,1,1]},"kombu.transport":{pyamqplib:[2,0,0],resolve_transport:[4,4,1],pyredis:[3,0,0],virtual:[1,0,0],base:[13,0,0],get_transport_cls:[4,4,1],memory:[6,0,0],pypika:[16,0,0]},"kombu.transport.virtual.QualityOfService":{ack:[1,3,1],restore_unacked:[1,3,1],restore_unacked_once:[1,3,1],can_consume:[1,3,1],requeue:[1,3,1],append:[1,3,1]},"kombu.compat":{Publisher:[20,1,1],iterconsume:[20,4,1],Consumer:[20,1,1],entry_to_queue:[20,4,1],ConsumerSet:[20,4,1]},"kombu.transport.pypika.AsyncoreConnection":{channel:[16,3,1]},"kombu.utils":{OrderedDict:[17,1,1],maybe_list:[17,4,1],partition:[17,4,1],rpartition:[17,4,1],retry_over_time:[17,4,1],repeatlast:[17,4,1]},"kombu.connection":{BrokerConnectionPool:[21,1,1],BrokerConnection:[21,1,1]},"kombu.utils.OrderedDict":{fromkeys:[17,5,1],setdefault:[17,3,1],keys:[17,3,1],items:[17,3,1],clear:[17,3,1],iteritems:[17,3,1],update:[17,3,1],pop:[17,3,1],values:[17,3,1],itervalues:[17,3,1],popitem:[17,3,1],copy:[17,3,1],iterkeys:[17,3,1]},"kombu.transport.virtual.FairCycle":{get:[1,3,1]},"kombu.transport.virtual":{Message:[1,1,1],Transport:[1,1,1],QualityOfService:[1,1,1],Channel:[1,1,1],FairCycle:[1,1,1]},"kombu.transport.virtual.Transport.Channel":{exchange_declare:[1,3,1],basic_get:[1,3,1],qos_manager:[1,2,1],basic_ack:[1,3,1],queue_purge:[1,3,1],queue_bind:[1,3,1],basic_qos:[1,3,1],drain_events:[1,3,1],basic_reject:[1,3,1],flow:[1,3,1],exchange_delete:[1,3,1],basic_recover:[1,3,1],basic_publish:[1,3,1],basic_consume:[1,3,1],message_to_python:[1,3,1],queue_declare:[1,3,1],basic_cancel:[1,3,1],close:[1,3,1],Message:[1,1,1],prepare_message:[1,3,1],queue_delete:[1,3,1]},"kombu.transport.pyredis":{Channel:[3,1,1],Transport:[3,1,1]},"kombu.compat.Publisher":{close:[20,3,1],send:[20,3,1]},"kombu.transport.base":{Message:[13,1,1],Transport:[13,1,1]},"kombu.transport.pyredis.Transport":{Channel:[3,1,1]}},terms:{"default":[11,18,12,7,17,10,21],pluggabl:7,concept:7,consum:[11,12,5,7,1,10,20],all:[0,12,7,17,10,21],interchang:11,four:[7,10],sleep:[17,21],per:7,follow:[7,12],disk:10,content:[7,5,12],depend:[0,7,11,10],base64:7,specif:[11,12,21,10],send:[11,5,12,7,15,10,20],articl:[7,10],program:7,under:7,sens:10,discontinu:7,sent:[7,12,13,10],passiv:10,mpg:11,sourc:7,everi:[7,17],string:[7,21,4],fals:[12,1,16,17,10,20,21],unacknowledg:12,util:[5,9,17,8],wikipedia:7,fan:7,fall:12,drain_ev:[13,7,1,2,16,21],affect:[7,12],look:7,iterconsum:20,level:[7,11],exchange_opt:21,messagestateerror:[0,13],list:[11,5,12,7,14,21],rabbitmq:[7,12,14,10],"try":[0,12,17],asyncoreconnect:16,pypika:[5,16,8],warren:7,refer:[7,5,11,8],localhost:[7,11,21],pleas:7,stompi:7,impli:10,smaller:[7,12],slower:7,maybe_list:17,direct:[7,1,10],zero:[7,12,10],video:[7,11],pass:[7,12,17,21],download:7,port:[7,11,21],append:1,compat:[7,5,21,20,8],index:[7,5],what:7,establish_connect:[1,13,2,16],sub:[7,5],repli:10,section:7,connection_error:21,abl:21,brief:14,current:[7,11,21,12,10],delet:[7,12,21,10],version:7,"new":[7,12,17,21,10],ever:10,method:[0,11,13,12,7,10,21],requeu:[1,13,14,12],full:[7,11,4],hash:[7,10],timeouterror:0,iteritem:17,join:7,gener:[12,10],never:21,here:[11,21],bodi:[12,13,7,2,16,10],address:21,path:[21,4],along:12,ensure_connect:21,modifi:10,sinc:7,valu:[16,2,17,10],wait:[12,7,2,10,20,21],search:5,produc:[7,5,21,11,12],larger:7,delivery_tag:[16,1,13,2,12],queue:[11,12,13,7,1,16,10,20,21],datetim:11,prefetch_count:[1,12],qos_manag:1,action:[7,10],bound_exchang:[7,10],chanc:1,semant:21,via:7,regardless:21,qualityofservic:1,primit:[7,10],modul:[7,5],releas:[8,21,15,19],"boolean":7,basic_qo:1,instal:[7,18],redi:[11,5,21,3,8],total:21,establish:[11,21,2,16],select:13,highli:7,usd:[7,10],from:[11,12,13,7,1,17,10,21],describ:10,memori:[11,5,6,7,8,10,21],regist:[7,12],two:[7,11,17,12,10],next:17,readi:12,handler:16,call:[0,11,12,7,9,10,21],criteria:10,msg:2,type:[7,1,18,12,10],tell:21,science_new:10,more:[0,7,21,12,10],prefetch_s:[1,12],desir:7,faircycl:1,readm:7,simplebuff:[11,21],warn:12,flag:10,"transient":[11,21,10],accept:12,rabbit:[7,21],aris:11,hold:10,content_typ:[12,13,7,1,2,16,10],must:[21,12,13,17,10],annoy:7,high:7,none:[11,12,13,1,2,16,17,4,10,20,21],word:[7,10],my_pictur:7,alia:[1,16,4,10],setup:7,work:[7,14],uniqu:[12,2,10],histori:[5,19],remain:10,tag:[12,2,10],can:[0,11,12,7,17,9,10,21],create_backend:21,purpos:7,root:7,fetch:20,def:[7,11,21],control:12,encapsul:[2,16],give:[12,17,21],process:[7,11,13,12],autodetect:12,share:21,dump_entri:11,indic:5,topic:[7,10],carrot:[7,5,19,20,8],exchange_delet:1,want:[7,11,12],tarbal:7,serial:[11,5,12,7,8,10,18],occur:[12,21,10],alwai:[7,21,10],multipl:21,goal:7,feed_url:7,secur:7,rather:12,anoth:7,interval_step:[17,21],how:[17,21],purg:[12,10],"__init__":11,reject:[7,1,13,14],answer:14,instead:11,simpl:[11,5,15,12],connect_timeout:21,updat:17,map:12,resourc:1,max:[17,21],clone:21,execed:21,befor:[7,17,21],wait_multi:2,mixin:9,date:[7,8,11,15,19],end:12,data:[11,5,18,7,2,16],grow:21,github:7,attempt:12,nativ:7,classmethod:17,bind:[7,12,9,10],element:17,caus:7,inform:[7,10],maintain:7,media:7,exclus:[20,10],mechan:12,order:[12,17],queue_delet:1,origin:[7,12,13],help:7,media_exchang:7,over:[7,17],becaus:10,jpeg:7,image_queu:7,held:12,undeliver:12,brokerconnect:[7,11,21],still:12,paramet:[12,17,16,21,10],fit:7,binari:[7,10],itervalu:17,amqplib:[11,5,7,2,8,21],better:7,yaml:[7,18],window:12,restart:10,persist:[11,21,10],mail:[7,5,14],therefor:10,consumerset:[7,20],eur:[7,10],them:[7,11,10],good:7,"return":[7,9,17,13,10],thei:[7,11,10],reveal:14,python:[11,5,13,18,7,2,16],auto:[7,21,10],cover:10,initi:[21,19],bound:[7,9,10],framework:[7,5],terminolog:7,amqp_messag:16,restore_unacked_onc:1,now:[7,10],discuss:14,introduct:[7,5],choic:7,term:12,name:[7,11,21,4,10],edit:7,close:[11,7,1,2,3,16,10,20,21],userid:[7,11,21],restore_unack:1,video_queu:7,separ:[7,21,10],reactiv:12,mode:10,timeout:[7,1,21,2,11],each:[7,1,17,21,10],januari:14,unicod:7,stock:[7,10],errback:[17,21],recommend:10,domain:[7,10],redeliv:12,replac:21,discard_al:20,connect:[0,5,13,11,6,12,7,1,2,15,3,16,8,10,20,21],our:[7,10],happen:[7,11],orient:7,special:[7,10],out:[0,7],msgpack:[7,18],unbound:[0,7,10],item:17,miss:7,publish:[12,13,7,10,20,21],primari:7,max_retri:[17,21],rewrit:[7,19],cest:19,sever:[7,11],print:[7,11,21],got:7,qualifi:4,insid:7,advanc:[7,12],bound_sicence_new:10,undo:12,standard:[7,11],reason:[7,14],base:[5,13,8],dictionari:[7,17],latest:7,ask:[7,5,14,12],close_connect:[1,13,2,16],interval_max:[17,21],basi:7,pyyaml:18,couldn:21,could:7,synchron:10,fromtimestamp:11,recov:12,channel_error:21,prefetch:12,log_messag:11,licens:7,frequent:[5,14],first:7,oper:[0,12,21,10],softwar:7,create_transport:21,attapattu:10,do_restor:1,exchange_declar:1,exchang:[11,12,7,1,16,10,20,21],qualiti:12,wast:7,basic_get:[1,16],mai:[7,11,21,12,10],instruct:7,alreadi:[0,12,13,7,9,21],done:[12,21,10],messag:[0,5,13,14,11,12,7,1,2,15,16,8,10,21],blank:10,open:[7,21],payload:[7,1,13,11],retry_over_tim:17,size:[7,12],prioriti:[1,16,2,12,10],is_bound:9,differ:11,when_bound:[9,10],guest:[7,11,21],queue_bind:[1,10],unknown:7,top:7,slept:21,system:7,least:10,necessarili:10,scheme:[7,10],routing_kei:[12,7,1,16,10,20,21],store:10,includ:[7,4],shell:7,option:[12,18,7,10,20,21],auto_delet:[20,1,10],signatur:12,copi:[21,9,17],message_data:[7,1,2,16],specifi:[7,11,21,12,10],process_media:7,forward:10,part:[7,10],consult:4,number:[11,12,17,21],than:[7,12,21,10],rss:7,keyword:[12,17,21],provid:[7,21,10],remov:[11,13,17,10],second:[17,21],structur:[7,18,13],charact:[7,10],reus:21,were:10,posit:17,design:10,minut:10,no_ack:[12,1,16,10,20,21],transport:[11,5,13,6,7,1,2,15,3,16,8,4,21],"function":[17,21,10],abov:[7,11],enable_callback:20,modern:7,ani:[7,12,21,2,10],raw:[7,5,10],pip:7,binding_argu:10,have:[7,11,21,12,10],deliv:[12,10],notbounderror:[0,7],notimplementederror:12,predic:1,issu:7,built:[7,18,10],equival:11,callback:[11,5,12,7,1,17,16,9,10,20,21],rout:[7,11,21,12,10],note:[7,21,10],rpartit:17,without:[7,5,11,10],read:[7,10],take:[12,17,21],which:[7,11,17,12,10],channel:[0,11,13,6,12,7,1,2,3,16,9,10,21],even:[7,11,10],shallow:17,distribut:7,usernam:[11,21],object:[11,5,7,17,8,9,10,21],compress:[11,12],dialogu:10,most:10,plai:7,regular:7,bsd:7,rkei:7,"class":[11,5,13,6,12,7,1,2,17,3,16,9,4,10,20,21],lazili:21,don:7,exc:[12,17,21],url:7,entry_to_queu:20,flow:[1,12],doe:[7,12,4,10],declar:[7,12,10],wildcard:10,pattern:[7,10],propos:7,dot:[7,10],recipi:12,imemedi:21,text:7,speedup:7,alias:21,nasdaq:[7,10],protocol:7,feed_queu:7,resolve_transport:4,find:12,access:10,onli:[11,21,10],explicitli:[11,10],acquir:[0,21],activemq:7,configur:[7,21],apach:7,forev:17,should:[7,12],queu:7,local:[12,10],queue_opt:21,pika:[11,5,7,16,8,21],info:[11,21],contribut:7,get:[11,7,1,4,10,21],familiar:7,stomp:7,express:7,pypi:7,synctransport:16,ssl:21,fifo:17,popitem:17,report:7,pipermail:14,requir:[11,18],bound_science_new:10,enabl:[12,21],yield:17,patch:7,channel_id:2,feed:7,common:10,partit:17,contain:10,asyncoretransport:16,where:[7,1,17,10],respond:10,set:[11,12,7,1,17,10,21],basic_ack:[1,16],allowed_method:2,sep:17,"float":7,basic_reject:1,around:7,see:[11,12,7,14,10,21],fanout:10,mandatori:[12,16,10],result:21,arg:[20,9,2,17],disadvantag:7,serializernotinstal:18,if_unus:[1,10],infinit:[20,17],can_consum:1,detect:7,preconnect:21,databas:11,someth:[7,11],particip:7,favor:7,state:10,won:10,pyredi:[5,3,8],between:[12,17,21,10],"import":[7,11,10],entiti:[0,5,12,8,9,10],attribut:[7,10],altern:[7,12],default_seri:18,auto_decod:2,nowait:[16,10],august:[8,15],kei:[11,12,7,17,10,21],screen:7,xrang:11,brokerconnectionpool:21,cycl:[7,1],prepare_messag:[1,2,16],wait_for_open:16,come:11,addit:[11,21,10],both:[11,10],last:[7,17,10],queue_nam:11,howev:7,equal:[1,17,12],etc:7,instanc:[12,7,2,17,9,10],context:11,mani:[7,21],iterqueu:20,feedconsum:7,com:[7,21,14],simplequeu:[11,21],load:21,kwd:17,cancer:10,instanti:[12,21],delivery_info:13,pop:17,feed_exchang:7,header:[12,13,7,1,2,16,10],dispatch:12,colon:21,param:12,cancel:[12,10],guid:[5,15],assum:10,been:[0,7,13,21,12],json:[7,11,18,12],much:[7,17],interpret:[7,10],basic:11,queue_declar:[1,10],immedi:[12,21,16,10],queue_purg:1,if_empti:[1,10],lifo:17,imag:7,convert:[2,16],argument:[11,12,1,17,10,21],decim:7,"catch":17,former:11,delimit:10,"case":[7,10],exchange_typ:20,stolen:10,queue_argu:10,process_next:20,packag:[7,18],plain:7,servic:12,properti:[13,7,1,2,16,10],import_fe:7,aim:7,defin:[7,11,10],"while":[7,11,17,12],suport:21,create_channel:[1,13,2,16],error:[11,21,10],fun:[1,17,21],loop:[7,21],import_feed_callback:7,stop:12,ordereddict:17,advantag:7,best:7,"__main__":11,henc:10,non:10,jpg:7,destin:10,need:[7,11,21,12],kwarg:[13,6,1,2,17,3,16,9,10,20,21],avi:7,apply_glob:[1,12],pyamqplib:[5,21,2,4,8],descript:10,conn:[7,21],scienc:10,develop:7,welcom:7,perform:[12,21,10],suggest:7,make:[7,11,10],passowrd:11,cross:7,same:[7,11,21,10],handl:12,html:14,decod:[7,12,13,18],timestamp:11,document:[7,5,11],complet:21,exhaust:17,finish:[12,10],http:[7,14],hostnam:[7,11,21],fairli:7,rais:[12,13,7,17,10,21],user:[7,5,11,15],improv:12,respons:10,implement:[7,14],fromkei:17,appropri:7,cjson:[7,18],whole:12,thu:7,itself:12,cutekitten:11,pickl:[7,18],person:7,client:[12,13,6,1,2,3,16,10,21],thi:[11,12,13,7,2,17,10,21],choos:11,news_exchang:10,self:[7,11],usual:21,identifi:[2,10],entri:11,just:10,when:[11,12,7,17,9,10,21],on_return:12,activ:[1,21,12,10],yet:[11,14],languag:7,task:7,password:[7,11,21],easi:7,also:[7,11,21,12,10],close_channel:1,consumer_tag:[1,16,10],raw_messag:[1,2,16],except:[0,5,13,12,7,8,17,21,18],shortcut:11,blog:10,poollimitexceed:[0,21],add:[0,21],poll:[7,10],appli:[12,21],els:7,logger:11,determin:10,match:[7,10],build:7,applic:10,vendor:7,auto_declar:12,preserv:10,lolcat1:7,tabl:[5,4,10],insist:21,basic_publish:[1,16],bit:7,characterist:7,recurs:7,insert:17,like:[7,11,10],lost:10,arbitrari:12,rajith:10,manual:[7,12,10],integ:10,server:[12,13,21,10],basic_recov:1,from_dict:20,api:[7,5,21,20,8],singl:[11,12,17,21,10],if_unusu:1,page:5,exceed:[0,17,21],poolexhaust:[0,21],easy_instal:7,acknowledg:[0,7,13,21,10],interv:[1,17,21],some:7,back:[13,2,16],global:12,on_decode_error:12,basic_cancel:1,log_queu:11,librari:[7,11,18,10],tmp:7,expliclti:21,"0x1002aa4c0":17,avoid:12,octet:12,subclass:12,buffer:[11,21],imedi:12,retri:[17,21],leav:10,cnn:7,notabl:7,blockingconnect:16,either:[7,17,10],encourag:7,run:7,slight:7,reach:17,ident:[7,10],usag:[21,10],broker:[5,12,7,2,16,8,10,21],broken:21,host:[11,21],maybe_bind:9,although:[12,10],found:10,peer:12,"__name__":11,post:10,about:[7,14,10],central:18,socket:[11,21],constraint:7,ack:[7,1,13,11],slightli:11,delivery_mod:[12,10],manag:21,exampl:[7,11,21,10],constructor:21,discard:13,mean:[11,12,13,10],disabl:[12,21],block:[11,21],associ:10,own:[11,10],reconnection_strategi:16,within:12,encod:[11,12,18,7,2,16,10],feedproduc:7,automat:[12,21],latter:11,down:12,pair:[17,21,10],empti:[1,10],ensur:[0,21],chang:[5,19],your:[7,11,10],durabl:[7,1,21,20,10],fast:7,log:11,transfer:7,support:[7,11,18,12,10],question:[5,14],iter:17,"long":[17,10],custom:[7,10],avail:[7,12,21,10],start:[7,17,21,10],setdefault:17,interfac:[11,5,13,7,1,15,8],tracker:7,myqueu:11,treat:10,deliveri:[12,2,10],properli:10,register_callback:[7,12],tupl:17,subscrib:12,gain:7,shamelessli:10,overflow:12,"true":[11,12,7,1,2,17,16,9,10,21],bug:7,iterkei:17,reappli:21,algorithm:[7,10],consist:[7,10],possibl:7,whether:10,maximum:[17,21],until:[12,17,10],below:7,limit:[0,7,21,20,12],virtual_host:[7,11,21],basic_consum:[1,16],otherwis:[12,10],clear:17,repeatlast:17,creat:[11,5,7,9,10,21],request:[12,21,18],"abstract":[5,9,8],filenam:11,doesn:14,cure:10,exist:[7,10],file:7,read_timeout:2,check:10,probabl:7,again:[7,17],amqp:[11,5,7,2,16,8,9,10],content_encod:[12,13,7,1,2,16,10],excel:[7,11],simplejson:[7,18],virtual:[11,1,21,8,5],event:[21,2],field:[11,10],other:[7,11,17,21,12],kombu:[0,5,13,11,6,12,7,1,2,17,3,16,8,9,4,10,20,21,18],rememb:[17,21],test:7,you:[11,12,13,7,10,21],deseri:[7,11,13],star:[7,10],registri:18,fulli:4,put:[11,13],why:14,time:[0,7,17,11,21],get_transport_cl:[21,4],increas:17,backend_cl:21,pool:[0,21],stai:7,unbind:10,receiv:[11,5,13,12,7,2,15,10],sphinx:7,filterfunc:20,directori:7,reliabl:7,gethostnam:11,detail:7,interval_start:[17,21],ignor:12,potenti:12,maybechannelbound:9,ensureexhaust:0,message_to_python:[1,2,16]},objtypes:{"0":"py:module","1":"py:class","2":"py:attribute","3":"py:method","4":"py:function","5":"py:classmethod","6":"py:exception","7":"py:data"},titles:["Exceptions - kombu.exceptions","Virtual Transport Interface - kombu.transport.virtual","amqplib Transport - kombu.transport.pyamqplib","Redis Transport - kombu.transport.pyredis","Transports - kombu.transport","Kombu Documentation","In-memory Transport - kombu.transport.memory","kombu - AMQP Messaging Framework for Python","API Reference","Object Utilities - kombu.abstract","AMQP Entities - kombu.entity","Simple Interface","Messaging - kombu.messaging","Base Transport Interface - kombu.transport.base","Frequently Asked Questions","User Guide","pika Transport - kombu.transport.pypika","Utilities - kombu.utils","Serialization - kombu.serialization","Change history","Carrot Compatible API - kombu.compat","Broker Connections - kombu.connection"],objnames:{"0":"Python module","1":"Python class","2":"Python attribute","3":"Python method","4":"Python function","5":"Python class method","6":"Python exception","7":"Python data"},filenames:["reference/kombu.exceptions","reference/kombu.transport.virtual","reference/kombu.transport.pyamqplib","reference/kombu.transport.pyredis","reference/kombu.transport","index","reference/kombu.transport.memory","introduction","reference/index","reference/kombu.abstract","reference/kombu.entity","userguide/simple","reference/kombu.messaging","reference/kombu.transport.base","faq","userguide/index","reference/kombu.transport.pypika","reference/kombu.utils","reference/kombu.serialization","changelog","reference/kombu.compat","reference/kombu.connection"]})
\ No newline at end of file diff --git a/sources/index.txt b/sources/index.txt index 228c5730..b9971f30 100644 --- a/sources/index.txt +++ b/sources/index.txt @@ -4,9 +4,10 @@ Kombu Documentation Contents: .. toctree:: - :maxdepth: 3 + :maxdepth: 2 introduction + userguide/index faq reference/index changelog |