diff options
Diffstat (limited to 'reference/kombu.transport.librabbitmq.html')
| -rw-r--r-- | reference/kombu.transport.librabbitmq.html | 461 |
1 files changed, 14 insertions, 447 deletions
diff --git a/reference/kombu.transport.librabbitmq.html b/reference/kombu.transport.librabbitmq.html index db80b72a..c4c8754d 100644 --- a/reference/kombu.transport.librabbitmq.html +++ b/reference/kombu.transport.librabbitmq.html @@ -6,13 +6,13 @@ <head> <meta http-equiv="Content-Type" content="text/html; charset=utf-8" /> - <title>kombu.transport.librabbitmq — Kombu v1.3.1 documentation</title> + <title><no title> — Kombu v1.3.2 documentation</title> <link rel="stylesheet" href="../_static/celery.css" type="text/css" /> <link rel="stylesheet" href="../_static/pygments.css" type="text/css" /> <script type="text/javascript"> var DOCUMENTATION_OPTIONS = { URL_ROOT: '../', - VERSION: '1.3.1', + VERSION: '1.3.2', COLLAPSE_INDEX: false, FILE_SUFFIX: '.html', HAS_SOURCE: true @@ -21,10 +21,10 @@ <script type="text/javascript" src="../_static/jquery.js"></script> <script type="text/javascript" src="../_static/underscore.js"></script> <script type="text/javascript" src="../_static/doctools.js"></script> - <link rel="top" title="Kombu v1.3.1 documentation" href="../index.html" /> + <link rel="top" title="Kombu v1.3.2 documentation" href="../index.html" /> <link rel="up" title="API Reference" href="index.html" /> - <link rel="next" title="<no title>" href="kombu.transport.pypika.html" /> - <link rel="prev" title="<no title>" href="kombu.transport.pyamqplib.html" /> + <link rel="next" title="kombu.transport.pypika" href="kombu.transport.pypika.html" /> + <link rel="prev" title="kombu.transport.pyamqplib" href="kombu.transport.pyamqplib.html" /> </head> <body> <div class="related"> @@ -37,12 +37,12 @@ <a href="../py-modindex.html" title="Python Module Index" >modules</a> |</li> <li class="right" > - <a href="kombu.transport.pypika.html" title="<no title>" + <a href="kombu.transport.pypika.html" title="kombu.transport.pypika" accesskey="N">next</a> |</li> <li class="right" > - <a href="kombu.transport.pyamqplib.html" title="<no title>" + <a href="kombu.transport.pyamqplib.html" title="kombu.transport.pyamqplib" accesskey="P">previous</a> |</li> - <li><a href="../index.html">Kombu v1.3.1 documentation</a> »</li> + <li><a href="../index.html">Kombu v1.3.2 documentation</a> »</li> <li><a href="index.html" accesskey="U">API Reference</a> »</li> </ul> </div> @@ -52,429 +52,7 @@ <div class="bodywrapper"> <div class="body"> - <span class="target" id="module-kombu.transport.librabbitmq"></span><div class="section" id="kombu-transport-librabbitmq"> -<h1>kombu.transport.librabbitmq<a class="headerlink" href="#kombu-transport-librabbitmq" title="Permalink to this headline">¶</a></h1> -<p>pylibrabbitmq transport.</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">copyright:</th><td class="field-body"><ol class="first loweralpha simple" start="3"> -<li>2010 - 2011 by Ask Solem.</li> -</ol> -</td> -</tr> -<tr class="field"><th class="field-name">license:</th><td class="field-body"><p class="first last">BSD, see LICENSE for more details.</p> -</td> -</tr> -</tbody> -</table> -<div class="contents local topic" id="contents"> -<ul class="simple"> -<li><a class="reference internal" href="#transport" id="id1">Transport</a></li> -<li><a class="reference internal" href="#connection" id="id2">Connection</a></li> -<li><a class="reference internal" href="#channel" id="id3">Channel</a></li> -<li><a class="reference internal" href="#message" id="id4">Message</a></li> -</ul> -</div> -<div class="section" id="transport"> -<h2><a class="toc-backref" href="#id1">Transport</a><a class="headerlink" href="#transport" title="Permalink to this headline">¶</a></h2> -<dl class="class"> -<dt id="kombu.transport.librabbitmq.Transport"> -<em class="property">class </em><tt class="descclassname">kombu.transport.librabbitmq.</tt><tt class="descname">Transport</tt><big>(</big><em>client</em>, <em>**kwargs</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Transport" title="Permalink to this definition">¶</a></dt> -<dd><dl class="class"> -<dt id="kombu.transport.librabbitmq.Transport.Connection"> -<em class="property">class </em><tt class="descname">Connection</tt><big>(</big><em>host='localhost'</em>, <em>userid='guest'</em>, <em>password='guest'</em>, <em>virtual_host='/'</em>, <em>port=5672</em>, <em>**kwargs</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Transport.Connection" title="Permalink to this definition">¶</a></dt> -<dd><dl class="class"> -<dt id="kombu.transport.librabbitmq.Transport.Connection.Channel"> -<em class="property">class </em><tt class="descname">Channel</tt><big>(</big><em>connection</em>, <em>channel_id</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Transport.Connection.Channel" title="Permalink to this definition">¶</a></dt> -<dd><dl class="class"> -<dt id="kombu.transport.librabbitmq.Transport.Connection.Channel.Message"> -<em class="property">class </em><tt class="descname">Message</tt><big>(</big><em>channel</em>, <em>message</em>, <em>**kwargs</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Transport.Connection.Channel.Message" title="Permalink to this definition">¶</a></dt> -<dd><p>A message received by the broker.</p> -<dl class="attribute"> -<dt id="kombu.transport.librabbitmq.Transport.Connection.Channel.Message.body"> -<tt class="descname">body</tt><a class="headerlink" href="#kombu.transport.librabbitmq.Transport.Connection.Channel.Message.body" title="Permalink to this definition">¶</a></dt> -<dd><p>The message body.</p> -</dd></dl> - -<dl class="attribute"> -<dt id="kombu.transport.librabbitmq.Transport.Connection.Channel.Message.delivery_tag"> -<tt class="descname">delivery_tag</tt><a class="headerlink" href="#kombu.transport.librabbitmq.Transport.Connection.Channel.Message.delivery_tag" title="Permalink to this definition">¶</a></dt> -<dd><p>The message delivery tag, uniquely identifying this message.</p> -</dd></dl> - -<dl class="attribute"> -<dt id="kombu.transport.librabbitmq.Transport.Connection.Channel.Message.channel"> -<tt class="descname">channel</tt><a class="headerlink" href="#kombu.transport.librabbitmq.Transport.Connection.Channel.Message.channel" title="Permalink to this definition">¶</a></dt> -<dd><p>The channel instance the message was received on.</p> -</dd></dl> - -</dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Transport.Connection.Channel.message_to_python"> -<tt class="descclassname">Transport.Connection.Channel.</tt><tt class="descname">message_to_python</tt><big>(</big><em>raw_message</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Transport.Connection.Channel.message_to_python" title="Permalink to this definition">¶</a></dt> -<dd><p>Convert encoded message body back to a Python value.</p> -</dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Transport.Connection.Channel.prepare_message"> -<tt class="descclassname">Transport.Connection.Channel.</tt><tt class="descname">prepare_message</tt><big>(</big><em>body</em>, <em>priority=None</em>, <em>content_type=None</em>, <em>content_encoding=None</em>, <em>headers=None</em>, <em>properties=None</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Transport.Connection.Channel.prepare_message" title="Permalink to this definition">¶</a></dt> -<dd><p>Encapsulate data into a AMQP message.</p> -</dd></dl> - -</dd></dl> - -</dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Transport.close_connection"> -<tt class="descclassname">Transport.</tt><tt class="descname">close_connection</tt><big>(</big><em>connection</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Transport.close_connection" title="Permalink to this definition">¶</a></dt> -<dd><p>Close the AMQP broker connection.</p> -</dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Transport.create_channel"> -<tt class="descclassname">Transport.</tt><tt class="descname">create_channel</tt><big>(</big><em>connection</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Transport.create_channel" title="Permalink to this definition">¶</a></dt> -<dd></dd></dl> - -<dl class="attribute"> -<dt id="kombu.transport.librabbitmq.Transport.default_connection_params"> -<tt class="descclassname">Transport.</tt><tt class="descname">default_connection_params</tt><a class="headerlink" href="#kombu.transport.librabbitmq.Transport.default_connection_params" title="Permalink to this definition">¶</a></dt> -<dd></dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Transport.drain_events"> -<tt class="descclassname">Transport.</tt><tt class="descname">drain_events</tt><big>(</big><em>connection</em>, <em>**kwargs</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Transport.drain_events" title="Permalink to this definition">¶</a></dt> -<dd></dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Transport.establish_connection"> -<tt class="descclassname">Transport.</tt><tt class="descname">establish_connection</tt><big>(</big><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Transport.establish_connection" title="Permalink to this definition">¶</a></dt> -<dd><p>Establish connection to the AMQP broker.</p> -</dd></dl> - -</dd></dl> - -</div> -<div class="section" id="connection"> -<h2><a class="toc-backref" href="#id2">Connection</a><a class="headerlink" href="#connection" title="Permalink to this headline">¶</a></h2> -<dl class="class"> -<dt id="kombu.transport.librabbitmq.Connection"> -<em class="property">class </em><tt class="descclassname">kombu.transport.librabbitmq.</tt><tt class="descname">Connection</tt><big>(</big><em>host='localhost'</em>, <em>userid='guest'</em>, <em>password='guest'</em>, <em>virtual_host='/'</em>, <em>port=5672</em>, <em>**kwargs</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection" title="Permalink to this definition">¶</a></dt> -<dd><dl class="class"> -<dt id="kombu.transport.librabbitmq.Connection.Channel"> -<em class="property">class </em><tt class="descname">Channel</tt><big>(</big><em>connection</em>, <em>channel_id</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel" title="Permalink to this definition">¶</a></dt> -<dd><dl class="method"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.Consumer"> -<tt class="descname">Consumer</tt><big>(</big><em>*args</em>, <em>**kwargs</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.Consumer" title="Permalink to this definition">¶</a></dt> -<dd></dd></dl> - -<dl class="class"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.Message"> -<em class="property">class </em><tt class="descname">Message</tt><big>(</big><em>channel</em>, <em>message</em>, <em>**kwargs</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.Message" title="Permalink to this definition">¶</a></dt> -<dd><p>A message received by the broker.</p> -<dl class="attribute"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.Message.body"> -<tt class="descname">body</tt><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.Message.body" title="Permalink to this definition">¶</a></dt> -<dd><p>The message body.</p> -</dd></dl> - -<dl class="attribute"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.Message.delivery_tag"> -<tt class="descname">delivery_tag</tt><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.Message.delivery_tag" title="Permalink to this definition">¶</a></dt> -<dd><p>The message delivery tag, uniquely identifying this message.</p> -</dd></dl> - -<dl class="attribute"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.Message.channel"> -<tt class="descname">channel</tt><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.Message.channel" title="Permalink to this definition">¶</a></dt> -<dd><p>The channel instance the message was received on.</p> -</dd></dl> - -<dl class="exception"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.Message.MessageStateError"> -<em class="property">exception </em><tt class="descname">MessageStateError</tt><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.Message.MessageStateError" title="Permalink to this definition">¶</a></dt> -<dd><p>The message has already been acknowledged.</p> -<dl class="attribute"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.Message.MessageStateError.args"> -<tt class="descname">args</tt><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.Message.MessageStateError.args" title="Permalink to this definition">¶</a></dt> -<dd></dd></dl> - -<dl class="attribute"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.Message.MessageStateError.message"> -<tt class="descname">message</tt><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.Message.MessageStateError.message" title="Permalink to this definition">¶</a></dt> -<dd></dd></dl> - -</dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.Message.ack"> -<tt class="descclassname">Connection.Channel.Message.</tt><tt class="descname">ack</tt><big>(</big><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.Message.ack" title="Permalink to this definition">¶</a></dt> -<dd><p>Acknowledge this message as being processed., -This will remove the message from the queue.</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" colspan="2">Raises MessageStateError:</th></tr> -<tr class="field"><td> </td><td class="field-body">If the message has already been -acknowledged/requeued/rejected.</td> -</tr> -</tbody> -</table> -</dd></dl> - -<dl class="attribute"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.Message.acknowledged"> -<tt class="descclassname">Connection.Channel.Message.</tt><tt class="descname">acknowledged</tt><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.Message.acknowledged" title="Permalink to this definition">¶</a></dt> -<dd><p>Set to true if the message has been acknowledged.</p> -</dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.Message.decode"> -<tt class="descclassname">Connection.Channel.Message.</tt><tt class="descname">decode</tt><big>(</big><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.Message.decode" title="Permalink to this definition">¶</a></dt> -<dd><p>Deserialize the message body, returning the original -python structure sent by the publisher.</p> -</dd></dl> - -<dl class="attribute"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.Message.payload"> -<tt class="descclassname">Connection.Channel.Message.</tt><tt class="descname">payload</tt><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.Message.payload" title="Permalink to this definition">¶</a></dt> -<dd><p>The decoded message body.</p> -</dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.Message.reject"> -<tt class="descclassname">Connection.Channel.Message.</tt><tt class="descname">reject</tt><big>(</big><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.Message.reject" title="Permalink to this definition">¶</a></dt> -<dd><p>Reject this message.</p> -<p>The message will be discarded by the server.</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" colspan="2">Raises MessageStateError:</th></tr> -<tr class="field"><td> </td><td class="field-body">If the message has already been -acknowledged/requeued/rejected.</td> -</tr> -</tbody> -</table> -</dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.Message.requeue"> -<tt class="descclassname">Connection.Channel.Message.</tt><tt class="descname">requeue</tt><big>(</big><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.Message.requeue" title="Permalink to this definition">¶</a></dt> -<dd><p>Reject this message and put it back on the queue.</p> -<p>You must not use this method as a means of selecting messages -to process.</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" colspan="2">Raises MessageStateError:</th></tr> -<tr class="field"><td> </td><td class="field-body">If the message has already been -acknowledged/requeued/rejected.</td> -</tr> -</tbody> -</table> -</dd></dl> - -</dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.Producer"> -<tt class="descclassname">Connection.Channel.</tt><tt class="descname">Producer</tt><big>(</big><em>*args</em>, <em>**kwargs</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.Producer" title="Permalink to this definition">¶</a></dt> -<dd></dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.after_reply_message_received"> -<tt class="descclassname">Connection.Channel.</tt><tt class="descname">after_reply_message_received</tt><big>(</big><em>queue</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.after_reply_message_received" title="Permalink to this definition">¶</a></dt> -<dd><p>reply queue semantics: can be used to delete the queue -after transient reply message received.</p> -</dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.basic_ack"> -<tt class="descclassname">Connection.Channel.</tt><tt class="descname">basic_ack</tt><big>(</big><em>delivery_tag</em>, <em>multiple=False</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.basic_ack" title="Permalink to this definition">¶</a></dt> -<dd></dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.basic_cancel"> -<tt class="descclassname">Connection.Channel.</tt><tt class="descname">basic_cancel</tt><big>(</big><em>consumer_tag</em>, <em>**kwargs</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.basic_cancel" title="Permalink to this definition">¶</a></dt> -<dd></dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.basic_consume"> -<tt class="descclassname">Connection.Channel.</tt><tt class="descname">basic_consume</tt><big>(</big><em>queue=''</em>, <em>consumer_tag=None</em>, <em>no_local=False</em>, <em>no_ack=False</em>, <em>exclusive=False</em>, <em>callback=None</em>, <em>nowait=False</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.basic_consume" title="Permalink to this definition">¶</a></dt> -<dd></dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.basic_get"> -<tt class="descclassname">Connection.Channel.</tt><tt class="descname">basic_get</tt><big>(</big><em>queue=''</em>, <em>noack=False</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.basic_get" title="Permalink to this definition">¶</a></dt> -<dd></dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.basic_publish"> -<tt class="descclassname">Connection.Channel.</tt><tt class="descname">basic_publish</tt><big>(</big><em>message</em>, <em>exchange=''</em>, <em>routing_key=''</em>, <em>mandatory=False</em>, <em>immediate=False</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.basic_publish" title="Permalink to this definition">¶</a></dt> -<dd></dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.basic_qos"> -<tt class="descclassname">Connection.Channel.</tt><tt class="descname">basic_qos</tt><big>(</big><em>prefetch_size=0</em>, <em>prefetch_count=0</em>, <em>_global=False</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.basic_qos" title="Permalink to this definition">¶</a></dt> -<dd></dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.basic_reject"> -<tt class="descclassname">Connection.Channel.</tt><tt class="descname">basic_reject</tt><big>(</big><em>delivery_tag</em>, <em>requeue=True</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.basic_reject" title="Permalink to this definition">¶</a></dt> -<dd></dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.close"> -<tt class="descclassname">Connection.Channel.</tt><tt class="descname">close</tt><big>(</big><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.close" title="Permalink to this definition">¶</a></dt> -<dd></dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.exchange_declare"> -<tt class="descclassname">Connection.Channel.</tt><tt class="descname">exchange_declare</tt><big>(</big><em>exchange=''</em>, <em>type='direct'</em>, <em>passive=False</em>, <em>durable=False</em>, <em>auto_delete=False</em>, <em>arguments=None</em>, <em>nowait=False</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.exchange_declare" title="Permalink to this definition">¶</a></dt> -<dd></dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.flow"> -<tt class="descclassname">Connection.Channel.</tt><tt class="descname">flow</tt><big>(</big><em>enabled</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.flow" title="Permalink to this definition">¶</a></dt> -<dd></dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.list_bindings"> -<tt class="descclassname">Connection.Channel.</tt><tt class="descname">list_bindings</tt><big>(</big><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.list_bindings" title="Permalink to this definition">¶</a></dt> -<dd></dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.message_to_python"> -<tt class="descclassname">Connection.Channel.</tt><tt class="descname">message_to_python</tt><big>(</big><em>raw_message</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.message_to_python" title="Permalink to this definition">¶</a></dt> -<dd><p>Convert encoded message body back to a Python value.</p> -</dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.prepare_message"> -<tt class="descclassname">Connection.Channel.</tt><tt class="descname">prepare_message</tt><big>(</big><em>body</em>, <em>priority=None</em>, <em>content_type=None</em>, <em>content_encoding=None</em>, <em>headers=None</em>, <em>properties=None</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.prepare_message" title="Permalink to this definition">¶</a></dt> -<dd><p>Encapsulate data into a AMQP message.</p> -</dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.queue_bind"> -<tt class="descclassname">Connection.Channel.</tt><tt class="descname">queue_bind</tt><big>(</big><em>queue=''</em>, <em>exchange=''</em>, <em>routing_key=''</em>, <em>arguments=None</em>, <em>nowait=False</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.queue_bind" title="Permalink to this definition">¶</a></dt> -<dd></dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.queue_declare"> -<tt class="descclassname">Connection.Channel.</tt><tt class="descname">queue_declare</tt><big>(</big><em>queue=''</em>, <em>passive=False</em>, <em>durable=False</em>, <em>exclusive=False</em>, <em>auto_delete=False</em>, <em>arguments=None</em>, <em>nowait=False</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.queue_declare" title="Permalink to this definition">¶</a></dt> -<dd></dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.queue_purge"> -<tt class="descclassname">Connection.Channel.</tt><tt class="descname">queue_purge</tt><big>(</big><em>queue</em>, <em>nowait=False</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.queue_purge" title="Permalink to this definition">¶</a></dt> -<dd></dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Connection.Channel.queue_unbind"> -<tt class="descclassname">Connection.Channel.</tt><tt class="descname">queue_unbind</tt><big>(</big><em>queue=''</em>, <em>exchange=''</em>, <em>binding_key=''</em>, <em>nowait=False</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.Channel.queue_unbind" title="Permalink to this definition">¶</a></dt> -<dd></dd></dl> - -</dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Connection.channel"> -<tt class="descclassname">Connection.</tt><tt class="descname">channel</tt><big>(</big><em>channel_id=None</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.channel" title="Permalink to this definition">¶</a></dt> -<dd></dd></dl> - -<dl class="attribute"> -<dt id="kombu.transport.librabbitmq.Connection.close"> -<tt class="descclassname">Connection.</tt><tt class="descname">close</tt><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.close" title="Permalink to this definition">¶</a></dt> -<dd><p>Close connection.</p> -</dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Connection.drain_events"> -<tt class="descclassname">Connection.</tt><tt class="descname">drain_events</tt><big>(</big><em>timeout=None</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Connection.drain_events" title="Permalink to this definition">¶</a></dt> -<dd></dd></dl> - -</dd></dl> - -</div> -<div class="section" id="channel"> -<h2><a class="toc-backref" href="#id3">Channel</a><a class="headerlink" href="#channel" title="Permalink to this headline">¶</a></h2> -<dl class="class"> -<dt id="kombu.transport.librabbitmq.Channel"> -<em class="property">class </em><tt class="descclassname">kombu.transport.librabbitmq.</tt><tt class="descname">Channel</tt><big>(</big><em>connection</em>, <em>channel_id</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Channel" title="Permalink to this definition">¶</a></dt> -<dd><dl class="class"> -<dt id="kombu.transport.librabbitmq.Channel.Message"> -<em class="property">class </em><tt class="descname">Message</tt><big>(</big><em>channel</em>, <em>message</em>, <em>**kwargs</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Channel.Message" title="Permalink to this definition">¶</a></dt> -<dd><p>A message received by the broker.</p> -<dl class="attribute"> -<dt id="kombu.transport.librabbitmq.Channel.Message.body"> -<tt class="descname">body</tt><a class="headerlink" href="#kombu.transport.librabbitmq.Channel.Message.body" title="Permalink to this definition">¶</a></dt> -<dd><p>The message body.</p> -</dd></dl> - -<dl class="attribute"> -<dt id="kombu.transport.librabbitmq.Channel.Message.delivery_tag"> -<tt class="descname">delivery_tag</tt><a class="headerlink" href="#kombu.transport.librabbitmq.Channel.Message.delivery_tag" title="Permalink to this definition">¶</a></dt> -<dd><p>The message delivery tag, uniquely identifying this message.</p> -</dd></dl> - -<dl class="attribute"> -<dt id="kombu.transport.librabbitmq.Channel.Message.channel"> -<tt class="descname">channel</tt><a class="headerlink" href="#kombu.transport.librabbitmq.Channel.Message.channel" title="Permalink to this definition">¶</a></dt> -<dd><p>The channel instance the message was received on.</p> -</dd></dl> - -</dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Channel.message_to_python"> -<tt class="descclassname">Channel.</tt><tt class="descname">message_to_python</tt><big>(</big><em>raw_message</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Channel.message_to_python" title="Permalink to this definition">¶</a></dt> -<dd><p>Convert encoded message body back to a Python value.</p> -</dd></dl> - -<dl class="method"> -<dt id="kombu.transport.librabbitmq.Channel.prepare_message"> -<tt class="descclassname">Channel.</tt><tt class="descname">prepare_message</tt><big>(</big><em>body</em>, <em>priority=None</em>, <em>content_type=None</em>, <em>content_encoding=None</em>, <em>headers=None</em>, <em>properties=None</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Channel.prepare_message" title="Permalink to this definition">¶</a></dt> -<dd><p>Encapsulate data into a AMQP message.</p> -</dd></dl> - -</dd></dl> - -</div> -<div class="section" id="message"> -<h2><a class="toc-backref" href="#id4">Message</a><a class="headerlink" href="#message" title="Permalink to this headline">¶</a></h2> -<dl class="class"> -<dt id="kombu.transport.librabbitmq.Message"> -<em class="property">class </em><tt class="descclassname">kombu.transport.librabbitmq.</tt><tt class="descname">Message</tt><big>(</big><em>channel</em>, <em>message</em>, <em>**kwargs</em><big>)</big><a class="headerlink" href="#kombu.transport.librabbitmq.Message" title="Permalink to this definition">¶</a></dt> -<dd><p>A message received by the broker.</p> -<dl class="attribute"> -<dt id="kombu.transport.librabbitmq.Message.body"> -<tt class="descname">body</tt><a class="headerlink" href="#kombu.transport.librabbitmq.Message.body" title="Permalink to this definition">¶</a></dt> -<dd><p>The message body.</p> -</dd></dl> - -<dl class="attribute"> -<dt id="kombu.transport.librabbitmq.Message.delivery_tag"> -<tt class="descname">delivery_tag</tt><a class="headerlink" href="#kombu.transport.librabbitmq.Message.delivery_tag" title="Permalink to this definition">¶</a></dt> -<dd><p>The message delivery tag, uniquely identifying this message.</p> -</dd></dl> - -<dl class="attribute"> -<dt id="kombu.transport.librabbitmq.Message.channel"> -<tt class="descname">channel</tt><a class="headerlink" href="#kombu.transport.librabbitmq.Message.channel" title="Permalink to this definition">¶</a></dt> -<dd><p>The channel instance the message was received on.</p> -</dd></dl> - -</dd></dl> - -</div> -</div> - + </div> </div> @@ -483,23 +61,12 @@ after transient reply message received.</p> <div class="sphinxsidebarwrapper"><p class="logo"><a href="../index.html"> <img class="logo" width="128" height="128" src="http://cloud.github.com/downloads/ask/kombu/kombusmall.jpg" alt="Logo"/> </a></p> - <h3><a href="../index.html">Table Of Contents</a></h3> - <ul> -<li><a class="reference internal" href="#">kombu.transport.librabbitmq</a><ul> -<li><a class="reference internal" href="#transport">Transport</a></li> -<li><a class="reference internal" href="#connection">Connection</a></li> -<li><a class="reference internal" href="#channel">Channel</a></li> -<li><a class="reference internal" href="#message">Message</a></li> -</ul> -</li> -</ul> - <h4>Previous topic</h4> <p class="topless"><a href="kombu.transport.pyamqplib.html" - title="previous chapter"><no title></a></p> + title="previous chapter">kombu.transport.pyamqplib</a></p> <h4>Next topic</h4> <p class="topless"><a href="kombu.transport.pypika.html" - title="next chapter"><no title></a></p> + title="next chapter">kombu.transport.pypika</a></p> <h3>This Page</h3> <ul class="this-page-menu"> <li><a href="../_sources/reference/kombu.transport.librabbitmq.txt" @@ -532,12 +99,12 @@ after transient reply message received.</p> <a href="../py-modindex.html" title="Python Module Index" >modules</a> |</li> <li class="right" > - <a href="kombu.transport.pypika.html" title="<no title>" + <a href="kombu.transport.pypika.html" title="kombu.transport.pypika" >next</a> |</li> <li class="right" > - <a href="kombu.transport.pyamqplib.html" title="<no title>" + <a href="kombu.transport.pyamqplib.html" title="kombu.transport.pyamqplib" >previous</a> |</li> - <li><a href="../index.html">Kombu v1.3.1 documentation</a> »</li> + <li><a href="../index.html">Kombu v1.3.2 documentation</a> »</li> <li><a href="index.html" >API Reference</a> »</li> </ul> </div> |