Rendered documentation for Github Pages.

5 files changed, 8 insertions, 141 deletions

diff --git a/genindex.html b/genindex.html
index 8fcaf767..319ff097 100644
--- a/genindex.html
+++ b/genindex.html
@@ -92,9 +92,6 @@
       <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Message.MessageStateError.args">(kombu.transport.virtual.Message.MessageStateError attribute)</a></dt>
   </dl></dd>
     <dt><a href="reference/kombu.entity.html#kombu.entity.Exchange.arguments">arguments (kombu.entity.Exchange attribute)</a></dt>
-    <dd><dl>
-      <dt><a href="reference/kombu.messaging.html#kombu.messaging.Producer.arguments">(kombu.messaging.Producer attribute)</a></dt>
-  </dl></dd>
     <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>
@@ -104,7 +101,6 @@
     <dt><a href="reference/kombu.entity.html#kombu.entity.Exchange.auto_delete">auto_delete (kombu.entity.Exchange attribute)</a></dt>
     <dd><dl>
       <dt><a href="reference/kombu.entity.html#kombu.entity.Queue.auto_delete">(kombu.entity.Queue attribute)</a></dt>
-      <dt><a href="reference/kombu.messaging.html#kombu.messaging.Producer.auto_delete">(kombu.messaging.Producer attribute)</a></dt>
   </dl></dd>
 </dl></td>
 </tr></table>
@@ -203,7 +199,7 @@
       <dt><a href="reference/kombu.entity.html#kombu.entity.Exchange.channel">(kombu.entity.Exchange attribute)</a></dt>
       <dt><a href="reference/kombu.entity.html#kombu.entity.Queue.channel">(kombu.entity.Queue attribute)</a></dt>
       <dt><a href="reference/kombu.messaging.html#kombu.messaging.Consumer.channel">(kombu.messaging.Consumer attribute)</a></dt>
-      <dt><a href="reference/kombu.messaging.html#kombu.messaging.Producer.channel">(kombu.messaging.Producer attribute)</a>, <a href="reference/kombu.messaging.html#kombu.messaging.Producer.channel">[1]</a></dt>
+      <dt><a href="reference/kombu.messaging.html#kombu.messaging.Producer.channel">(kombu.messaging.Producer attribute)</a></dt>
       <dt><a href="reference/kombu.pidbox.html#kombu.pidbox.Node.channel">(kombu.pidbox.Node attribute)</a></dt>
       <dt><a href="reference/kombu.simple.html#kombu.simple.SimpleBuffer.channel">(kombu.simple.SimpleBuffer attribute)</a></dt>
       <dt><a href="reference/kombu.simple.html#kombu.simple.SimpleQueue.channel">(kombu.simple.SimpleQueue attribute)</a></dt>
@@ -372,9 +368,6 @@
   </dl></dd>
     <dt><a href="reference/kombu.transport.base.html#kombu.transport.base.Message.delivery_info">delivery_info (kombu.transport.base.Message attribute)</a></dt>
     <dt><a href="reference/kombu.entity.html#kombu.entity.Exchange.delivery_mode">delivery_mode (kombu.entity.Exchange attribute)</a></dt>
-    <dd><dl>
-      <dt><a href="reference/kombu.messaging.html#kombu.messaging.Producer.delivery_mode">(kombu.messaging.Producer attribute)</a></dt>
-  </dl></dd>
     <dt><a href="reference/kombu.transport.base.html#kombu.transport.base.Message.delivery_tag">delivery_tag (kombu.transport.base.Message attribute)</a></dt>
     <dd><dl>
       <dt><a href="reference/kombu.transport.librabbitmq.html#kombu.transport.librabbitmq.Channel.Message.delivery_tag">(kombu.transport.librabbitmq.Channel.Message attribute)</a></dt>
@@ -410,7 +403,6 @@
     <dt><a href="reference/kombu.entity.html#kombu.entity.Exchange.durable">durable (kombu.entity.Exchange attribute)</a></dt>
     <dd><dl>
       <dt><a href="reference/kombu.entity.html#kombu.entity.Queue.durable">(kombu.entity.Queue attribute)</a></dt>
-      <dt><a href="reference/kombu.messaging.html#kombu.messaging.Producer.durable">(kombu.messaging.Producer attribute)</a></dt>
   </dl></dd>
 </dl></td>
 </tr></table>
@@ -653,7 +645,6 @@
     <dt><a href="reference/kombu.entity.html#kombu.entity.Exchange.name">name (kombu.entity.Exchange attribute)</a></dt>
     <dd><dl>
       <dt><a href="reference/kombu.entity.html#kombu.entity.Queue.name">(kombu.entity.Queue attribute)</a></dt>
-      <dt><a href="reference/kombu.messaging.html#kombu.messaging.Producer.name">(kombu.messaging.Producer attribute)</a></dt>
   </dl></dd>
     <dt><a href="reference/kombu.pidbox.html#kombu.pidbox.Mailbox.namespace">namespace (kombu.pidbox.Mailbox attribute)</a></dt>
     <dt><a href="reference/kombu.messaging.html#kombu.messaging.Consumer.no_ack">no_ack (kombu.messaging.Consumer attribute)</a></dt>
@@ -916,7 +907,6 @@
     <dt><a href="reference/kombu.transport.html#kombu.transport.TRANSPORT_ALIASES">TRANSPORT_ALIASES (in module kombu.transport)</a></dt>
     <dt><a href="reference/kombu.entity.html#kombu.entity.Exchange.type">type (kombu.entity.Exchange attribute)</a></dt>
     <dd><dl>
-      <dt><a href="reference/kombu.messaging.html#kombu.messaging.Producer.type">(kombu.messaging.Producer attribute)</a></dt>
       <dt><a href="reference/kombu.pidbox.html#kombu.pidbox.Mailbox.type">(kombu.pidbox.Mailbox attribute)</a></dt>
   </dl></dd>
     <dt><a href="reference/kombu.transport.virtual.html#kombu.transport.virtual.Channel.typeof">typeof() (kombu.transport.virtual.Channel method)</a></dt>
diff --git a/objects.inv b/objects.inv
index 5d528b86..27e98726 100644
--- a/objects.inv
+++ b/objects.inv
diff --git a/reference/kombu.messaging.html b/reference/kombu.messaging.html
index efd54360..98edfb9c 100644
--- a/reference/kombu.messaging.html
+++ b/reference/kombu.messaging.html
@@ -95,9 +95,10 @@ compression.</li>
 <li><strong>auto_declare</strong> &#8211; Automatically declare the exchange
 at instantiation. Default is <tt class="xref py py-const xref docutils literal"><span class="pre">True</span></tt>.</li>
 <li><strong>on_return</strong> &#8211; Callback to call for undeliverable messages,
-when the <cite>mandatory</cite> or <cite>imediate</cite> arguments to
+when the <cite>mandatory</cite> or <cite>immediate</cite> arguments to
 <a class="reference internal" href="#kombu.messaging.Producer.publish" title="kombu.messaging.Producer.publish"><tt class="xref py py-meth docutils literal"><span class="pre">publish()</span></tt></a> is used. This callback needs the following
-signature: <cite>(exception, exchange, routing_key, message)</cite>.</li>
+signature: <cite>(exception, exchange, routing_key, message)</cite>.
+Note that the producer needs to drain events to use this feature.</li>
 </ul>
 </td>
 </tr>
@@ -112,131 +113,7 @@ signature: <cite>(exception, exchange, routing_key, message)</cite>.</li>
 <dl class="attribute">
 <dt id="kombu.messaging.Producer.exchange">
 <tt class="descname">exchange</tt><a class="headerlink" href="#kombu.messaging.Producer.exchange" title="Permalink to this definition">¶</a></dt>
-<dd><p>An Exchange declaration.</p>
-<table class="docutils field-list" frame="void" rules="none">
-<col class="field-name" />
-<col class="field-body" />
-<tbody valign="top">
-<tr class="field"><th class="field-name">Parameters:</th><td class="field-body"><ul class="first last simple">
-<li><strong>name</strong> &#8211; See <a class="reference internal" href="#kombu.messaging.Producer.name" title="kombu.messaging.Producer.name"><tt class="xref py py-attr docutils literal"><span class="pre">name</span></tt></a>.</li>
-<li><strong>type</strong> &#8211; See <a class="reference internal" href="#kombu.messaging.Producer.type" title="kombu.messaging.Producer.type"><tt class="xref py py-attr docutils literal"><span class="pre">type</span></tt></a>.</li>
-<li><strong>channel</strong> &#8211; See <a class="reference internal" href="#kombu.messaging.Producer.channel" title="kombu.messaging.Producer.channel"><tt class="xref py py-attr docutils literal"><span class="pre">channel</span></tt></a>.</li>
-<li><strong>durable</strong> &#8211; See <a class="reference internal" href="#kombu.messaging.Producer.durable" title="kombu.messaging.Producer.durable"><tt class="xref py py-attr docutils literal"><span class="pre">durable</span></tt></a>.</li>
-<li><strong>auto_delete</strong> &#8211; See <a class="reference internal" href="#kombu.messaging.Producer.auto_delete" title="kombu.messaging.Producer.auto_delete"><tt class="xref py py-attr docutils literal"><span class="pre">auto_delete</span></tt></a>.</li>
-<li><strong>delivery_mode</strong> &#8211; See <a class="reference internal" href="#kombu.messaging.Producer.delivery_mode" title="kombu.messaging.Producer.delivery_mode"><tt class="xref py py-attr docutils literal"><span class="pre">delivery_mode</span></tt></a>.</li>
-<li><strong>arguments</strong> &#8211; See <a class="reference internal" href="#kombu.messaging.Producer.arguments" title="kombu.messaging.Producer.arguments"><tt class="xref py py-attr docutils literal"><span class="pre">arguments</span></tt></a>.</li>
-</ul>
-</td>
-</tr>
-</tbody>
-</table>
-<dl class="attribute">
-<dt id="kombu.messaging.Producer.name">
-<tt class="descname">name</tt><a class="headerlink" href="#kombu.messaging.Producer.name" title="Permalink to this definition">¶</a></dt>
-<dd><p>Name of the exchange. Default is no name (the default exchange).</p>
-</dd></dl>
-
-<dl class="attribute">
-<dt id="kombu.messaging.Producer.type">
-<tt class="descname">type</tt><a class="headerlink" href="#kombu.messaging.Producer.type" title="Permalink to this definition">¶</a></dt>
-<dd><p>AMQP defines four default exchange types (routing algorithms) that
-covers most of the common messaging use cases. An AMQP broker can
-also define additional exchange types, so see your broker
-manual for more information about available exchange types.</p>
-<blockquote>
-<ul>
-<li><p class="first"><cite>direct</cite> (<em>default</em>)</p>
-<blockquote>
-<p>Direct match between the routing key in the message, and the
-routing criteria used when a queue is bound to this exchange.</p>
-</blockquote>
-</li>
-<li><p class="first"><cite>topic</cite></p>
-<blockquote>
-<p>Wildcard match between the routing key and the routing pattern
-specified in the exchange/queue binding. The routing key is
-treated as zero or more words delimited by <cite>&#8221;.&#8221;</cite> and
-supports special wildcard characters. <cite>&#8220;*&#8221;</cite> matches a
-single word and <cite>&#8220;#&#8221;</cite> matches zero or more words.</p>
-</blockquote>
-</li>
-<li><p class="first"><cite>fanout</cite></p>
-<blockquote>
-<p>Queues are bound to this exchange with no arguments. Hence any
-message sent to this exchange will be forwarded to all queues
-bound to this exchange.</p>
-</blockquote>
-</li>
-<li><p class="first"><cite>headers</cite></p>
-<blockquote>
-<p>Queues are bound to this exchange with a table of arguments
-containing headers and values (optional). A special argument
-named &#8220;x-match&#8221; determines the matching algorithm, where
-<cite>&#8220;all&#8221;</cite> implies an <cite>AND</cite> (all pairs must match) and
-<cite>&#8220;any&#8221;</cite> implies <cite>OR</cite> (at least one pair must match).</p>
-<p><a class="reference internal" href="#kombu.messaging.Producer.arguments" title="kombu.messaging.Producer.arguments"><tt class="xref py py-attr docutils literal"><span class="pre">arguments</span></tt></a> is used to specify the arguments.</p>
-</blockquote>
-</li>
-</ul>
-<p>This description of AMQP exchange types was shamelessly stolen
-from the blog post <a class="reference external" href="http://bit.ly/amqp-exchange-types">AMQP in 10 minutes: Part 4</a> by
-Rajith Attapattu. This article is recommended reading.</p>
-</blockquote>
-</dd></dl>
-
-<dl class="attribute">
-<dt>
-<tt class="descname">channel</tt></dt>
-<dd><p>The channel the exchange is bound to (if bound).</p>
-</dd></dl>
-
-<dl class="attribute">
-<dt id="kombu.messaging.Producer.durable">
-<tt class="descname">durable</tt><a class="headerlink" href="#kombu.messaging.Producer.durable" title="Permalink to this definition">¶</a></dt>
-<dd><p>Durable exchanges remain active when a server restarts. Non-durable
-exchanges (transient exchanges) are purged when a server restarts.
-Default is <tt class="xref py py-const xref docutils literal"><span class="pre">True</span></tt>.</p>
-</dd></dl>
-
-<dl class="attribute">
-<dt id="kombu.messaging.Producer.auto_delete">
-<tt class="descname">auto_delete</tt><a class="headerlink" href="#kombu.messaging.Producer.auto_delete" title="Permalink to this definition">¶</a></dt>
-<dd><p>If set, the exchange is deleted when all queues have finished
-using it. Default is <tt class="xref py py-const xref docutils literal"><span class="pre">False</span></tt>.</p>
-</dd></dl>
-
-<dl class="attribute">
-<dt id="kombu.messaging.Producer.delivery_mode">
-<tt class="descname">delivery_mode</tt><a class="headerlink" href="#kombu.messaging.Producer.delivery_mode" title="Permalink to this definition">¶</a></dt>
-<dd><p>The default delivery mode used for messages. The value is an integer,
-or alias string.</p>
-<blockquote>
-<ul>
-<li><p class="first">1 or <cite>&#8220;transient&#8221;</cite></p>
-<blockquote>
-<p>The message is transient. Which means it is stored in
-memory only, and is lost if the server dies or restarts.</p>
-</blockquote>
-</li>
-<li><dl class="first docutils">
-<dt>2 or &#8220;persistent&#8221; (<em>default</em>)</dt>
-<dd><p class="first last">The message is persistent. Which means the message is
-stored both in-memory, and on disk, and therefore
-preserved if the server dies or restarts.</p>
-</dd>
-</dl>
-</li>
-</ul>
-</blockquote>
-<p>The default value is 2 (persistent).</p>
-</dd></dl>
-
-<dl class="attribute">
-<dt id="kombu.messaging.Producer.arguments">
-<tt class="descname">arguments</tt><a class="headerlink" href="#kombu.messaging.Producer.arguments" title="Permalink to this definition">¶</a></dt>
-<dd><p>Additional arguments to specify when the exchange is declared.</p>
-</dd></dl>
-
+<dd><p>Default exchange.</p>
 </dd></dl>
 
 <dl class="attribute">
@@ -292,7 +169,7 @@ is set to <tt class="xref py py-const xref docutils literal"><span class="pre">T
 <tr class="field"><th class="field-name">Parameters:</th><td class="field-body"><ul class="first last simple">
 <li><strong>body</strong> &#8211; Message body.</li>
 <li><strong>routing_key</strong> &#8211; Message routing key.</li>
-<li><strong>delivery_mode</strong> &#8211; See <a class="reference internal" href="#kombu.messaging.Producer.delivery_mode" title="kombu.messaging.Producer.delivery_mode"><tt class="xref py py-attr docutils literal"><span class="pre">delivery_mode</span></tt></a>.</li>
+<li><strong>delivery_mode</strong> &#8211; See <tt class="xref py py-attr docutils literal"><span class="pre">delivery_mode</span></tt>.</li>
 <li><strong>mandatory</strong> &#8211; Currently not supported.</li>
 <li><strong>immediate</strong> &#8211; Currently not supported.</li>
 <li><strong>priority</strong> &#8211; Message priority. A number between 0 and 9.</li>
diff --git a/reference/kombu.utils.compat.html b/reference/kombu.utils.compat.html
index d6989c3a..86b42726 100644
--- a/reference/kombu.utils.compat.html
+++ b/reference/kombu.utils.compat.html
@@ -104,7 +104,7 @@ and values equal to v (which defaults to None).</p>
 
 <dl class="method">
 <dt id="kombu.utils.compat.CompatOrderedDict.pop">
-<tt class="descname">pop</tt><big>(</big><em>key</em>, <em>default=&lt;object object at 0x102a539b0&gt;</em><big>)</big><a class="headerlink" href="#kombu.utils.compat.CompatOrderedDict.pop" title="Permalink to this definition">¶</a></dt>
+<tt class="descname">pop</tt><big>(</big><em>key</em>, <em>default=&lt;object object at 0x1022308d0&gt;</em><big>)</big><a class="headerlink" href="#kombu.utils.compat.CompatOrderedDict.pop" title="Permalink to this definition">¶</a></dt>
 <dd></dd></dl>
 
 <dl class="method">
diff --git a/searchindex.js b/searchindex.js
index cd847ee6..96f320a9 100644
--- a/searchindex.js
+++ b/searchindex.js
@@ -1 +1 @@
-Search.setIndex({objects:{"kombu.transport.pypika.BlockingConnection":{ensure_drain_events:[28,5,1],channel:[28,5,1]},"kombu.transport.virtual.scheduling.FairCycle":{close:[33,5,1],get:[33,5,1]},"kombu.transport.beanstalk.Transport":{Channel:[31,1,1]},"kombu.connection.ChannelPool":{release:[36,5,1],acquire:[36,5,1],LimitExceeded:[36,2,1]},"kombu.transport.librabbitmq.Transport.Connection.Channel":{Message:[4,1,1],message_to_python:[4,5,1],prepare_message:[4,5,1]},"kombu.simple.SimpleBuffer":{queue_opts:[34,2,1],qsize:[34,5,1],producer:[34,2,1],get:[34,5,1],clear:[34,5,1],get_nowait:[34,5,1],queue:[34,2,1],exchange_opts:[34,2,1],channel:[34,2,1],put:[34,5,1],close:[34,5,1],consumer:[34,2,1],no_ack:[34,2,1],"__len__":[34,5,1]},"kombu.transport.virtual.Channel":{do_restore:[1,2,1],qos:[1,2,1],basic_ack:[1,5,1],basic_reject:[1,5,1],basic_get:[1,5,1],close:[1,5,1],basic_recover:[1,5,1],exchange_declare:[1,5,1],exchange_delete:[1,5,1],queue_bind:[1,5,1],drain_events:[1,5,1],state:[1,2,1],basic_publish:[1,5,1],basic_consume:[1,5,1],queue_delete:[1,5,1],queue_declare:[1,5,1],queue_purge:[1,5,1],basic_qos:[1,5,1],basic_cancel:[1,5,1],message_to_python:[1,5,1],get_table:[1,5,1],exchange_types:[1,2,1],flow:[1,5,1],"typeof":[1,5,1],Message:[1,2,1],prepare_message:[1,5,1]},"kombu.transport.virtual.scheduling":{FairCycle:[33,1,1]},"kombu.pidbox.Mailbox":{Node:[29,5,1],abcast:[29,5,1],get_reply_queue:[29,5,1],exchange:[29,2,1],multi_call:[29,5,1],namespace:[29,2,1],cast:[29,5,1],connection:[29,2,1],call:[29,5,1],get_queue:[29,5,1],reply_exchange:[29,2,1],type:[29,2,1]},"kombu.simple.SimpleQueue":{queue_opts:[34,2,1],qsize:[34,5,1],producer:[34,2,1],get:[34,5,1],clear:[34,5,1],get_nowait:[34,5,1],queue:[34,2,1],exchange_opts:[34,2,1],channel:[34,2,1],put:[34,5,1],close:[34,5,1],consumer:[34,2,1],no_ack:[34,2,1],"__len__":[34,5,1]},"kombu.transport.librabbitmq.Connection.Channel":{exchange_declare:[4,5,1],basic_ack:[4,5,1],queue_bind:[4,5,1],queue_unbind:[4,5,1],basic_qos:[4,5,1],flow:[4,5,1],basic_get:[4,5,1],basic_publish:[4,5,1],basic_consume:[4,5,1],prepare_message:[4,5,1],queue_declare:[4,5,1],basic_cancel:[4,5,1],close:[4,5,1],Message:[4,1,1],queue_purge:[4,5,1],message_to_python:[4,5,1]},"kombu.transport.virtual.exchange.ExchangeType":{equivalent:[18,5,1],lookup:[18,5,1],prepare_bind:[18,5,1]},"kombu.transport.librabbitmq.Connection":{close:[4,2,1],drain_events:[4,5,1],channel:[4,5,1],Channel:[4,1,1]},"kombu.transport.virtual.Message.MessageStateError":{message:[1,2,1],args:[1,2,1]},"kombu.transport":{pyamqplib:[2,0,1],librabbitmq:[4,0,1],mongodb:[3,0,1],resolve_transport:[6,4,1],pyredis:[27,0,1],virtual:[1,0,1],TRANSPORT_ALIASES:[6,3,1],DEFAULT_TRANSPORT:[6,3,1],beanstalk:[31,0,1],base:[21,0,1],pycouchdb:[30,0,1],get_transport_cls:[6,4,1],memory:[11,0,1],pypika:[28,0,1]},"kombu.pidbox":{Node:[29,1,1],Mailbox:[29,1,1]},"kombu.transport.pypika.AsyncoreConnection":{Super:[28,2,1],on_data_available:[28,5,1],ensure_drain_events:[28,5,1],channel:[28,5,1]},"kombu.transport.base.Message":{body:[21,2,1],ack:[21,5,1],delivery_info:[21,2,1],acknowledged:[21,2,1],properties:[21,2,1],decode:[21,5,1],headers:[21,2,1],content_encoding:[21,2,1],content_type:[21,2,1],reject:[21,5,1],delivery_tag:[21,2,1],requeue:[21,5,1],payload:[21,2,1],channel:[21,2,1]},"kombu.compat.Publisher":{close:[35,5,1],send:[35,5,1],revive:[35,5,1],publish:[35,5,1],declare:[35,5,1]},"kombu.connection.ConnectionPool":{release:[36,5,1],acquire:[36,5,1],LimitExceeded:[36,2,1]},"kombu.transport.pyredis.Transport":{Channel:[27,1,1]},"kombu.transport.pyamqplib.Transport":{Connection:[2,1,1],establish_connection:[2,5,1],drain_events:[2,5,1],create_channel:[2,5,1],close_connection:[2,5,1]},"kombu.transport.pycouchdb.Transport.Channel":{client:[30,2,1]},"kombu.connection.BrokerConnection":{SimpleBuffer:[36,5,1],info:[36,5,1],create_transport:[36,5,1],SimpleQueue:[36,5,1],get_transport_cls:[36,5,1],channel_errors:[36,2,1],drain_events:[36,5,1],transport:[36,2,1],host:[36,2,1],ChannelPool:[36,5,1],connection:[36,2,1],connection_errors:[36,2,1],ensure:[36,5,1],Pool:[36,5,1],ensure_connection:[36,5,1],release:[36,5,1],clone:[36,5,1],channel:[36,5,1],connect:[36,5,1]},"kombu.entity":{Queue:[17,1,1],Exchange:[17,1,1]},"kombu.transport.pycouchdb.Transport":{Channel:[30,1,1]},"kombu.transport.pyamqplib":{Transport:[2,1,1],Connection:[2,1,1],Message:[2,1,1],Channel:[2,1,1]},"kombu.utils.finalize.Finalize":{cancel:[22,5,1],still_active:[22,5,1]},"kombu.transport.pypika.Channel":{basic_ack:[28,5,1],basic_get:[28,5,1],basic_publish:[28,5,1],basic_consume:[28,5,1],queue_purge:[28,5,1],Message:[28,1,1],prepare_message:[28,5,1],message_to_python:[28,5,1]},"kombu.transport.pycouchdb.Channel":{client:[30,2,1]},"kombu.serialization":{register:[7,4,1],decode:[7,4,1],SerializerNotInstalled:[7,6,1],encode:[7,4,1],raw_encode:[7,4,1],registry:[7,3,1]},"kombu.transport.mongodb.Transport":{Channel:[3,1,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,5,1],drain_events:[1,5,1],interval:[1,2,1],establish_connection:[1,5,1],close_connection:[1,5,1],state:[1,2,1],create_channel:[1,5,1],default_port:[1,2,1],cycle:[1,2,1],Channel:[1,2,1],Cycle:[1,2,1]},"kombu.compat":{Publisher:[35,1,1],Consumer:[35,1,1],ConsumerSet:[35,1,1]},"kombu.transport.virtual.exchange.FanoutExchange":{lookup:[18,5,1]},"kombu.transport.pypika":{SyncTransport:[28,1,1],AsyncoreConnection:[28,1,1],Message:[28,1,1],AsyncoreTransport:[28,1,1],Channel:[28,1,1],BlockingConnection:[28,1,1]},"kombu.transport.librabbitmq.Connection.Channel.Message":{body:[4,2,1],ack:[4,5,1],MessageStateError:[4,6,1],acknowledged:[4,2,1],delivery_tag:[4,2,1],decode:[4,5,1],reject:[4,5,1],requeue:[4,5,1],payload:[4,2,1],channel:[4,2,1]},"kombu.transport.mongodb.Transport.Channel":{close:[3,5,1],client:[3,2,1]},"kombu.transport.memory.Transport":{state:[11,2,1],Channel:[11,1,1]},"kombu.messaging.Producer":{arguments:[20,2,1],revive:[20,5,1],name:[20,2,1],exchange:[20,2,1],serializer:[20,2,1],auto_delete:[20,2,1],delivery_mode:[20,2,1],on_return:[20,2,1],publish:[20,5,1],routing_key:[20,2,1],auto_declare:[20,2,1],declare:[20,5,1],type:[20,2,1],durable:[20,2,1],channel:[20,2,1],compression:[20,2,1]},"kombu.transport.pyamqplib.Connection":{drain_events:[2,5,1],wait_multi:[2,5,1],read_timeout:[2,5,1],close:[2,5,1],channel:[2,5,1],wait:[2,5,1]},"kombu.transport.virtual.QoS":{ack:[1,5,1],restore_unacked:[1,5,1],restore_unacked_once:[1,5,1],prefetch_count:[1,2,1],can_consume:[1,5,1],reject:[1,5,1],append:[1,5,1]},"kombu.transport.pyredis":{Channel:[27,1,1],Transport:[27,1,1]},"kombu.transport.virtual.Message":{ack:[1,5,1],MessageStateError:[1,6,1],acknowledged:[1,2,1],serializable:[1,5,1],decode:[1,5,1],reject:[1,5,1],requeue:[1,5,1],payload:[1,2,1]},"kombu.abstract.MaybeChannelBound":{is_bound:[16,2,1],when_bound:[16,5,1],bind:[16,5,1],revive:[16,5,1],maybe_bind:[16,5,1],channel:[16,2,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:[11,1,1],Channel:[11,1,1]},"kombu.utils.finalize":{Finalize:[22,1,1]},"kombu.transport.beanstalk":{Transport:[31,1,1],Channel:[31,1,1]},"kombu.pidbox.Node":{handle:[29,5,1],handlers:[29,2,1],dispatch_from_message:[29,5,1],hostname:[29,2,1],state:[29,2,1],dispatch:[29,5,1],mailbox:[29,2,1],handle_call:[29,5,1],handler:[29,5,1],handle_cast:[29,5,1],handle_message:[29,5,1],reply:[29,5,1],Consumer:[29,5,1],channel:[29,2,1],listen:[29,5,1]},"kombu.transport.base.Transport":{close_channel:[21,5,1],channel_errors:[21,2,1],drain_events:[21,5,1],establish_connection:[21,5,1],client:[21,2,1],connection_errors:[21,2,1],create_channel:[21,5,1],default_port:[21,2,1],close_connection:[21,5,1]},"kombu.transport.librabbitmq.Channel":{Message:[4,1,1],message_to_python:[4,5,1],prepare_message:[4,5,1]},"kombu.transport.pypika.SyncTransport":{drain_events:[28,5,1],establish_connection:[28,5,1],Connection:[28,2,1],create_channel:[28,5,1],Message:[28,1,1],close_connection:[28,5,1]},"kombu.transport.pycouchdb":{create_message_view:[30,4,1],Channel:[30,1,1],Transport:[30,1,1]},"kombu.transport.pyamqplib.Channel.Message":{body:[2,2,1],delivery_tag:[2,2,1],channel:[2,2,1]},"kombu.transport.virtual.exchange.TopicExchange":{wildcards:[18,2,1],lookup:[18,5,1],prepare_bind:[18,5,1],key_to_pattern:[18,5,1]},"kombu.messaging.Consumer":{qos:[20,5,1],consume:[20,5,1],register_callback:[20,5,1],callbacks:[20,2,1],receive:[20,5,1],queues:[20,2,1],cancel_by_queue:[20,5,1],flow:[20,5,1],revive:[20,5,1],declare:[20,5,1],purge:[20,5,1],cancel:[20,5,1],auto_declare:[20,2,1],on_decode_error:[20,2,1],recover:[20,5,1],no_ack:[20,2,1],channel:[20,2,1]},"kombu.transport.mongodb.Channel":{close:[3,5,1],client:[3,2,1]},"kombu.transport.pyamqplib.Channel":{Message:[2,1,1],message_to_python:[2,5,1],prepare_message:[2,5,1]},"kombu.utils.compat.CompatOrderedDict":{fromkeys:[8,7,1],setdefault:[8,5,1],keys:[8,5,1],items:[8,5,1],clear:[8,5,1],popitem:[8,5,1],update:[8,5,1],pop:[8,5,1],values:[8,5,1],itervalues:[8,5,1],iteritems:[8,5,1],copy:[8,5,1],iterkeys:[8,5,1]},"kombu.transport.virtual.BrokerState":{bindings:[1,2,1],exchanges:[1,2,1]},"kombu.transport.librabbitmq.Transport":{drain_events:[4,5,1],establish_connection:[4,5,1],Connection:[4,1,1],create_channel:[4,5,1],close_connection:[4,5,1]},"kombu.connection":{ChannelPool:[36,1,1],ConnectionPool:[36,1,1],BrokerConnection:[36,1,1]},"kombu.transport.virtual.exchange.DirectExchange":{lookup:[18,5,1]},"kombu.transport.librabbitmq.Connection.Channel.Message.MessageStateError":{message:[4,2,1],args:[4,2,1]},"kombu.transport.librabbitmq.Message":{body:[4,2,1],delivery_tag:[4,2,1],channel:[4,2,1]},"kombu.compat.ConsumerSet":{add_consumer_from_dict:[35,5,1],iterconsume:[35,5,1],add_consumer:[35,5,1],consume:[35,5,1],register_callback:[35,5,1],receive:[35,5,1],flow:[35,5,1],revive:[35,5,1],cancel_by_queue:[35,5,1],purge:[35,5,1],discard_all:[35,5,1],cancel:[35,5,1],close:[35,5,1],recover:[35,5,1],declare:[35,5,1],qos:[35,5,1]},"kombu.transport.librabbitmq.Transport.Connection.Channel.Message":{body:[4,2,1],delivery_tag:[4,2,1],channel:[4,2,1]},"kombu.transport.beanstalk.Transport.Channel":{close:[31,5,1],client:[31,2,1]},"kombu.entity.Queue":{exclusive:[17,2,1],unbind:[17,5,1],when_bound:[17,5,1],consume:[17,5,1],name:[17,2,1],get:[17,5,1],auto_delete:[17,2,1],durable:[17,2,1],routing_key:[17,2,1],purge:[17,5,1],queue_bind:[17,5,1],queue_arguments:[17,2,1],maybe_bind:[17,5,1],channel:[17,2,1],binding_arguments:[17,2,1],cancel:[17,5,1],queue_declare:[17,5,1],declare:[17,5,1],exchange:[17,2,1],"delete":[17,5,1]},"kombu.transport.pypika.AsyncoreTransport":{Connection:[28,2,1]},"kombu.transport.librabbitmq.Transport.Connection":{Channel:[4,1,1]},"kombu.transport.pyredis.Transport.Channel":{client:[27,2,1],get_table:[27,5,1],subclient:[27,2,1],basic_cancel:[27,5,1],basic_consume:[27,5,1],active_queues:[27,2,1],close:[27,5,1]},"kombu.entity.Exchange":{name:[17,2,1],auto_delete:[17,2,1],delivery_mode:[17,2,1],publish:[17,5,1],declare:[17,5,1],maybe_bind:[17,5,1],arguments:[17,2,1],Message:[17,5,1],type:[17,2,1],durable:[17,2,1],channel:[17,2,1],"delete":[17,5,1]},"kombu.transport.beanstalk.Channel":{close:[31,5,1],client:[31,2,1]},"kombu.transport.librabbitmq":{Message:[4,1,1],Channel:[4,1,1],Connection:[4,1,1],Transport:[4,1,1]},"kombu.abstract":{MaybeChannelBound:[16,1,1]},"kombu.simple":{SimpleBuffer:[34,1,1],SimpleQueue:[34,1,1]},"kombu.transport.virtual.exchange":{DirectExchange:[18,1,1],ExchangeType:[18,1,1],FanoutExchange:[18,1,1],TopicExchange:[18,1,1]},"kombu.compression":{encoders:[25,4,1],get_encoder:[25,4,1],register:[25,4,1],compress:[25,4,1],decompress:[25,4,1],get_decoder:[25,4,1]},kombu:{compat:[35,0,1],compression:[25,0,1],simple:[34,0,1],"abstract":[16,0,1],syn:[5,0,1],entity:[17,0,1],exceptions:[0,0,1],connection:[36,0,1],messaging:[20,0,1],pidbox:[29,0,1],serialization:[7,0,1],utils:[26,0,1],transport:[6,0,1]},"kombu.transport.pyamqplib.Transport.Connection":{read_timeout:[2,5,1],drain_events:[2,5,1],wait_multi:[2,5,1],channel:[2,5,1]},"kombu.transport.virtual":{QoS:[1,1,1],exchange:[18,0,1],BrokerState:[1,1,1],Transport:[1,1,1],scheduling:[33,0,1],AbstractChannel:[1,1,1],Message:[1,1,1],Channel:[1,1,1]},"kombu.syn":{select_blocking_method:[5,4,1],detect_sync_method:[5,4,1],blocking:[5,4,1]},"kombu.transport.mongodb":{Channel:[3,1,1],Transport:[3,1,1]},"kombu.compat.Consumer":{iterconsume:[35,5,1],qos:[35,5,1],process_next:[35,5,1],register_callback:[35,5,1],receive:[35,5,1],consume:[35,5,1],flow:[35,5,1],cancel_by_queue:[35,5,1],revive:[35,5,1],purge:[35,5,1],discard_all:[35,5,1],fetch:[35,5,1],cancel:[35,5,1],close:[35,5,1],iterqueue:[35,5,1],recover:[35,5,1],declare:[35,5,1],wait:[35,5,1]},"kombu.utils":{compat:[8,0,1],kwdict:[26,4,1],cached_property:[26,2,1],finalize:[22,0,1],partition:[26,4,1],functional:[9,0,1],rpartition:[26,4,1],emergency_dump_state:[26,4,1],uuid4:[26,4,1],fxrange:[26,4,1],gen_unique_id:[26,4,1],retry_over_time:[26,4,1],say:[26,4,1],maybe_list:[26,4,1]},"kombu.transport.librabbitmq.Channel.Message":{body:[4,2,1],delivery_tag:[4,2,1],channel:[4,2,1]},"kombu.transport.pyredis.Channel":{client:[27,2,1],active_queues:[27,2,1],subclient:[27,2,1],basic_cancel:[27,5,1],basic_consume:[27,5,1],get_table:[27,5,1],close:[27,5,1]},"kombu.messaging":{Consumer:[20,1,1],Producer:[20,1,1]},"kombu.utils.compat":{CompatOrderedDict:[8,1,1]},"kombu.transport.base":{Message:[21,1,1],Transport:[21,1,1]}},terms:{fanoutexchang:18,represent:20,pluggabl:12,concept:12,get_reply_queu:29,consum:[19,20,29,12,1,33,13,34,15,17,35],all:[20,12,1,2,13,17,35,18,8],interchang:19,four:[12,20,17],uncknowledg:1,code:2,sleep:[26,36],per:13,abil:12,follow:[12,20,35,13],disk:[20,17],request:[35,20,36,2,7],content:[10,21,7,13,20,35],typeerror:26,depend:[0,12,36,14,17],decim:13,specif:[20,2,14,17,35,36,18],send:[19,20,29,7,12,2,13,24,14,17,35],articl:[12,20,17],dispatch_from_messag:29,init:29,program:13,under:12,sens:17,imedi:20,brokerst:1,sent:[20,21,12,1,13,4,17,35],suitabl:7,passiv:[1,4,17],mpg:19,sourc:12,everi:[12,26,13],solem:[0,20,21,11,1,2,33,25,27,28,34,16,4,6,17,35,29,18,36],fals:[20,1,28,26,4,17,35,36,8],unacknowledg:[35,1,20],util:[9,10,22,33,25,15,16,5,26,7,8],ident:[12,17],fan:12,fall:[35,20],drain_ev:[29,21,12,1,2,28,4,36],affect:[12,20,35],ticket:29,exact:18,abcast:29,iterconsum:35,level:[12,19],exchange_opt:[34,36],messagestateerror:[0,1,21,4],list:[7,20,12,23,13,25,14,36],nasdaq:[12,17],rabbitmq:[12,20,23,35,17],"try":[0,20,26,29],item:[7,36,8],pypika:[10,28,15],default_port:[1,21],quick:12,refer:[14,10,13,15],prepar:[1,26],localhost:[12,14,36,4,19],pleas:12,impli:[20,17],when_bound:[16,17],slower:13,maybe_list:26,still_act:22,sync:12,"_queue_bind":18,zero:[12,20,35,17],video:[12,19],pass:[29,20,7,13,26,35,36],download:12,port:[21,12,1,14,4,36],append:1,compat:[9,10,12,13,15,35,8],index:[12,10],dialogu:17,establish_connect:[4,1,21,2,28],sub:12,eventlet:5,repli:[29,2,17],connection_error:[21,36],brief:23,current:[19,20,1,29,34,16,5,17,35,36],delet:[20,12,1,2,26,17,35,36],version:[12,26],key_to_pattern:18,encourag:12,"new":[7,20,12,1,25,17,35,36,8],ever:17,method:[0,20,21,7,1,2,13,25,14,4,5,17,35,29,18,36],requeu:[20,21,1,23,4,35],transport_alias:6,full:[12,14,6],hash:[12,17],timeouterror:0,iteritem:8,gener:[29,26,17],never:36,onli:[19,7,20,12,1,17],len:34,bodi:[29,20,21,7,1,2,25,4,17,35],base64:13,pub:12,address:36,path:[36,6],along:[35,20],ensure_connect:36,modifi:17,sinc:13,valu:[20,1,2,26,4,17,8],wait:[20,12,2,5,17,35,36],search:10,produc:[19,20,12,13,34,15,35,36],sender:2,configuar:12,host:[14,36,4],delivery_tag:[4,1,21,2,28],queue:[19,20,21,12,1,27,28,34,15,4,17,35,36,18],datetim:19,base:[7,21,10,1,15,18],within:[35,20],action:[26,17],implement:[12,1,23,18],chanc:[1,26,33],control:[35,20],semant:36,via:12,regardless:36,primit:[12,17],modul:[10,36,13],put:[19,1,21,4,34],beanstalk:[12,10,31,15],api:[1,15,10],celerybeat:29,basic_qo:[1,4],instal:[12,10,7],redi:[32,12,27,14,36,18],simultaen:[0,36],establish:[2,28,14,16,4,36],unit:12,highli:12,regex:18,usd:[12,17],from:[19,20,21,22,12,1,2,33,14,4,17,35,34,36,8],describ:[7,17],limitexceed:[0,36],memori:[10,11,20,12,1,14,15,17,36],method_sig:2,regist:[35,20,25,13,7],two:[19,20,12,26,17,35],next:26,overflow:[35,20],handler:[29,28],call:[0,19,20,12,29,14,16,5,17,35,36],recommend:[20,36,17],taken:22,scope:1,prev:18,type:[29,20,21,7,12,1,33,13,25,4,5,17,35,18],until:[35,20,26,36,17],science_new:17,more:[0,1,2,3,4,6,11,12,13,14,16,17,18,20,21,7,25,28,27,29,30,31,33,34,35,36],prefetch_s:[35,1,20],desir:13,faircycl:[1,33],detail:[0,1,2,3,4,6,11,12,16,17,18,20,21,7,25,28,27,29,30,31,33,34,35,36],afer:16,simplebuff:[19,34,36],warn:[35,20,36],flag:[34,1,16,20,17],"transient":[19,20,36,17],accept:[35,20],rabbit:[12,36],aris:19,unseri:7,obj:[36,22],hold:17,arg:[22,1,2,26,27,16,4,5,35,8],cach:26,content_typ:[20,21,7,1,2,13,25,4,17,35,28],must:[20,21,12,1,2,26,4,17,35,36],annoy:12,high:12,none:[19,20,21,22,1,2,29,28,34,26,4,6,17,35,36,7,8],join:12,active_queu:27,restor:1,alia:[20,28,25,6,17],setup:12,work:[23,13,32],uniqu:[4,26,2,17],histori:[10,32],default_transport:6,descriptor:26,remain:[20,17],tag:[4,1,21,2,17],del:26,can:[19,20,21,7,12,1,2,13,14,16,17,35,36,26],pidbox:[29,10,15],root:12,fetch:35,def:[19,29,26,36],overrid:[35,20],close_channel:[1,21],stream:7,give:[35,20,26,36],process:[19,20,21,12,1,13,4,35,29],autodetect:[35,20],share:[36,18],dump_entri:19,indic:[10,2],topic:[12,15,18,20,17],carrot:[12,35,13,32],exchange_delet:1,want:[7,20,1,2,13,14],tarbal:12,serial:[19,10,21,20,12,13,24,34,15,17,35,7],occur:[20,36,7,17],string:[20,7,13,6,17,36],alwai:[12,36,17],end:[35,20],secur:12,rather:[35,1,20],anoth:36,interval_step:[26,36],how:[26,36],need:[19,20,12,13,14,35,36,18],purg:[35,20,17],"__init__":19,reject:[1,21,4,23],answer:23,instead:[19,1,21],reviv:[35,20,16],simpl:[19,10,20,24,34,15,35],connect_timeout:36,convers:18,stock:[12,17],map:[29,20,1,6,35,18],create_message_view:30,resourc:[1,36,2,33],create_channel:[4,1,21,2,28],librabbitmq:[10,4,15],max:26,clone:36,after:[20,2],befor:[12,26,36],wait_multi:2,reply_exchang:29,date:[19,15,32,13,24],multipl:[36,4],data:[19,7,29,1,2,13,24,15,4,6],handl:[12,20,2,29],github:12,attempt:[35,20],nativ:[12,13],encapsul:[4,2],bind:[20,12,1,16,17,35,18],stdin:36,"0x102a539b0":8,correspond:[1,18],django:12,issu:[12,2],inform:[14,20,21,17],maintain:13,environ:5,allow:12,media:12,exclus:[35,4,17],mechan:[35,20],order:[20,8],queue_delet:1,add_consumer_from_dict:35,method_id:2,help:[12,10],media_exchang:12,queue_opt:[34,36],failur:[21,2],becaus:17,jpeg:13,handle_cal:29,image_queu:12,held:[35,20],own:[14,21,17],reconnect:2,undeliver:20,brokerconnect:[19,29,21,12,1,14,36],still:[35,20],paramet:[7,20,1,2,25,28,26,17,35,36,18],prepare_bind:18,fit:13,itervalu:8,amqplib:[12,14,36,2],fix:[12,26],clymer:30,defin:[19,20,12,1,2,17,18],better:13,yaml:[7,13],window:[35,20],restart:[20,17],persist:[19,20,34,15,17,36],mail:[12,23],therefor:[20,17],consumerset:[35,15],select_blocking_method:5,epol:32,eur:[12,17],non:[12,1,20,17],good:13,synopsi:[12,10],thei:[12,19,13,17],reveal:23,python:[9,10,21,19,7,12,1,2,13,26,4,35],auto:[36,13,17],initi:[1,32],easy_instal:12,framework:[12,10],automat:[12,20,36,35],amqp_messag:28,restore_unacked_onc:1,now:[26,32,13,17],discuss:23,introduct:[12,15,29],choic:13,term:[35,20],name:[19,7,29,20,12,25,34,6,17,35,36],event:[12,1,36,2],userid:[14,19,36,4],restore_unack:1,video_queu:12,separ:[12,36,18,17],easili:12,localis:2,reactiv:[35,20],mode:[20,17],timeout:[19,29,12,1,2,28,34,4,36],each:[1,33,13,26,17,36],januari:[15,23,24],unicod:[7,26,13],updat:8,side:2,mean:[20,21,1,2,14,4,17,35],domain:[12,17],redeliv:[35,20],replac:35,kombu:[0,1,2,3,4,5,6,7,8,9,10,11,12,14,15,16,17,18,19,20,21,22,25,28,26,27,29,30,31,33,34,35,36],discard_al:35,realli:12,connect:[0,1,2,3,4,10,11,12,14,15,16,17,19,20,21,31,24,28,26,29,30,35,36],channelpool:36,our:[12,2,17],happen:[12,19,21],errror:12,orient:12,special:[12,20,7,17],out:[0,1,12],msgpack:[7,13],unbound:[0,12,17],asyncoreconnect:28,goe:1,open:[12,36,26,13],publish:[20,21,12,1,13,34,15,4,17,35,36],payload:[12,1,21,4,19],max_retri:[26,36],cest:32,sever:[12,14],print:[19,26,36],gen_unique_id:26,sphinx:12,qualifi:6,directexchang:18,insid:13,advanc:[12,20,35],bound_sicence_new:17,undo:[35,20],standard:[12,19,18,13],small:26,reason:[12,23],orm:12,mime:[7,25],dictionari:[7,8,13],ask:[0,1,2,27,4,6,10,11,12,16,17,18,20,21,23,25,28,29,33,34,35,36],org:[35,26],close_connect:[4,1,21,2,28],decompress:25,basi:13,pyyaml:7,perform:[12,20,35,17],couldn:36,thread:36,forc:[36,2],delivery_info:21,traceback:36,synchron:[1,17],fromtimestamp:19,if_unus:[1,17],david:[30,31],connectionlimitexceed:[0,36],channel_error:[21,36],prefetch:[35,1,20],reply_cod:2,log_messag:19,global:[35,20,11],licens:[0,1,2,3,4,6,10,11,12,16,17,18,20,21,7,25,28,27,29,30,31,33,34,35,36],frequent:[10,23],oper:[0,20,12,17,35,36],softwar:12,create_transport:36,mixin:16,do_restor:1,exchange_declar:[1,4],exchang:[19,10,29,20,12,1,13,27,28,34,15,4,17,35,36,18],qualiti:[35,1,20,15],number:[0,20,1,14,26,35,36],basic_get:[1,4,28],ziegler:31,mai:[20,21,2,13,14,17,35,36],instruct:13,alreadi:[0,20,21,12,1,16,4,17,35],done:[35,1,36,20,17],messag:[0,1,2,4,10,12,13,14,15,17,18,19,20,21,23,24,28,29,7,34,35,36],blank:17,miss:13,primari:13,retry_over_tim:26,size:[12,20,35],prioriti:[20,1,2,28,4,17,35],is_bound:16,differ:[14,19],"long":[26,17],smaller:[35,20,13],guest:[12,14,36,4,19],queue_bind:[1,4,17],associ:[2,25,17],top:12,slept:36,least:[20,17],necessarili:17,monkei:5,interfac:[19,10,21,12,24,34,15,35,36,18],scheme:[12,13,17],routing_kei:[29,20,12,1,13,28,34,4,17,35,36,18],store:[20,26,18,17],listen:29,premoli:3,option:[29,20,7,13,34,17,35,36],auto_delet:[20,1,4,17,35,18],namespac:29,shallow:8,message_data:[1,2,28],specifi:[19,20,21,7,1,13,14,6,17,35,36],direct:[29,20,12,1,15,4,17,18],broadcast:[29,18],forward:[20,17],"short":2,word:[12,20,18,17],handle_cast:29,basic_publish:[1,4,28],than:[12,20,35,13,17],conveni:7,keyword:[20,26,36],provid:[12,26,2,36,17],remov:[19,21,1,4,17,8],connectionpool:36,uuid4:26,structur:[1,21,4,13,7],charact:[12,20,18,7,17],project:12,classmethod:8,info:[19,29,36],str:[20,7],were:17,posit:26,design:17,minut:[20,17],no_ack:[20,1,28,34,4,17,35,36],transport:[30,21,11,10,12,1,2,33,24,3,28,14,15,4,31,27,6,36,18],deliveri:[4,20,21,2,17],sai:26,counter:2,kwdict:26,enable_callback:35,adher:1,modern:13,ani:[20,12,2,13,17,35,36,18],latter:[19,7],packag:[12,7,35],pip:12,binding_argu:17,have:[19,20,12,13,14,26,17,35,36],"__main__":19,notbounderror:[0,12],notimplementederror:[35,1,20],exclud:18,caus:[2,13],built:[12,26,13,6,17],equival:[19,18],callback:[19,20,29,22,1,26,28,16,4,17,35,36],rout:[19,20,12,1,17,35,36,18],ack:[19,1,21,4],note:[35,20,7,13,17],rpartit:26,without:[14,13,24,17],get_tabl:[1,18,27],take:[20,26],which:[19,20,2,13,14,17,35,8],fifo:8,text:[12,21,2,25],channel:[0,1,2,3,4,11,12,13,15,16,17,18,19,20,21,31,28,27,29,30,34,35,36],even:[12,14,7,5,17],copi:[36,16,18,8],unless:7,distribut:12,onf:5,buffer:[19,15,36,34],object:[19,20,22,13,16,17,36,7,8],compress:[19,10,20,12,25,34,15,16,35],most:[12,20,36,17],regular:12,bsd:[0,1,2,3,4,6,11,12,16,17,18,20,21,7,25,28,27,29,30,31,33,34,35,36],process_media:12,why:23,lazili:36,don:[12,13],exc:[20,26,36],clear:[34,8],cover:[20,17],doe:[12,20,35,6,17],deliv:[35,20,18,17],part:[1,13,20,17],determin:[20,17],pattern:[12,20,17],latest:12,dot:[12,18,17],recipi:[35,20],serializ:1,multi_cal:29,particip:12,consult:6,speedup:13,directli:1,protocol:[12,18],resolve_transport:6,find:[35,20],setter:26,access:[1,17],fxrang:26,explicitli:[14,17],acquir:36,copyright:[0,1,2,3,4,6,11,16,17,18,20,21,7,25,28,27,29,30,31,33,34,35,36],"true":[19,20,21,12,1,2,29,28,34,4,17,35,36,18,8],transact:1,configur:[12,36],releas:[15,36,24,32],forev:[26,36],should:[12,20,26,35,7],recov:[35,1,20],local:[35,20,17],over:[26,13],pika:[12,14,36,28],iterkei:8,contribut:[12,10],get:[19,10,12,1,33,25,34,26,6,17,36,18],beat:29,familiar:12,express:13,stop:[35,20,26],synctransport:28,ssl:36,cannot:2,postencod:21,popitem:8,report:12,pipermail:23,get_queu:29,requir:[19,18],bound_science_new:17,auto_declar:[35,20],enabl:[20,1,34,4,35,36],patch:[12,5],rfc:2,channel_id:[4,2],common:[12,20,17],partit:26,contain:[1,7,20,17],asyncoretransport:28,where:[20,1,33,26,5,17],attapattu:[20,17],respond:[2,17],set:[26,20,21,7,1,33,13,14,16,4,17,35,36,18],basic_ack:[1,4,28],allowed_method:2,sep:26,basic_reject:1,around:13,get_decod:25,see:[0,1,2,3,4,6,11,12,14,16,17,18,20,21,7,23,25,28,26,27,29,30,31,33,34,35,36],fanout:[29,20,12,15,17,18],mandatori:[35,20,28,4,17],result:[36,5],respons:[36,17],fail:2,close:[19,31,1,2,33,3,28,34,4,27,17,35,36],serializernotinstal:7,best:13,onc:1,infinit:35,can_consum:1,detect:[2,5,13],correctli:2,hopefulli:26,down:[35,20,2],databas:14,someth:19,wikipedia:12,veri:26,unack:1,state:[29,11,1,15,26,17,18],won:17,pyredi:[10,27,15],prefetch_count:[35,1,20],between:[20,1,26,17,35,36],register_callback:[12,20,35],"import":[12,14,19,17],entiti:[0,10,17,20,15],across:12,attribut:[12,36,18,13,17],altern:[35,20,13],signatur:[35,20],auto_decod:2,nowait:[1,28,4,17],pylibrabbitmq:4,kei:[19,20,12,1,17,35,36,18,8],default_seri:7,xrang:19,mailbox:[29,15],pypi:[12,35],cycl:[1,13],prepare_messag:[4,1,2,28],wait_for_open:28,here:19,come:19,uuid:26,both:[12,19,20,17],last:[36,8,17],execed:36,supports_fanout:18,howev:13,equal:[35,1,33,8,20],connection_info:29,etc:[12,13],shortstr:2,instanc:[26,20,21,1,2,13,16,4,17,35,36],context:[19,29,2],improv:[35,20],iterqueu:35,com:[12,36,23],simplequeu:[19,34,36],load:36,simpli:12,kwd:8,cancer:17,point:1,instanti:[35,20,36],schedul:[10,33,15],pop:8,header:[20,21,1,2,13,28,34,4,17,35,18],colon:36,shortcut:[19,36],shutdown:1,linux:32,cancel:[29,20,22,1,17,35],guid:[10,24],assum:17,backend:[18,11],second:[26,36],would:7,due:[21,2],been:[0,20,21,12,1,4,35,36],json:[12,19,7,13,20],much:26,interpret:[12,17],subscrib:[35,20],raw_encod:7,emul:1,addit:[19,20,21,34,26,17,36],"__len__":34,field:[14,17],if_empti:[1,17],lifo:8,imag:[12,13],appli:[35,20,36],convert:[4,1,2],argument:[19,20,1,29,14,26,4,17,35,36,18],proven:12,predic:33,"catch":26,former:19,queue_nam:19,"case":[20,7,13,17],exchange_typ:[35,1],stolen:[20,17],queue_argu:17,process_next:35,raw:[7,21,1,13,24,17],plain:13,servic:[35,1,20,15],properti:[21,12,1,2,28,26,4,17],kwarg:[29,30,21,11,22,1,2,33,26,3,28,34,16,4,31,5,17,35,27,36],aim:12,cast:29,"while":[12,19,26,29,20],suport:36,"typeof":1,abov:[19,13],error:[19,21,2,36,17],fun:[29,36,26,33,5],aid:2,loop:36,layer:12,larger:13,advantag:13,readi:[35,1,20],tabl:[20,10,1,6,17,18],henc:[20,17],them:[12,19,17],jpg:13,destin:[29,17],origin:[20,21,12,1,4,35],"default":[20,21,7,12,1,2,13,14,5,6,17,35,36,18,8],itself:[35,20],avi:12,apply_glob:[35,1,20],"return":[29,20,21,7,1,13,25,26,4,17,18,8],descript:[20,17],ascii:7,conn:36,scienc:17,issue4978:26,weakref:22,disabl:[34,1,36,35,20],develop:12,welcom:12,author:12,receiv:[19,20,21,12,2,24,14,4,17,35,34],suggest:12,make:[12,19,26,5,17],couchdb:[12,30],cross:13,same:[19,20,12,13,14,17,36],binari:[7,13,17],html:23,decod:[20,21,7,1,13,25,15,4,35],timestamp:19,algorithm:[12,20,17],document:[12,10,14,35],complet:36,finish:[35,20,17],http:[12,35,26,23],hostnam:[14,19,36,29],message_to_python:[4,1,2,28],syn:[10,5,15],solut:12,fairli:[1,13],rais:[20,21,7,12,1,26,4,17,35,36],user:[12,10,19,24],mani:[36,13],bound_exchang:[12,17],recent:36,fromkei:8,drain:1,kept:12,cjson:13,whole:[35,20],reload_schedul:29,inherit:1,cutekitten:19,pickl:[12,7,13],client:[29,30,21,11,20,12,1,2,3,28,4,31,27,17,35,36],command:29,thi:[19,20,21,7,12,1,2,25,14,26,4,17,35,29,18,36],choos:14,queue_purg:[1,4,28],cure:17,self:[19,7,26,36,34],usual:[29,1,36,7],identifi:[4,21,2,25,17],entri:19,just:17,when:[19,20,21,12,1,2,13,14,16,6,17,35,36,26],on_return:20,activ:[35,1,36,20,17],percoco:3,on_data_avail:28,simultan:[0,36],yet:[14,23],languag:13,warren:12,task:12,password:[14,19,36,4],emergency_dump_st:26,easi:12,also:[20,12,13,14,17,35,36],consumer_tag:[1,28,4,27,17],raw_messag:[4,1,2,28],except:[0,10,20,12,1,2,33,13,15,26,4,36,7],param:20,blog:[20,17],add:12,other:[20,2,13,14,35,8],noack:4,overview:[12,15,7],logger:19,match:[12,18,2,20,17],build:12,applic:[12,7,21,29,17],pyamqplib:[10,36,2,6,15],maybechannelbound:16,loss:20,preserv:[20,17],multiprocess:22,lolcat1:12,alias:[36,25,6],dispatch:[29,20,2,35],"final":[29,10,15,22],amq:[18,1,2],bit:13,characterist:13,recurs:13,insert:8,like:[12,19,13,17],lost:[20,17],arbitrari:[35,20],rajith:[20,17],manual:[12,20,17],resolv:2,integ:[20,17],server:[20,21,12,1,2,4,17,35,36],basic_recov:1,from_dict:35,"boolean":13,singl:[19,20,26,17,36,18],if_unusu:1,popular:12,async:[12,10,29,5,15],nice:20,page:10,provok:2,underli:36,node:[29,15],exceed:[0,26,36],cancel_by_queu:[35,20],acknowledg:[0,20,21,1,34,4,17,36],interv:[1,26,36],some:[12,13],back:[4,1,21,2],abstractchannel:1,on_decode_error:20,intern:2,sure:[26,5],read:[12,20,13,17],guarante:1,basic_cancel:[1,4,27],log_queu:19,librari:[19,13,17],registri:[15,25,7],tmp:12,poll:[1,17],collect:1,"function":[9,30,10,25,15,26,5,6,17,36],avoid:[35,20],get_nowait:34,octet:[35,20],subclass:[35,1,20],usernam:[14,36],retri:[26,36],leav:17,select:[1,21,4,5],condit:2,notabl:13,blockingconnect:28,either:[12,26,17],preload:36,ensure_drain_ev:28,idiomat:12,uncompress:25,reach:26,usag:36,broker:[20,1,2,28,4,17,35,36],step:26,maybe_bind:[16,17],although:[35,20,17],found:17,peer:[35,20,2],"__name__":19,post:[20,17],"super":28,pycouchdb:[30,15,10],binding_kei:4,comparison:[12,10],about:[12,20,23,17],central:7,socket:[19,36],constraint:13,class_id:2,slightli:19,delivery_mod:[35,20,17],unnecessari:7,exampl:[19,7,12,29,14,26,17,36,18],includ:[13,6],disadvantag:13,constructor:[29,1,36],discard:[4,1,21,2,36],errback:[26,36],marshal:7,block:[19,34,36,5],topicexchang:18,qsize:34,detect_sync_method:5,reconnection_strategi:28,"float":13,encod:[19,20,21,7,12,2,13,25,15,4,17,35],bound:[29,20,12,16,17,18],terminolog:[12,10],three:7,interval_max:[26,36],pair:[20,36,8,17],read_timeout:2,empti:17,ensur:[12,1,16,36],chang:[1,32,10],exchangetyp:18,your:[12,14,13,20,17],durabl:[20,12,1,4,17,35,36,18],manag:1,rkei:[18,13],log:[19,2],wai:36,compatordereddict:8,transfer:13,support:[20,7,12,1,13,14,17,35,18],question:[10,23],iter:8,fast:13,custom:[12,13,17],avail:[20,7,12,25,17,35,36],start:[12,26,36,17],setdefault:8,no_loc:4,tracker:[12,10],myqueu:19,slight:13,treat:[20,17],fork:32,properli:17,simplejson:13,channellimitexceed:[0,36],tupl:[7,21,18,26],basic:[19,20],unbind:17,msg:2,sqlalchemi:12,gain:13,newer:26,queue_declar:[1,4,17],shamelessli:[20,17],line:36,buf:28,bug:[12,10,26],dump:26,count:1,reappli:36,immedi:[20,28,4,17,35,36],utf:7,attr:26,consist:[12,17],possibl:[12,7],whether:17,caller:36,maximum:[0,26,36],tell:36,gevent:5,limit:[0,29,20,1,13,35,36],virtual_host:[14,19,36,4],insist:36,basic_consum:[1,4,27,28],otherwis:[35,20,17],problem:12,delimit:[20,17],repeatlast:26,featur:[12,10],add_consum:35,creat:[19,29,14,16,17,36],flow:[35,1,4,20],"abstract":[1,16],filenam:19,doesn:23,repres:7,criteria:[20,17],exist:[12,17],file:[12,36,13],shut:2,check:17,probabl:13,again:[26,36],wast:13,amqp:[19,10,20,12,2,28,14,16,4,17,7],content_encod:[20,21,7,1,2,13,28,4,17,35],handle_messag:29,excel:19,exitprior:22,virtual:[10,12,1,33,14,15,36,18],flavio:3,vendor:12,my_pictur:13,subclient:27,declar:[20,12,1,34,17,35],lookup:18,get_encod:25,rememb:[36,8],test:12,you:[19,20,21,7,12,1,13,14,4,17,36],reply_text:2,queu:12,deseri:[19,7,21,1,13,4],news_exchang:17,star:[12,17],wildcard:[20,18,17],fulli:6,mongodb:[12,10,3,15],"class":[1,2,3,4,6,8,11,13,16,17,18,19,20,21,22,28,26,27,29,30,31,33,34,35,36],plug:12,get_transport_cl:[36,6],increas:26,backend_cl:36,previous:25,pool:[15,36],stai:12,colliss:26,open_fil:26,filterfunc:35,directori:12,reliabl:12,gethostnam:19,rule:2,interval_start:[26,36],queue_unbind:4,ignor:[35,20],gracefulli:12,potenti:[35,20],time:[0,19,26,36],reply_to:29,cached_properti:26},objtypes:{"0":"py:module","1":"py:class","2":"py:attribute","3":"py:data","4":"py:function","5":"py:method","6":"py:exception","7":"py:classmethod"},titles:["kombu.exceptions","kombu.transport.virtual","kombu.transport.pyamqplib","kombu.transport.mongodb","kombu.transport.librabbitmq","Async Utilities - kombu.syn","kombu.transport","kombu.serialization","Compat. utilities - kombu.utils.compat","kombu.utils.functional","Kombu Documentation","kombu.transport.memory","kombu - AMQP Messaging Framework for Python","Serialization","Connections and transports","API Reference","kombu.compression","kombu.entity","kombu.transport.virtual.exchange","Simple Interface","kombu.messaging","kombu.transport.base","Finalize - kombu.utils.finalize","Frequently Asked Questions","User Guide","kombu.compression","Utilities - kombu.utils","kombu.transport.pyredis","kombu.transport.pypika","kombu.pidbox","kombu.transport.pycouchdb","kombu.transport.beanstalk","Change history","kombu.transport.virtual.scheduling","kombu.simple","kombu.compat","kombu.connection"],objnames:{"0":"Python module","1":"Python class","2":"Python attribute","3":"Python data","4":"Python function","5":"Python method","6":"Python exception","7":"Python class method"},filenames:["reference/kombu.exceptions","reference/kombu.transport.virtual","reference/kombu.transport.pyamqplib","reference/kombu.transport.mongodb","reference/kombu.transport.librabbitmq","reference/kombu.syn","reference/kombu.transport","reference/kombu.serialization","reference/kombu.utils.compat","reference/kombu.utils.functional","index","reference/kombu.transport.memory","introduction","userguide/serialization","userguide/connections","reference/index","reference/kombu.abstract","reference/kombu.entity","reference/kombu.transport.virtual.exchange","userguide/simple","reference/kombu.messaging","reference/kombu.transport.base","reference/kombu.utils.finalize","faq","userguide/index","reference/kombu.compression","reference/kombu.utils","reference/kombu.transport.pyredis","reference/kombu.transport.pypika","reference/kombu.pidbox","reference/kombu.transport.pycouchdb","reference/kombu.transport.beanstalk","changelog","reference/kombu.transport.virtual.scheduling","reference/kombu.simple","reference/kombu.compat","reference/kombu.connection"]})
\ No newline at end of file
+Search.setIndex({objects:{"kombu.transport.pypika.BlockingConnection":{ensure_drain_events:[28,5,1],channel:[28,5,1]},"kombu.transport.virtual.scheduling.FairCycle":{close:[33,5,1],get:[33,5,1]},"kombu.transport.beanstalk.Transport":{Channel:[31,1,1]},"kombu.connection.ChannelPool":{release:[36,5,1],acquire:[36,5,1],LimitExceeded:[36,2,1]},"kombu.transport.librabbitmq.Transport.Connection.Channel":{Message:[4,1,1],message_to_python:[4,5,1],prepare_message:[4,5,1]},"kombu.simple.SimpleBuffer":{queue_opts:[34,2,1],qsize:[34,5,1],producer:[34,2,1],get:[34,5,1],clear:[34,5,1],get_nowait:[34,5,1],queue:[34,2,1],exchange_opts:[34,2,1],channel:[34,2,1],put:[34,5,1],close:[34,5,1],consumer:[34,2,1],no_ack:[34,2,1],"__len__":[34,5,1]},"kombu.transport.virtual.Channel":{do_restore:[1,2,1],qos:[1,2,1],basic_ack:[1,5,1],basic_reject:[1,5,1],basic_get:[1,5,1],close:[1,5,1],basic_recover:[1,5,1],exchange_declare:[1,5,1],exchange_delete:[1,5,1],queue_bind:[1,5,1],drain_events:[1,5,1],state:[1,2,1],basic_publish:[1,5,1],basic_consume:[1,5,1],queue_delete:[1,5,1],queue_declare:[1,5,1],queue_purge:[1,5,1],basic_qos:[1,5,1],basic_cancel:[1,5,1],message_to_python:[1,5,1],get_table:[1,5,1],exchange_types:[1,2,1],flow:[1,5,1],"typeof":[1,5,1],Message:[1,2,1],prepare_message:[1,5,1]},"kombu.transport.virtual.scheduling":{FairCycle:[33,1,1]},"kombu.pidbox.Mailbox":{Node:[29,5,1],abcast:[29,5,1],get_reply_queue:[29,5,1],exchange:[29,2,1],multi_call:[29,5,1],namespace:[29,2,1],cast:[29,5,1],connection:[29,2,1],call:[29,5,1],get_queue:[29,5,1],reply_exchange:[29,2,1],type:[29,2,1]},"kombu.simple.SimpleQueue":{queue_opts:[34,2,1],qsize:[34,5,1],producer:[34,2,1],get:[34,5,1],clear:[34,5,1],get_nowait:[34,5,1],queue:[34,2,1],exchange_opts:[34,2,1],channel:[34,2,1],put:[34,5,1],close:[34,5,1],consumer:[34,2,1],no_ack:[34,2,1],"__len__":[34,5,1]},"kombu.transport.librabbitmq.Connection.Channel":{exchange_declare:[4,5,1],basic_ack:[4,5,1],queue_bind:[4,5,1],queue_unbind:[4,5,1],basic_qos:[4,5,1],flow:[4,5,1],basic_get:[4,5,1],basic_publish:[4,5,1],basic_consume:[4,5,1],prepare_message:[4,5,1],queue_declare:[4,5,1],basic_cancel:[4,5,1],close:[4,5,1],Message:[4,1,1],queue_purge:[4,5,1],message_to_python:[4,5,1]},"kombu.transport.virtual.exchange.ExchangeType":{equivalent:[18,5,1],lookup:[18,5,1],prepare_bind:[18,5,1]},"kombu.transport.librabbitmq.Connection":{close:[4,2,1],drain_events:[4,5,1],channel:[4,5,1],Channel:[4,1,1]},"kombu.transport.virtual.Message.MessageStateError":{message:[1,2,1],args:[1,2,1]},"kombu.transport":{pyamqplib:[2,0,1],librabbitmq:[4,0,1],mongodb:[3,0,1],resolve_transport:[6,4,1],pyredis:[27,0,1],virtual:[1,0,1],TRANSPORT_ALIASES:[6,3,1],DEFAULT_TRANSPORT:[6,3,1],beanstalk:[31,0,1],base:[21,0,1],pypika:[28,0,1],get_transport_cls:[6,4,1],memory:[11,0,1],pycouchdb:[7,0,1]},"kombu.pidbox":{Node:[29,1,1],Mailbox:[29,1,1]},"kombu.transport.pypika.AsyncoreConnection":{Super:[28,2,1],on_data_available:[28,5,1],ensure_drain_events:[28,5,1],channel:[28,5,1]},"kombu.transport.base.Message":{body:[21,2,1],ack:[21,5,1],delivery_info:[21,2,1],acknowledged:[21,2,1],properties:[21,2,1],decode:[21,5,1],headers:[21,2,1],content_encoding:[21,2,1],content_type:[21,2,1],reject:[21,5,1],delivery_tag:[21,2,1],requeue:[21,5,1],payload:[21,2,1],channel:[21,2,1]},"kombu.compat.Publisher":{close:[35,5,1],send:[35,5,1],revive:[35,5,1],publish:[35,5,1],declare:[35,5,1]},"kombu.connection.ConnectionPool":{release:[36,5,1],acquire:[36,5,1],LimitExceeded:[36,2,1]},"kombu.transport.pyredis.Transport":{Channel:[27,1,1]},"kombu.transport.pyamqplib.Transport":{Connection:[2,1,1],establish_connection:[2,5,1],drain_events:[2,5,1],create_channel:[2,5,1],close_connection:[2,5,1]},"kombu.transport.pycouchdb.Transport.Channel":{client:[7,2,1]},"kombu.connection.BrokerConnection":{info:[36,5,1],SimpleBuffer:[36,5,1],create_transport:[36,5,1],SimpleQueue:[36,5,1],get_transport_cls:[36,5,1],channel_errors:[36,2,1],drain_events:[36,5,1],transport:[36,2,1],host:[36,2,1],release:[36,5,1],connection:[36,2,1],connection_errors:[36,2,1],ensure:[36,5,1],Pool:[36,5,1],ensure_connection:[36,5,1],ChannelPool:[36,5,1],clone:[36,5,1],channel:[36,5,1],connect:[36,5,1]},"kombu.entity":{Queue:[17,1,1],Exchange:[17,1,1]},"kombu.transport.pycouchdb.Transport":{Channel:[7,1,1]},"kombu.transport.pyamqplib":{Transport:[2,1,1],Connection:[2,1,1],Message:[2,1,1],Channel:[2,1,1]},"kombu.utils.finalize.Finalize":{cancel:[22,5,1],still_active:[22,5,1]},"kombu.transport.pypika.Channel":{basic_ack:[28,5,1],basic_get:[28,5,1],basic_publish:[28,5,1],basic_consume:[28,5,1],message_to_python:[28,5,1],queue_purge:[28,5,1],Message:[28,1,1],prepare_message:[28,5,1]},"kombu.transport.pycouchdb.Channel":{client:[7,2,1]},"kombu.serialization":{register:[30,4,1],decode:[30,4,1],SerializerNotInstalled:[30,6,1],encode:[30,4,1],raw_encode:[30,4,1],registry:[30,3,1]},"kombu.transport.mongodb.Transport":{Channel:[3,1,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,5,1],drain_events:[1,5,1],interval:[1,2,1],establish_connection:[1,5,1],close_connection:[1,5,1],state:[1,2,1],create_channel:[1,5,1],default_port:[1,2,1],cycle:[1,2,1],Channel:[1,2,1],Cycle:[1,2,1]},"kombu.compat":{Publisher:[35,1,1],Consumer:[35,1,1],ConsumerSet:[35,1,1]},"kombu.transport.virtual.exchange.FanoutExchange":{lookup:[18,5,1]},"kombu.transport.pypika":{SyncTransport:[28,1,1],AsyncoreConnection:[28,1,1],Message:[28,1,1],AsyncoreTransport:[28,1,1],Channel:[28,1,1],BlockingConnection:[28,1,1]},"kombu.transport.librabbitmq.Connection.Channel.Message":{body:[4,2,1],ack:[4,5,1],MessageStateError:[4,6,1],acknowledged:[4,2,1],delivery_tag:[4,2,1],decode:[4,5,1],reject:[4,5,1],requeue:[4,5,1],payload:[4,2,1],channel:[4,2,1]},"kombu.transport.mongodb.Transport.Channel":{close:[3,5,1],client:[3,2,1]},"kombu.transport.memory.Transport":{state:[11,2,1],Channel:[11,1,1]},"kombu.messaging.Producer":{compression:[20,2,1],exchange:[20,2,1],serializer:[20,2,1],revive:[20,5,1],publish:[20,5,1],routing_key:[20,2,1],auto_declare:[20,2,1],on_return:[20,2,1],declare:[20,5,1],channel:[20,2,1]},"kombu.transport.pyamqplib.Connection":{drain_events:[2,5,1],wait_multi:[2,5,1],read_timeout:[2,5,1],close:[2,5,1],channel:[2,5,1],wait:[2,5,1]},"kombu.transport.virtual.QoS":{ack:[1,5,1],restore_unacked:[1,5,1],restore_unacked_once:[1,5,1],prefetch_count:[1,2,1],can_consume:[1,5,1],reject:[1,5,1],append:[1,5,1]},"kombu.transport.pyredis":{Channel:[27,1,1],Transport:[27,1,1]},"kombu.transport.virtual.Message":{ack:[1,5,1],MessageStateError:[1,6,1],acknowledged:[1,2,1],serializable:[1,5,1],decode:[1,5,1],reject:[1,5,1],requeue:[1,5,1],payload:[1,2,1]},"kombu.transport.librabbitmq.Transport.Connection.Channel.Message":{body:[4,2,1],delivery_tag:[4,2,1],channel:[4,2,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:[11,1,1],Channel:[11,1,1]},"kombu.utils.finalize":{Finalize:[22,1,1]},"kombu.transport.beanstalk":{Transport:[31,1,1],Channel:[31,1,1]},"kombu.pidbox.Node":{handle:[29,5,1],handlers:[29,2,1],dispatch_from_message:[29,5,1],hostname:[29,2,1],state:[29,2,1],dispatch:[29,5,1],mailbox:[29,2,1],handle_call:[29,5,1],handler:[29,5,1],handle_cast:[29,5,1],handle_message:[29,5,1],reply:[29,5,1],Consumer:[29,5,1],channel:[29,2,1],listen:[29,5,1]},"kombu.transport.base.Transport":{close_channel:[21,5,1],channel_errors:[21,2,1],drain_events:[21,5,1],establish_connection:[21,5,1],client:[21,2,1],connection_errors:[21,2,1],create_channel:[21,5,1],default_port:[21,2,1],close_connection:[21,5,1]},"kombu.transport.librabbitmq.Channel":{Message:[4,1,1],message_to_python:[4,5,1],prepare_message:[4,5,1]},"kombu.transport.pypika.SyncTransport":{drain_events:[28,5,1],establish_connection:[28,5,1],Connection:[28,2,1],create_channel:[28,5,1],Message:[28,1,1],close_connection:[28,5,1]},"kombu.transport.pycouchdb":{create_message_view:[7,4,1],Transport:[7,1,1],Channel:[7,1,1]},"kombu.transport.pyamqplib.Channel.Message":{body:[2,2,1],delivery_tag:[2,2,1],channel:[2,2,1]},"kombu.transport.virtual.exchange.TopicExchange":{wildcards:[18,2,1],lookup:[18,5,1],prepare_bind:[18,5,1],key_to_pattern:[18,5,1]},"kombu.messaging.Consumer":{qos:[20,5,1],consume:[20,5,1],register_callback:[20,5,1],receive:[20,5,1],cancel:[20,5,1],cancel_by_queue:[20,5,1],flow:[20,5,1],revive:[20,5,1],declare:[20,5,1],purge:[20,5,1],callbacks:[20,2,1],auto_declare:[20,2,1],on_decode_error:[20,2,1],queues:[20,2,1],recover:[20,5,1],no_ack:[20,2,1],channel:[20,2,1]},"kombu.transport.mongodb.Channel":{close:[3,5,1],client:[3,2,1]},"kombu.transport.pyamqplib.Channel":{Message:[2,1,1],message_to_python:[2,5,1],prepare_message:[2,5,1]},"kombu.utils.compat.CompatOrderedDict":{fromkeys:[8,7,1],setdefault:[8,5,1],keys:[8,5,1],items:[8,5,1],clear:[8,5,1],popitem:[8,5,1],update:[8,5,1],pop:[8,5,1],values:[8,5,1],itervalues:[8,5,1],iteritems:[8,5,1],copy:[8,5,1],iterkeys:[8,5,1]},"kombu.transport.virtual.BrokerState":{bindings:[1,2,1],exchanges:[1,2,1]},"kombu.transport.librabbitmq.Transport":{drain_events:[4,5,1],establish_connection:[4,5,1],Connection:[4,1,1],create_channel:[4,5,1],close_connection:[4,5,1]},"kombu.connection":{ChannelPool:[36,1,1],ConnectionPool:[36,1,1],BrokerConnection:[36,1,1]},"kombu.transport.virtual.exchange.DirectExchange":{lookup:[18,5,1]},"kombu.transport.librabbitmq.Connection.Channel.Message.MessageStateError":{message:[4,2,1],args:[4,2,1]},"kombu.transport.librabbitmq.Message":{body:[4,2,1],delivery_tag:[4,2,1],channel:[4,2,1]},"kombu.compat.ConsumerSet":{add_consumer_from_dict:[35,5,1],iterconsume:[35,5,1],add_consumer:[35,5,1],consume:[35,5,1],register_callback:[35,5,1],receive:[35,5,1],flow:[35,5,1],revive:[35,5,1],cancel_by_queue:[35,5,1],purge:[35,5,1],discard_all:[35,5,1],cancel:[35,5,1],close:[35,5,1],recover:[35,5,1],declare:[35,5,1],qos:[35,5,1]},"kombu.abstract.MaybeChannelBound":{is_bound:[16,2,1],when_bound:[16,5,1],bind:[16,5,1],revive:[16,5,1],maybe_bind:[16,5,1],channel:[16,2,1]},"kombu.transport.beanstalk.Transport.Channel":{close:[31,5,1],client:[31,2,1]},"kombu.entity.Queue":{exclusive:[17,2,1],unbind:[17,5,1],when_bound:[17,5,1],name:[17,2,1],exchange:[17,2,1],queue_declare:[17,5,1],auto_delete:[17,2,1],durable:[17,2,1],routing_key:[17,2,1],purge:[17,5,1],queue_bind:[17,5,1],queue_arguments:[17,2,1],maybe_bind:[17,5,1],binding_arguments:[17,2,1],cancel:[17,5,1],get:[17,5,1],"delete":[17,5,1],declare:[17,5,1],channel:[17,2,1],consume:[17,5,1]},"kombu.transport.pypika.AsyncoreTransport":{Connection:[28,2,1]},"kombu.transport.librabbitmq.Transport.Connection":{Channel:[4,1,1]},"kombu.transport.pyredis.Transport.Channel":{client:[27,2,1],get_table:[27,5,1],subclient:[27,2,1],basic_cancel:[27,5,1],basic_consume:[27,5,1],active_queues:[27,2,1],close:[27,5,1]},"kombu.entity.Exchange":{delivery_mode:[17,2,1],name:[17,2,1],auto_delete:[17,2,1],durable:[17,2,1],publish:[17,5,1],maybe_bind:[17,5,1],arguments:[17,2,1],Message:[17,5,1],type:[17,2,1],declare:[17,5,1],channel:[17,2,1],"delete":[17,5,1]},"kombu.transport.beanstalk.Channel":{close:[31,5,1],client:[31,2,1]},"kombu.transport.librabbitmq":{Message:[4,1,1],Channel:[4,1,1],Connection:[4,1,1],Transport:[4,1,1]},"kombu.abstract":{MaybeChannelBound:[16,1,1]},"kombu.simple":{SimpleBuffer:[34,1,1],SimpleQueue:[34,1,1]},"kombu.transport.virtual.exchange":{DirectExchange:[18,1,1],ExchangeType:[18,1,1],FanoutExchange:[18,1,1],TopicExchange:[18,1,1]},"kombu.compression":{encoders:[25,4,1],get_encoder:[25,4,1],register:[25,4,1],compress:[25,4,1],decompress:[25,4,1],get_decoder:[25,4,1]},kombu:{compat:[35,0,1],compression:[25,0,1],simple:[34,0,1],"abstract":[16,0,1],syn:[5,0,1],entity:[17,0,1],exceptions:[0,0,1],connection:[36,0,1],messaging:[20,0,1],pidbox:[29,0,1],serialization:[30,0,1],utils:[26,0,1],transport:[6,0,1]},"kombu.transport.pyamqplib.Transport.Connection":{read_timeout:[2,5,1],drain_events:[2,5,1],wait_multi:[2,5,1],channel:[2,5,1]},"kombu.transport.virtual":{AbstractChannel:[1,1,1],exchange:[18,0,1],BrokerState:[1,1,1],Transport:[1,1,1],scheduling:[33,0,1],QoS:[1,1,1],Message:[1,1,1],Channel:[1,1,1]},"kombu.syn":{select_blocking_method:[5,4,1],detect_sync_method:[5,4,1],blocking:[5,4,1]},"kombu.transport.mongodb":{Channel:[3,1,1],Transport:[3,1,1]},"kombu.compat.Consumer":{iterconsume:[35,5,1],qos:[35,5,1],process_next:[35,5,1],register_callback:[35,5,1],receive:[35,5,1],consume:[35,5,1],flow:[35,5,1],cancel_by_queue:[35,5,1],revive:[35,5,1],purge:[35,5,1],discard_all:[35,5,1],fetch:[35,5,1],cancel:[35,5,1],close:[35,5,1],iterqueue:[35,5,1],recover:[35,5,1],declare:[35,5,1],wait:[35,5,1]},"kombu.utils":{compat:[8,0,1],kwdict:[26,4,1],cached_property:[26,2,1],finalize:[22,0,1],partition:[26,4,1],functional:[9,0,1],rpartition:[26,4,1],emergency_dump_state:[26,4,1],uuid4:[26,4,1],fxrange:[26,4,1],gen_unique_id:[26,4,1],retry_over_time:[26,4,1],say:[26,4,1],maybe_list:[26,4,1]},"kombu.transport.librabbitmq.Channel.Message":{body:[4,2,1],delivery_tag:[4,2,1],channel:[4,2,1]},"kombu.transport.pyredis.Channel":{client:[27,2,1],active_queues:[27,2,1],subclient:[27,2,1],basic_cancel:[27,5,1],basic_consume:[27,5,1],get_table:[27,5,1],close:[27,5,1]},"kombu.messaging":{Consumer:[20,1,1],Producer:[20,1,1]},"kombu.utils.compat":{CompatOrderedDict:[8,1,1]},"kombu.transport.base":{Message:[21,1,1],Transport:[21,1,1]}},terms:{fanoutexchang:18,represent:20,pluggabl:12,concept:12,get_reply_queu:29,consum:[19,20,29,12,1,33,13,34,15,17,35],all:[20,12,1,2,13,17,35,18,8],interchang:19,four:[12,17],uncknowledg:1,code:2,sleep:[26,36],per:13,abil:12,follow:[12,20,35,13],disk:17,request:[35,30,36,2,20],content:[30,21,20,10,13,35],typeerror:26,depend:[0,12,36,14,17],decim:13,specif:[20,2,14,17,35,36,18],send:[19,30,29,20,12,2,13,24,14,17,35],articl:[12,17],dispatch_from_messag:29,init:29,program:13,under:12,sens:17,shortstr:2,brokerst:1,sent:[20,21,12,1,13,4,17,35],suitabl:30,passiv:[1,4,17],mpg:19,sourc:12,everi:[12,26,13],solem:[0,20,21,11,1,2,33,25,27,28,34,16,4,6,17,35,29,18,36],fals:[20,1,28,26,4,17,35,36,8],unacknowledg:[35,1,20],util:[9,30,10,22,33,25,15,16,5,26,8],ident:[12,17],fan:12,fall:[35,20],drain_ev:[29,21,12,1,2,28,4,36],affect:[12,20,35],ticket:29,exact:18,abcast:29,iterconsum:35,level:[12,19],exchange_opt:[34,36],messagestateerror:[0,1,21,4],list:[30,20,12,23,13,25,14,36],nasdaq:[12,17],rabbitmq:[12,20,23,35,17],"try":[0,20,26,29],item:[30,36,8],pypika:[10,28,15],default_port:[1,21],quick:12,refer:[14,10,13,15],prepar:[1,26],localhost:[12,14,36,4,19],pleas:12,impli:17,when_bound:[16,17],slower:13,maybe_list:26,still_act:22,sync:12,"_queue_bind":18,zero:[12,20,35,17],video:[12,19],pass:[29,30,20,13,26,35,36],download:12,port:[21,12,1,14,4,36],append:1,compat:[9,10,12,13,15,35,8],index:[12,10],dialogu:17,establish_connect:[4,1,21,2,28],sub:12,eventlet:5,repli:[29,2,17],connection_error:[21,36],brief:23,current:[19,20,1,29,34,16,5,17,35,36],delet:[20,12,1,2,26,17,35,36],version:[12,26],key_to_pattern:18,encourag:12,"new":[20,30,12,1,25,17,35,36,8],ever:17,method:[0,30,21,20,1,2,13,25,14,4,5,17,35,29,18,36],requeu:[20,21,1,23,4,35],transport_alias:6,full:[12,14,6],hash:[12,17],timeouterror:0,iteritem:8,gener:[29,26,17],never:36,onli:[12,1,17,19,30],len:34,bodi:[29,20,21,30,1,2,25,4,17,35],base64:13,pub:12,address:36,path:[36,6],along:[35,20],ensure_connect:36,modifi:17,sinc:13,valu:[20,1,2,26,4,17,8],wait:[20,12,2,5,17,35,36],search:10,produc:[19,20,12,13,34,15,35,36],sender:2,configuar:12,host:[14,36,4],delivery_tag:[4,1,21,2,28],queue:[19,20,21,12,1,27,28,34,15,4,17,35,36,18],datetim:19,base:[10,21,30,1,15,18],within:[35,20],action:[26,17],implement:[12,1,23,18],chanc:[1,26,33],control:[35,20],semant:36,via:12,regardless:36,primit:[12,17],modul:[10,36,13],put:[19,1,21,4,34],beanstalk:[12,10,31,15],api:[1,15,10],celerybeat:29,basic_qo:[1,4],instal:[12,30,10],redi:[32,12,27,14,36,18],simultaen:[0,36],establish:[2,28,14,16,4,36],unit:12,highli:12,regex:18,usd:[12,17],from:[19,20,21,22,12,1,2,33,14,4,17,35,34,36,8],describ:[30,17],limitexceed:[0,36],memori:[10,11,12,1,14,15,17,36],method_sig:2,regist:[35,30,25,13,20],two:[19,20,12,26,17,35],next:26,overflow:[35,20],handler:[29,28],call:[0,19,20,12,29,14,16,5,17,35,36],recommend:[36,17],taken:22,scope:1,prev:18,type:[29,30,21,20,12,1,33,13,25,4,5,17,35,18],until:[35,20,26,36,17],science_new:17,more:[0,1,2,3,4,6,11,12,13,14,16,17,18,20,21,7,25,28,27,29,30,31,33,34,35,36],prefetch_s:[35,1,20],desir:13,faircycl:[1,33],detail:[0,1,2,3,4,6,7,11,12,16,17,18,20,21,31,25,28,27,29,30,33,34,35,36],afer:16,simplebuff:[19,34,36],warn:[35,20,36],flag:[34,1,16,20,17],"transient":[19,36,17],accept:[35,20],rabbit:[12,36],aris:19,unseri:30,obj:[36,22],hold:17,arg:[22,1,2,26,27,16,4,5,35,8],cach:26,content_typ:[30,21,20,1,2,13,25,4,17,35,28],must:[20,21,12,1,2,26,4,17,35,36],annoy:12,high:12,none:[19,30,21,22,20,1,2,29,28,34,26,4,6,17,35,36,8],join:12,active_queu:27,restor:1,alia:[28,25,6,17],setup:12,work:[23,13,32],uniqu:[4,26,2,17],histori:[10,32],default_transport:6,descriptor:26,remain:17,tag:[4,1,21,2,17],del:26,can:[19,30,21,20,12,1,2,13,14,16,17,35,36,26],pidbox:[29,10,15],root:12,fetch:35,def:[19,29,26,36],overrid:[35,20],close_channel:[1,21],stream:30,give:[35,20,26,36],process:[19,20,21,12,1,13,4,35,29],autodetect:[35,20],share:[36,18],dump_entri:19,indic:[10,2],topic:[12,15,18,17],carrot:[12,35,13,32],exchange_delet:1,want:[20,30,1,2,13,14],tarbal:12,serial:[19,30,21,10,12,13,20,24,34,15,17,35],occur:[30,36,20,17],string:[30,20,13,6,17,36],alwai:[12,36,17],end:[35,20],secur:12,rather:[35,1,20],anoth:36,interval_step:[26,36],how:[26,36],need:[19,20,12,13,14,35,36,18],purg:[35,20,17],"__init__":19,reject:[1,21,4,23],answer:23,instead:[19,1,21],reviv:[35,20,16],simpl:[19,10,20,24,34,15,35],connect_timeout:36,convers:18,stock:[12,17],map:[29,20,1,6,35,18],create_message_view:7,resourc:[1,36,2,33],create_channel:[4,1,21,2,28],librabbitmq:[10,4,15],max:26,clone:36,after:[20,2],befor:[12,26,36],wait_multi:2,reply_exchang:29,date:[19,15,32,13,24],multipl:[36,4],data:[19,30,29,1,2,13,24,15,4,6],handl:[12,20,2,29],github:12,attempt:[35,20],nativ:[12,13],encapsul:[4,2],bind:[20,12,1,16,17,35,18],stdin:36,correspond:[1,18],django:12,issu:[12,2],inform:[14,21,17],maintain:13,environ:5,allow:12,media:12,exclus:[35,4,17],mechan:[35,20],order:[20,8],queue_delet:1,add_consumer_from_dict:35,method_id:2,help:[12,10],media_exchang:12,queue_opt:[34,36],failur:[21,2],becaus:17,jpeg:13,handle_cal:29,image_queu:12,held:[35,20],own:[14,21,17],reconnect:2,undeliver:20,brokerconnect:[19,29,21,12,1,14,36],still:[35,20],paramet:[20,30,1,2,25,28,26,17,35,36,18],prepare_bind:18,fit:13,itervalu:8,amqplib:[12,14,36,2],fix:[12,26],clymer:7,defin:[19,12,1,2,17,18],better:13,yaml:[30,13],window:[35,20],restart:17,persist:[19,15,36,34,17],mail:[12,23],therefor:17,consumerset:[35,15],select_blocking_method:5,epol:32,eur:[12,17],non:[12,1,17],good:13,synopsi:[12,10],thei:[12,19,13,17],reveal:23,python:[9,10,21,19,30,12,1,2,13,26,4,35],auto:[36,13,17],initi:[1,32],easy_instal:12,framework:[12,10],automat:[12,20,36,35],amqp_messag:28,restore_unacked_onc:1,now:[26,32,13,17],discuss:23,introduct:[12,15,29],choic:13,term:[35,20],name:[19,30,29,20,12,25,34,6,17,35,36],event:[12,1,36,2,20],userid:[14,19,36,4],restore_unack:1,video_queu:12,separ:[12,36,18,17],easili:12,localis:2,reactiv:[35,20],mode:17,timeout:[19,29,12,1,2,28,34,4,36],each:[1,33,13,26,17,36],januari:[15,23,24],unicod:[30,26,13],updat:8,side:2,mean:[20,21,1,2,14,4,17,35],domain:[12,17],redeliv:[35,20],replac:35,kombu:[0,1,2,3,4,5,6,7,8,9,10,11,12,14,15,16,17,18,19,20,21,22,25,28,26,27,29,30,31,33,34,35,36],discard_al:35,realli:12,connect:[0,1,2,3,4,10,11,12,14,15,16,17,19,20,21,7,24,28,26,29,31,35,36],channelpool:36,our:[12,2,17],happen:[12,19,21],errror:12,orient:12,special:[12,30,17],out:[0,1,12],msgpack:[30,13],unbound:[0,12,17],asyncoreconnect:28,goe:1,open:[12,36,26,13],publish:[20,21,12,1,13,34,15,4,17,35,36],payload:[12,1,21,4,19],max_retri:[26,36],cest:32,sever:[12,14],print:[19,26,36],gen_unique_id:26,sphinx:12,qualifi:6,directexchang:18,insid:13,advanc:[12,20,35],bound_sicence_new:17,undo:[35,20],standard:[12,19,18,13],small:26,reason:[12,23],orm:12,mime:[30,25],dictionari:[30,8,13],ask:[0,1,2,27,4,6,10,11,12,16,17,18,20,21,23,25,28,29,33,34,35,36],org:[35,26],close_connect:[4,1,21,2,28],decompress:25,basi:13,pyyaml:30,perform:[12,20,35,17],couldn:36,thread:36,forc:[36,2],delivery_info:21,traceback:36,synchron:[1,17],fromtimestamp:19,if_unus:[1,17],david:[7,31],connectionlimitexceed:[0,36],channel_error:[21,36],prefetch:[35,1,20],reply_cod:2,log_messag:19,global:[35,20,11],licens:[0,1,2,3,4,6,7,10,11,12,16,17,18,20,21,31,25,28,27,29,30,33,34,35,36],frequent:[10,23],oper:[0,20,12,17,35,36],softwar:12,create_transport:36,mixin:16,do_restor:1,exchange_declar:[1,4],exchang:[19,10,29,20,12,1,13,27,28,34,15,4,17,35,36,18],qualiti:[35,1,20,15],number:[0,20,1,14,26,35,36],basic_get:[1,4,28],ziegler:31,mai:[20,21,2,13,14,17,35,36],instruct:13,alreadi:[0,20,21,12,1,16,4,17,35],done:[35,1,36,20,17],messag:[0,1,2,4,10,12,13,14,15,17,18,19,20,21,23,24,28,29,30,34,35,36],blank:17,miss:13,primari:13,retry_over_tim:26,size:[12,20,35],prioriti:[20,1,2,28,4,17,35],is_bound:16,differ:[14,19],"long":[26,17],smaller:[35,20,13],guest:[12,14,36,4,19],queue_bind:[1,4,17],associ:[2,25,17],top:12,slept:36,least:17,necessarili:17,monkei:5,interfac:[19,10,21,12,24,34,15,35,36,18],scheme:[12,13,17],routing_kei:[29,20,12,1,13,28,34,4,17,35,36,18],store:[26,18,17],listen:29,premoli:3,option:[29,30,20,13,34,17,35,36],auto_delet:[18,1,4,35,17],namespac:29,shallow:8,message_data:[1,2,28],specifi:[19,30,21,20,1,13,14,6,17,35,36],direct:[29,12,1,15,4,17,18],broadcast:[29,18],forward:17,"short":2,word:[12,18,17],handle_cast:29,basic_publish:[1,4,28],than:[12,20,35,13,17],conveni:30,keyword:[20,26,36],provid:[12,26,2,36,17],remov:[19,21,1,4,17,8],connectionpool:36,uuid4:26,structur:[1,21,4,13,30],charact:[12,30,18,17],project:12,classmethod:8,info:[19,29,36],str:[30,20],were:17,posit:26,design:17,minut:17,no_ack:[20,1,28,34,4,17,35,36],transport:[10,21,11,7,12,1,2,33,24,3,28,14,15,4,31,27,6,36,18],deliveri:[4,21,2,17],sai:26,counter:2,kwdict:26,enable_callback:35,adher:1,modern:13,ani:[20,12,2,13,17,35,36,18],packag:[12,30,35],pip:12,binding_argu:17,have:[19,20,12,13,14,26,17,35,36],"__main__":19,notbounderror:[0,12],notimplementederror:[35,1,20],exclud:18,caus:[2,13],built:[12,26,13,6,17],equival:[19,18],callback:[19,20,29,22,1,26,28,16,4,17,35,36],latter:[19,30],ack:[19,1,21,4],note:[35,30,13,20,17],rpartit:26,without:[14,13,24,17],get_tabl:[1,18,27],take:[20,26],which:[19,20,2,13,14,17,35,8],fifo:8,text:[12,21,2,25],channel:[0,1,2,3,4,11,12,13,15,16,17,18,19,20,21,7,28,27,29,31,34,35,36],even:[12,30,14,5,17],copi:[36,16,18,8],unless:30,distribut:12,onf:5,buffer:[19,15,36,34],object:[19,30,20,22,13,16,17,36,8],compress:[19,10,20,12,25,34,15,16,35],most:[12,36,17],regular:12,bsd:[0,1,2,3,4,6,7,11,12,16,17,18,20,21,31,25,28,27,29,30,33,34,35,36],process_media:12,why:23,lazili:36,don:[12,13],exc:[20,26,36],clear:[34,8],cover:17,doe:[12,20,35,6,17],deliv:[35,20,18,17],part:[1,13,17],determin:17,pattern:[12,17],latest:12,dot:[12,18,17],drain:[1,20],recipi:[35,20],serializ:1,multi_cal:29,particip:12,consult:6,speedup:13,directli:1,protocol:[12,18],resolve_transport:6,find:[35,20],setter:26,access:[1,17],fxrang:26,explicitli:[14,17],acquir:36,copyright:[0,1,2,3,4,6,7,11,16,17,18,20,21,31,25,28,27,29,30,33,34,35,36],"true":[19,20,21,12,1,2,29,28,34,4,17,35,36,18,8],transact:1,configur:[12,36],releas:[15,36,24,32],forev:[26,36],should:[12,30,26,35,20],recov:[35,1,20],local:[35,20,17],over:[26,13],pika:[12,14,36,28],iterkei:8,contribut:[12,10],get:[19,10,12,1,33,25,34,26,6,17,36,18],beat:29,familiar:12,express:13,stop:[35,20,26],synctransport:28,ssl:36,cannot:2,postencod:21,popitem:8,report:12,pipermail:23,get_queu:29,requir:[19,18],bound_science_new:17,auto_declar:[35,20],enabl:[20,1,34,4,35,36],patch:[12,5],rfc:2,channel_id:[4,2],common:[12,17],partit:26,contain:[1,17,30],asyncoretransport:28,where:[1,26,33,5,17],attapattu:17,respond:[2,17],set:[26,30,21,20,1,33,13,14,16,4,17,35,36,18],basic_ack:[1,4,28],allowed_method:2,sep:26,basic_reject:1,around:13,get_decod:25,see:[0,1,2,3,4,6,11,12,14,16,17,18,20,21,7,23,25,28,26,27,29,30,31,33,34,35,36],fanout:[12,15,18,29,17],mandatori:[35,20,28,4,17],result:[36,5],respons:[36,17],fail:2,close:[19,31,1,2,33,3,28,34,4,27,17,35,36],serializernotinstal:30,best:13,onc:1,infinit:35,can_consum:1,detect:[2,5,13],correctli:2,hopefulli:26,down:[35,20,2],databas:14,someth:19,wikipedia:12,veri:26,unack:1,state:[29,11,1,15,26,17,18],won:17,pyredi:[10,27,15],prefetch_count:[35,1,20],between:[20,1,26,17,35,36],register_callback:[12,20,35],"import":[12,14,19,17],entiti:[0,10,17,20,15],across:12,attribut:[12,36,18,13,17],altern:[35,20,13],signatur:[35,20],auto_decod:2,nowait:[1,28,4,17],pylibrabbitmq:4,kei:[19,20,12,1,17,35,36,18,8],default_seri:30,xrang:19,mailbox:[29,15],pypi:[12,35],cycl:[1,13],prepare_messag:[4,1,2,28],wait_for_open:28,here:19,come:19,uuid:26,both:[12,19,17],last:[36,8,17],execed:36,supports_fanout:18,howev:13,equal:[35,1,33,8,20],connection_info:29,etc:[12,13],instanc:[26,20,21,1,2,13,16,4,17,35,36],context:[19,29,2],improv:[35,20],iterqueu:35,com:[12,36,23],simplequeu:[19,34,36],load:36,simpli:12,kwd:8,cancer:17,point:1,instanti:[35,20,36],schedul:[10,33,15],pop:8,header:[20,21,1,2,13,28,34,4,17,35,18],colon:36,shortcut:[19,36],shutdown:1,linux:32,cancel:[29,20,22,1,17,35],guid:[10,24],assum:17,backend:[18,11],second:[26,36],would:30,due:[21,2],been:[0,20,21,12,1,4,35,36],json:[12,30,19,13,20],much:26,interpret:[12,17],subscrib:[35,20],raw_encod:30,emul:1,addit:[19,21,34,26,17,36],"__len__":34,field:[14,17],if_empti:[1,17],lifo:8,imag:[12,13],appli:[35,20,36],convert:[4,1,2],argument:[19,20,1,29,14,26,4,17,35,36,18],proven:12,predic:33,"catch":26,former:19,queue_nam:19,"case":[30,13,17],exchange_typ:[35,1],stolen:17,queue_argu:17,process_next:35,raw:[30,21,1,13,24,17],plain:13,servic:[35,1,20,15],properti:[21,12,1,2,28,26,4,17],kwarg:[29,7,21,11,22,1,2,33,26,3,28,34,16,4,31,5,17,35,27,36],aim:12,cast:29,"while":[12,19,26,29,20],suport:36,"typeof":1,abov:[19,13],error:[19,21,2,36,17],fun:[29,36,26,33,5],aid:2,loop:36,layer:12,larger:13,advantag:13,readi:[35,1,20],tabl:[18,1,17,6,10],henc:17,them:[12,19,17],jpg:13,destin:[29,17],origin:[20,21,12,1,4,35],"default":[30,21,20,12,1,2,13,14,5,6,17,35,36,18,8],itself:[35,20],avi:12,apply_glob:[35,1,20],"return":[29,30,21,20,1,13,25,26,4,17,18,8],descript:17,ascii:30,conn:36,scienc:17,issue4978:26,weakref:22,disabl:[34,1,36,35,20],develop:12,welcom:12,author:12,receiv:[19,20,21,12,2,24,14,4,17,35,34],suggest:12,make:[12,19,26,5,17],couchdb:[12,7],cross:13,same:[19,20,12,13,14,17,36],binari:[30,13,17],html:23,decod:[20,21,30,1,13,25,15,4,35],timestamp:19,algorithm:[12,17],document:[12,10,14,35],complet:36,finish:[35,20,17],http:[12,35,26,23],hostnam:[14,19,36,29],message_to_python:[4,1,2,28],syn:[10,5,15],solut:12,fairli:[1,13],rais:[20,21,30,12,1,26,4,17,35,36],user:[12,10,19,24],mani:[36,13],bound_exchang:[12,17],recent:36,fromkei:8,task:12,kept:12,cjson:13,whole:[35,20],reload_schedul:29,inherit:1,cutekitten:19,pickl:[12,30,13],client:[29,20,21,11,7,12,1,2,3,28,4,31,27,17,35,36],command:29,thi:[19,30,21,20,12,1,2,25,14,26,4,17,35,29,18,36],choos:14,queue_purg:[1,4,28],cure:17,rout:[19,20,12,1,17,35,36,18],usual:[29,1,36,30],identifi:[4,21,2,25,17],entri:19,just:17,when:[19,20,21,12,1,2,13,14,16,6,17,35,36,26],on_return:20,activ:[35,1,36,20,17],"0x1022308d0":8,percoco:3,on_data_avail:28,simultan:[0,36],yet:[14,23],languag:13,warren:12,password:[14,19,36,4],emergency_dump_st:26,easi:12,also:[20,12,13,14,17,35,36],consumer_tag:[1,28,4,27,17],raw_messag:[4,1,2,28],except:[0,10,30,12,1,2,33,13,20,15,26,4,36],param:20,blog:17,add:12,other:[20,2,13,14,35,8],noack:4,overview:[12,30,15],logger:19,match:[12,18,2,17],build:12,applic:[12,30,21,29,17],pyamqplib:[10,36,2,6,15],maybechannelbound:16,loss:20,preserv:17,multiprocess:22,lolcat1:12,alias:[36,25,6],dispatch:[29,20,2,35],"final":[29,10,22,15],amq:[18,1,2],bit:13,characterist:13,recurs:13,insert:8,like:[12,19,13,17],lost:17,arbitrari:[35,20],rajith:17,manual:[12,20,17],resolv:2,integ:17,server:[20,21,12,1,2,4,17,35,36],basic_recov:1,from_dict:35,"boolean":13,singl:[19,20,26,17,36,18],if_unusu:1,popular:12,async:[12,10,29,5,15],nice:20,page:10,provok:2,underli:36,node:[29,15],exceed:[0,26,36],cancel_by_queu:[35,20],acknowledg:[0,20,21,1,34,4,17,36],interv:[1,26,36],some:[12,13],back:[4,1,21,2],self:[19,30,26,36,34],abstractchannel:1,on_decode_error:20,intern:2,sure:[26,5],read:[12,13,17],guarante:1,basic_cancel:[1,4,27],log_queu:19,librari:[19,13,17],registri:[30,25,15],tmp:12,poll:[1,17],collect:1,"function":[9,10,7,25,15,26,5,6,17,36],avoid:[35,20],get_nowait:34,octet:[35,20],subclass:[35,1,20],usernam:[14,36],retri:[26,36],leav:17,select:[1,21,4,5],condit:2,notabl:13,blockingconnect:28,either:[12,26,17],preload:36,ensure_drain_ev:28,idiomat:12,uncompress:25,reach:26,usag:36,broker:[20,1,2,28,4,17,35,36],step:26,maybe_bind:[16,17],although:[35,20,17],found:17,peer:[35,20,2],"__name__":19,post:17,"super":28,pycouchdb:[10,7,15],binding_kei:4,comparison:[12,10],about:[12,23,17],central:30,socket:[19,36],constraint:13,class_id:2,slightli:19,delivery_mod:[35,20,17],unnecessari:30,exampl:[19,30,12,29,14,26,17,36,18],includ:[13,6],disadvantag:13,constructor:[29,1,36],discard:[4,1,21,2,36],errback:[26,36],marshal:30,block:[19,34,36,5],topicexchang:18,qsize:34,detect_sync_method:5,reconnection_strategi:28,"float":13,encod:[19,30,21,20,12,2,13,25,15,4,17,35],bound:[12,29,16,18,17],terminolog:[12,10],three:30,interval_max:[26,36],pair:[36,8,17],read_timeout:2,empti:17,ensur:[12,1,16,36],chang:[1,32,10],exchangetyp:18,your:[12,14,13,17],durabl:[12,1,4,17,35,36,18],manag:1,rkei:[18,13],log:[19,2],wai:36,compatordereddict:8,transfer:13,support:[30,20,12,1,13,14,17,35,18],question:[10,23],iter:8,fast:13,custom:[12,13,17],avail:[30,20,12,25,17,35,36],start:[12,26,36,17],setdefault:8,no_loc:4,tracker:[12,10],myqueu:19,slight:13,treat:17,fork:32,properli:17,simplejson:13,channellimitexceed:[0,36],tupl:[30,21,18,26],basic:[19,20],unbind:17,msg:2,sqlalchemi:12,gain:13,newer:26,queue_declar:[1,4,17],shamelessli:17,line:36,buf:28,bug:[12,10,26],dump:26,count:1,reappli:36,immedi:[20,28,4,17,35,36],utf:30,attr:26,consist:[12,17],possibl:[12,30],whether:17,caller:36,maximum:[0,26,36],tell:36,gevent:5,limit:[0,29,20,1,13,35,36],virtual_host:[14,19,36,4],insist:36,basic_consum:[1,4,27,28],otherwis:[35,20,17],problem:12,delimit:17,repeatlast:26,featur:[12,10,20],add_consum:35,creat:[19,29,14,16,17,36],flow:[35,1,4,20],"abstract":[1,16],filenam:19,doesn:23,repres:30,criteria:17,exist:[12,17],file:[12,36,13],shut:2,check:17,probabl:13,again:[26,36],wast:13,amqp:[19,30,10,12,2,28,14,16,4,17],content_encod:[30,21,20,1,2,13,28,4,17,35],handle_messag:29,excel:19,exitprior:22,virtual:[10,12,1,33,14,15,36,18],flavio:3,vendor:12,my_pictur:13,subclient:27,declar:[20,12,1,34,17,35],lookup:18,get_encod:25,rememb:[36,8],test:12,you:[19,30,21,20,12,1,13,14,4,17,36],reply_text:2,queu:12,deseri:[19,30,21,1,13,4],news_exchang:17,star:[12,17],wildcard:[18,17],fulli:6,mongodb:[12,10,3,15],"class":[1,2,3,4,6,7,8,11,13,16,17,18,19,20,21,22,28,26,27,29,31,33,34,35,36],plug:12,get_transport_cl:[36,6],increas:26,backend_cl:36,previous:25,pool:[15,36],stai:12,colliss:26,open_fil:26,filterfunc:35,directori:12,reliabl:12,gethostnam:19,rule:2,interval_start:[26,36],queue_unbind:4,ignor:[35,20],gracefulli:12,potenti:[35,20],time:[0,19,26,36],reply_to:29,cached_properti:26},objtypes:{"0":"py:module","1":"py:class","2":"py:attribute","3":"py:data","4":"py:function","5":"py:method","6":"py:exception","7":"py:classmethod"},titles:["kombu.exceptions","kombu.transport.virtual","kombu.transport.pyamqplib","kombu.transport.mongodb","kombu.transport.librabbitmq","Async Utilities - kombu.syn","kombu.transport","kombu.transport.pycouchdb","Compat. utilities - kombu.utils.compat","kombu.utils.functional","Kombu Documentation","kombu.transport.memory","kombu - AMQP Messaging Framework for Python","Serialization","Connections and transports","API Reference","kombu.compression","kombu.entity","kombu.transport.virtual.exchange","Simple Interface","kombu.messaging","kombu.transport.base","Finalize - kombu.utils.finalize","Frequently Asked Questions","User Guide","kombu.compression","Utilities - kombu.utils","kombu.transport.pyredis","kombu.transport.pypika","kombu.pidbox","kombu.serialization","kombu.transport.beanstalk","Change history","kombu.transport.virtual.scheduling","kombu.simple","kombu.compat","kombu.connection"],objnames:{"0":"Python module","1":"Python class","2":"Python attribute","3":"Python data","4":"Python function","5":"Python method","6":"Python exception","7":"Python class method"},filenames:["reference/kombu.exceptions","reference/kombu.transport.virtual","reference/kombu.transport.pyamqplib","reference/kombu.transport.mongodb","reference/kombu.transport.librabbitmq","reference/kombu.syn","reference/kombu.transport","reference/kombu.transport.pycouchdb","reference/kombu.utils.compat","reference/kombu.utils.functional","index","reference/kombu.transport.memory","introduction","userguide/serialization","userguide/connections","reference/index","reference/kombu.abstract","reference/kombu.entity","reference/kombu.transport.virtual.exchange","userguide/simple","reference/kombu.messaging","reference/kombu.transport.base","reference/kombu.utils.finalize","faq","userguide/index","reference/kombu.compression","reference/kombu.utils","reference/kombu.transport.pyredis","reference/kombu.transport.pypika","reference/kombu.pidbox","reference/kombu.serialization","reference/kombu.transport.beanstalk","changelog","reference/kombu.transport.virtual.scheduling","reference/kombu.simple","reference/kombu.compat","reference/kombu.connection"]})
\ No newline at end of file