From 0b7736c3bc313c03dca5b04f1df35b68c699a90b Mon Sep 17 00:00:00 2001 From: Ask Solem Date: Wed, 6 Jun 2012 14:52:02 +0100 Subject: Rendered documentation for Github Pages. --- reference/index.html | 16 +- reference/kombu.abstract.html | 12 +- reference/kombu.clocks.html | 12 +- reference/kombu.common.html | 14 +- reference/kombu.compat.html | 14 +- reference/kombu.compression.html | 12 +- reference/kombu.connection.html | 32 ++- reference/kombu.entity.html | 14 +- reference/kombu.exceptions.html | 12 +- reference/kombu.log.html | 12 +- reference/kombu.messaging.html | 12 +- reference/kombu.mixins.html | 33 +-- reference/kombu.pidbox.html | 12 +- reference/kombu.pools.html | 159 +++++++++++- reference/kombu.serialization.html | 14 +- reference/kombu.simple.html | 12 +- reference/kombu.syn.html | 12 +- reference/kombu.transport.SQS.html | 12 +- reference/kombu.transport.amqplib.html | 57 +++-- reference/kombu.transport.base.html | 12 +- reference/kombu.transport.beanstalk.html | 12 +- reference/kombu.transport.couchdb.html | 12 +- reference/kombu.transport.django.html | 12 +- ...o.management.commands.clean_kombu_messages.html | 12 +- reference/kombu.transport.django.managers.html | 12 +- reference/kombu.transport.django.models.html | 16 +- reference/kombu.transport.html | 12 +- reference/kombu.transport.librabbitmq.html | 279 ++++++++++++++++++--- reference/kombu.transport.memory.html | 14 +- reference/kombu.transport.mongodb.html | 12 +- reference/kombu.transport.pika.html | 12 +- reference/kombu.transport.pika2.html | 12 +- reference/kombu.transport.redis.html | 255 ++++++++++++++++--- reference/kombu.transport.sqlalchemy.html | 12 +- reference/kombu.transport.sqlalchemy.models.html | 12 +- reference/kombu.transport.virtual.exchange.html | 12 +- reference/kombu.transport.virtual.html | 35 ++- reference/kombu.transport.virtual.scheduling.html | 12 +- reference/kombu.utils.compat.html | 14 +- reference/kombu.utils.debug.html | 12 +- reference/kombu.utils.encoding.html | 12 +- reference/kombu.utils.finalize.html | 12 +- reference/kombu.utils.functional.html | 12 +- reference/kombu.utils.html | 14 +- reference/kombu.utils.limits.html | 12 +- 45 files changed, 949 insertions(+), 379 deletions(-) (limited to 'reference') diff --git a/reference/index.html b/reference/index.html index 117a8e81..9bcf73b5 100644 --- a/reference/index.html +++ b/reference/index.html @@ -7,7 +7,7 @@ - API Reference — Kombu 2.1.3 documentation + API Reference — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -44,7 +44,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
    • @@ -59,9 +59,9 @@ -Release:2.1 +Release:2.2 -Date:April 03, 2012 +Date:June 06, 2012 @@ -308,12 +308,12 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.abstract.html b/reference/kombu.abstract.html index 55b96a68..194e2654 100644 --- a/reference/kombu.abstract.html +++ b/reference/kombu.abstract.html @@ -7,7 +7,7 @@ - kombu.compression — Kombu 2.1.3 documentation + kombu.compression — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -174,13 +174,13 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.clocks.html b/reference/kombu.clocks.html index cfab2b52..d9e86497 100644 --- a/reference/kombu.clocks.html +++ b/reference/kombu.clocks.html @@ -7,7 +7,7 @@ - Clocks and Synchronization - kombu.clocks — Kombu 2.1.3 documentation + Clocks and Synchronization - kombu.clocks — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -191,13 +191,13 @@ the time stamp of the incoming message.

  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.common.html b/reference/kombu.common.html index 1760d93d..7f540f26 100644 --- a/reference/kombu.common.html +++ b/reference/kombu.common.html @@ -7,7 +7,7 @@ - Common Utilities - kombu.common — Kombu 2.1.3 documentation + Common Utilities - kombu.common — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -123,7 +123,7 @@ collision.

    -kombu.common.itermessages(conn, channel, queue, limit=1, timeout=None, Consumer=<class 'kombu.messaging.Consumer'>, **kwargs)
    +kombu.common.itermessages(conn, channel, queue, limit=1, timeout=None, Consumer=<class 'kombu.messaging.Consumer'>, callbacks=None, **kwargs)
    @@ -215,13 +215,13 @@ despite intermittent connection failures.

  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.compat.html b/reference/kombu.compat.html index b9cba741..9c0c632e 100644 --- a/reference/kombu.compat.html +++ b/reference/kombu.compat.html @@ -7,7 +7,7 @@ - kombu.compat — Kombu 2.1.3 documentation + kombu.compat — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -493,7 +493,7 @@ and the Message instance (a subclass of

    Replace with kombu.messaging.Consumer.

    -class kombu.compat.ConsumerSet(connection, from_dict=None, consumers=None, **kwargs)
    +class kombu.compat.ConsumerSet(connection, from_dict=None, consumers=None, channel=None, **kwargs)
    add_consumer(consumer)
    @@ -771,13 +771,13 @@ and the Message instance (a subclass of
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.compression.html b/reference/kombu.compression.html index 42aa6323..8b6eb552 100644 --- a/reference/kombu.compression.html +++ b/reference/kombu.compression.html @@ -7,7 +7,7 @@ - kombu.compression — Kombu 2.1.3 documentation + kombu.compression — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -220,13 +220,13 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.connection.html b/reference/kombu.connection.html index e24a5df2..e1fd71be 100644 --- a/reference/kombu.connection.html +++ b/reference/kombu.connection.html @@ -7,7 +7,7 @@ - kombu.connection — Kombu 2.1.3 documentation + kombu.connection — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -82,7 +82,7 @@

    Connection

    -class kombu.connection.BrokerConnection(hostname='localhost', userid=None, password=None, virtual_host=None, port=None, insist=False, ssl=False, transport=None, connect_timeout=5, transport_options=None, login_method=None, **kwargs)
    +class kombu.connection.BrokerConnection(hostname='localhost', userid=None, password=None, virtual_host=None, port=None, insist=False, ssl=False, transport=None, connect_timeout=5, transport_options=None, login_method=None, uri_prefix=None, **kwargs)

    A connection to the broker.

    @@ -197,7 +197,7 @@ Raises socket.time
    -ensure_connection(errback=None, max_retries=None, interval_start=2, interval_step=2, interval_max=30)
    +ensure_connection(errback=None, max_retries=None, interval_start=2, interval_step=2, interval_max=30, callback=None)

    Ensure we have a connection to the server.

    If not retry establishing the connection with the settings specified.

    @@ -216,6 +216,10 @@ If this limit is exceeded the connection error will be re-raised. for each retry.
  • interval_max – Maximum number of seconds to sleep between each retry.
    • +
  • callback – Optional callback that is called for every +internal iteration (1 s)
    • +
  • callback – Optional callback that is called for every +internal iteration (1 s).
    • @@ -438,11 +442,7 @@ and the limit has been exceeded.

    release(resource)
    -

    Release resource so it can be used by another thread.

    -

    The caller is responsible for discarding the object, -and to never use the resource again. A new resource must -be acquired if so needed.

    -
    +
    @@ -482,11 +482,7 @@ and the limit has been exceeded.

    release(resource)
    -

    Release resource so it can be used by another thread.

    -

    The caller is responsible for discarding the object, -and to never use the resource again. A new resource must -be acquired if so needed.

    -
    +
    @@ -553,13 +549,13 @@ be acquired if so needed.

  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.entity.html b/reference/kombu.entity.html index a7472ea6..01569c66 100644 --- a/reference/kombu.entity.html +++ b/reference/kombu.entity.html @@ -7,7 +7,7 @@ - kombu.entity — Kombu 2.1.3 documentation + kombu.entity — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -277,7 +277,7 @@ properly sets content_encoding.
    -attrs = (('name', None), ('type', None), ('arguments', None), ('durable', <type 'bool'>), ('auto_delete', <type 'bool'>), ('delivery_mode', <function <lambda> at 0x1026f8500>))
    +attrs = (('name', None), ('type', None), ('arguments', None), ('durable', <type 'bool'>), ('auto_delete', <type 'bool'>), ('delivery_mode', <function <lambda> at 0x102912a28>))
    @@ -761,13 +761,13 @@ without modifying the server state.
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.exceptions.html b/reference/kombu.exceptions.html index 6adc5ecd..0ef1f88b 100644 --- a/reference/kombu.exceptions.html +++ b/reference/kombu.exceptions.html @@ -7,7 +7,7 @@ - kombu.exceptions — Kombu 2.1.3 documentation + kombu.exceptions — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -161,13 +161,13 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.log.html b/reference/kombu.log.html index e9aaeed0..79a98a8f 100644 --- a/reference/kombu.log.html +++ b/reference/kombu.log.html @@ -7,7 +7,7 @@ - Logging - kombu.log — Kombu 2.1.3 documentation + Logging - kombu.log — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -185,13 +185,13 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.messaging.html b/reference/kombu.messaging.html index abd6f64e..ef8b4ba1 100644 --- a/reference/kombu.messaging.html +++ b/reference/kombu.messaging.html @@ -7,7 +7,7 @@ - kombu.messaging — Kombu 2.1.3 documentation + kombu.messaging — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -480,13 +480,13 @@ registered.

  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.mixins.html b/reference/kombu.mixins.html index fdfd43e3..5e6b434b 100644 --- a/reference/kombu.mixins.html +++ b/reference/kombu.mixins.html @@ -7,7 +7,7 @@ - Mixin Classes - kombu.mixins — Kombu 2.1.3 documentation + Mixin Classes - kombu.mixins — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -92,19 +92,20 @@ of 
    class Worker(ConsumerMixin):
-    task_queue = Queue("tasks", Exchange("tasks"), "tasks"))
+
    class Worker(ConsumerMixin):
+    task_queue = Queue("tasks", Exchange("tasks"), "tasks"))
 
-    def __init__(self, connection):
-        self.connection = None
+    def __init__(self, connection):
+        self.connection = None
 
-    def get_consumers(self, Consumer, channel):
-        return [Consumer(queues=[self.task_queue],
-                         callback=[self.on_task])]
+    def get_consumers(self, Consumer, channel):
+        return [Consumer(queues=[self.task_queue],
+                         callback=[self.on_task])]
 
-    def on_task(self, body, message):
-        print("Got task: %r" % (body, ))
-        message.ack()
    
+    def on_task(self, body, message):
+        print("Got task: %r" % (body, ))
+        message.ack()
+

    Additional handler methods:

    @@ -328,13 +329,13 @@ of a thread.

  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.pidbox.html b/reference/kombu.pidbox.html index 43fb1d3b..40de2ed3 100644 --- a/reference/kombu.pidbox.html +++ b/reference/kombu.pidbox.html @@ -7,7 +7,7 @@ - kombu.pidbox — Kombu 2.1.3 documentation + kombu.pidbox — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -351,13 +351,13 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.pools.html b/reference/kombu.pools.html index 2675a6c7..e5840d28 100644 --- a/reference/kombu.pools.html +++ b/reference/kombu.pools.html @@ -7,7 +7,7 @@ - General Pools - kombu.pools — Kombu 2.1.3 documentation + General Pools - kombu.pools — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -82,34 +82,167 @@
    class kombu.pools.ProducerPool(connections, *args, **kwargs)
    -
    +
    -Producer(connection)
    +class Producer(channel, exchange=None, routing_key=None, serializer=None, auto_declare=None, compression=None, on_return=None) +

    Message Producer.

    +
    +++ + + + +
    Parameters:
      +
    • channel – Connection or channel.
      • +
    • exchange – Optional default exchange.
      • +
    • routing_key – Optional default routing key.
      • +
    • serializer – Default serializer. Default is “json”.
      • +
    • compression – Default compression method. Default is no +compression.
      • +
    • auto_declare – Automatically declare the default exchange +at instantiation. Default is True.
      • +
    • on_return – Callback to call for undeliverable messages, +when the mandatory or immediate arguments to +publish() is used. This callback needs the following +signature: (exception, exchange, routing_key, message). +Note that the producer needs to drain events to use this feature.
      • +
    +
    +
    +
    +auto_declare = True
    +
    +
    +channel = None
    +
    + +
    +
    +close()
    +
    + +
    +
    +compression = None
    +
    + +
    +
    +connection
    +
    + +
    +
    +declare()
    +

    Declare the exchange.

    +

    This happens automatically at instantiation if +auto_declare is enabled.

    +
    + +
    +
    +exchange = None
    +
    + +
    +
    +maybe_declare(entity, retry=False, **retry_policy)
    +

    Declare the exchange if it hasn’t already been declared +during this session.

    +
    + +
    +
    +on_return = None
    +
    + +
    +
    +publish(body, routing_key=None, delivery_mode=None, mandatory=False, immediate=False, priority=0, content_type=None, content_encoding=None, serializer=None, headers=None, compression=None, exchange=None, retry=False, retry_policy=None, declare=[], **properties)
    +

    Publish message to the specified exchange.

    + +++ + + + +
    Parameters:
      +
    • body – Message body.
      • +
    • routing_key – Message routing key.
      • +
    • delivery_mode – See delivery_mode.
      • +
    • mandatory – Currently not supported.
      • +
    • immediate – Currently not supported.
      • +
    • priority – Message priority. A number between 0 and 9.
      • +
    • content_type – Content type. Default is auto-detect.
      • +
    • content_encoding – Content encoding. Default is auto-detect.
      • +
    • serializer – Serializer to use. Default is auto-detect.
      • +
    • compression – Compression method to use. Default is none.
      • +
    • headers – Mapping of arbitrary headers to pass along +with the message body.
      • +
    • exchange – Override the exchange. Note that this exchange +must have been declared.
      • +
    • declare – Optional list of required entities that must +have been declared before publishing the message. The entities +will be declared using maybe_declare().
      • +
    • retry – Retry publishing, or declaring entities if the +connection is lost.
      • +
    • retry_policy – Retry configuration, this is the keywords +supported by ensure().
      • +
    • **properties – Additional message properties, see AMQP spec.
      • +
    +
    +
    + +
    +
    +release()
    +
    + +
    +
    +revive(channel)
    +

    Revive the producer after connection loss.

    +
    + +
    +
    +routing_key = ''
    +
    + +
    +
    +serializer = None
    +
    + +
    +
    -create_producer()
    +ProducerPool.create_producer()
    -new()
    +ProducerPool.new()
    -prepare(p)
    +ProducerPool.prepare(p)
    -release(resource)
    +ProducerPool.release(resource)
    -setup()
    +ProducerPool.setup()
    @@ -206,13 +339,13 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.serialization.html b/reference/kombu.serialization.html index 67249a5a..e0819d4f 100644 --- a/reference/kombu.serialization.html +++ b/reference/kombu.serialization.html @@ -7,7 +7,7 @@ - kombu.serialization — Kombu 2.1.3 documentation + kombu.serialization — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -199,7 +199,7 @@ utf-8`, us-ascii, or binary.
    -kombu.serialization.registry = <kombu.serialization.SerializerRegistry object at 0x10269b250>
    +kombu.serialization.registry = <kombu.serialization.SerializerRegistry object at 0x1026a6d50>
    kombu.serialization.encode(data, serializer=default_serializer)
    @@ -308,13 +308,13 @@ requested is not available.

  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.simple.html b/reference/kombu.simple.html index 23cbb56b..599c976d 100644 --- a/reference/kombu.simple.html +++ b/reference/kombu.simple.html @@ -7,7 +7,7 @@ - kombu.simple — Kombu 2.1.3 documentation + kombu.simple — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -314,13 +314,13 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.syn.html b/reference/kombu.syn.html index 2406a792..28448efd 100644 --- a/reference/kombu.syn.html +++ b/reference/kombu.syn.html @@ -7,7 +7,7 @@ - Async Utilities - kombu.syn — Kombu 2.1.3 documentation + Async Utilities - kombu.syn — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -145,13 +145,13 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.transport.SQS.html b/reference/kombu.transport.SQS.html index 30b45045..3f6782be 100644 --- a/reference/kombu.transport.SQS.html +++ b/reference/kombu.transport.SQS.html @@ -7,7 +7,7 @@ - kombu.transport.SQS — Kombu 2.1.3 documentation + kombu.transport.SQS — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -497,13 +497,13 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.transport.amqplib.html b/reference/kombu.transport.amqplib.html index 738b56e0..611f29f8 100644 --- a/reference/kombu.transport.amqplib.html +++ b/reference/kombu.transport.amqplib.html @@ -7,7 +7,7 @@ - kombu.transport.amqplib — Kombu 2.1.3 documentation + kombu.transport.amqplib — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -95,8 +95,8 @@
    -drain_events(allowed_methods=None, timeout=None)
    -

    Wait for an event on any channel.

    +drain_events(timeout=None) +

    Wait for an event on a channel.

    @@ -104,12 +104,6 @@ read_timeout(timeout=None)
    -
    -
    -wait_multi(channels, allowed_methods=None, timeout=None)
    -

    Wait for an event on a channel.

    -
    -
    @@ -154,11 +148,36 @@

    Establish connection to the AMQP broker.

    +
    +
    +Transport.eventmap(connection)
    +
    + +
    +
    +Transport.get_manager(hostname=None, port=None, userid=None, password=None)
    +
    +
    Transport.is_alive(connection)
    +
    +
    +Transport.nb_keep_draining = True
    +
    + +
    +
    +Transport.on_poll_init(poller)
    +
    + +
    +
    +Transport.on_poll_start()
    +
    +
    Transport.verify_connection(connection)
    @@ -235,8 +254,8 @@ is the ID of the method.

    -drain_events(allowed_methods=None, timeout=None)
    -

    Wait for an event on any channel.

    +drain_events(timeout=None) +

    Wait for an event on a channel.

    @@ -251,12 +270,6 @@ is the ID of the method.

    default value of None means match any method), and dispatch to it.

    -
    -
    -wait_multi(channels, allowed_methods=None, timeout=None)
    -

    Wait for an event on a channel.

    -
    -
    @@ -377,13 +390,13 @@ default value of None means match any method), and dispatch to it.

  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.transport.base.html b/reference/kombu.transport.base.html index cefdf765..5a162919 100644 --- a/reference/kombu.transport.base.html +++ b/reference/kombu.transport.base.html @@ -7,7 +7,7 @@ - kombu.transport.base — Kombu 2.1.3 documentation + kombu.transport.base — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -318,13 +318,13 @@ python structure sent by the publisher.

  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.transport.beanstalk.html b/reference/kombu.transport.beanstalk.html index a158485f..725b0406 100644 --- a/reference/kombu.transport.beanstalk.html +++ b/reference/kombu.transport.beanstalk.html @@ -7,7 +7,7 @@ - kombu.transport.beanstalk — Kombu 2.1.3 documentation + kombu.transport.beanstalk — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -201,13 +201,13 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.transport.couchdb.html b/reference/kombu.transport.couchdb.html index d6075c67..1e982a2d 100644 --- a/reference/kombu.transport.couchdb.html +++ b/reference/kombu.transport.couchdb.html @@ -7,7 +7,7 @@ - kombu.transport.couchdb — Kombu 2.1.3 documentation + kombu.transport.couchdb — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -211,13 +211,13 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.transport.django.html b/reference/kombu.transport.django.html index 6c1a28fc..847fa121 100644 --- a/reference/kombu.transport.django.html +++ b/reference/kombu.transport.django.html @@ -7,7 +7,7 @@ - kombu.transport.django — Kombu 2.1.3 documentation + kombu.transport.django — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -187,13 +187,13 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.transport.django.management.commands.clean_kombu_messages.html b/reference/kombu.transport.django.management.commands.clean_kombu_messages.html index 1ba02159..fd8c0532 100644 --- a/reference/kombu.transport.django.management.commands.clean_kombu_messages.html +++ b/reference/kombu.transport.django.management.commands.clean_kombu_messages.html @@ -7,7 +7,7 @@ - Django Management - clean_kombu_messages — Kombu 2.1.3 documentation + Django Management - clean_kombu_messages — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -120,13 +120,13 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.transport.django.managers.html b/reference/kombu.transport.django.managers.html index b8689373..f6ae1c28 100644 --- a/reference/kombu.transport.django.managers.html +++ b/reference/kombu.transport.django.managers.html @@ -7,7 +7,7 @@ - Django Managers - kombu.transport.django.managers — Kombu 2.1.3 documentation + Django Managers - kombu.transport.django.managers — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -165,13 +165,13 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.transport.django.models.html b/reference/kombu.transport.django.models.html index e8634661..1cd37b9b 100644 --- a/reference/kombu.transport.django.models.html +++ b/reference/kombu.transport.django.models.html @@ -7,7 +7,7 @@ - Django Models - kombu.transport.django.models — Kombu 2.1.3 documentation + Django Models - kombu.transport.django.models — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -73,7 +73,7 @@
    -Message.objects = <kombu.transport.django.managers.MessageManager object at 0x1034fe090>
    +Message.objects = <kombu.transport.django.managers.MessageManager object at 0x1041d93d0>
    @@ -104,7 +104,7 @@
    -Queue.objects = <kombu.transport.django.managers.QueueManager object at 0x1034feb90>
    +Queue.objects = <kombu.transport.django.managers.QueueManager object at 0x1041d2e90>
    @@ -162,13 +162,13 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.transport.html b/reference/kombu.transport.html index bea53438..3c61bea2 100644 --- a/reference/kombu.transport.html +++ b/reference/kombu.transport.html @@ -7,7 +7,7 @@ - kombu.transport — Kombu 2.1.3 documentation + kombu.transport — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -175,13 +175,13 @@ the alias table will be consulted.

  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.transport.librabbitmq.html b/reference/kombu.transport.librabbitmq.html index 77ced493..d24229af 100644 --- a/reference/kombu.transport.librabbitmq.html +++ b/reference/kombu.transport.librabbitmq.html @@ -7,7 +7,7 @@ - kombu.transport.librabbitmq — Kombu 2.1.3 documentation + kombu.transport.librabbitmq — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -57,7 +57,7 @@

    kombu.transport.librabbitmq

    -

    pylibrabbitmq transport.

    +

    librabbitmq transport.

    @@ -87,13 +87,13 @@ class kombu.transport.librabbitmq.Transport(client, **kwargs)
    -class Connection(host='localhost', userid='guest', password='guest', virtual_host='/', port=5672, **kwargs)
    +class Connection(host='localhost', userid='guest', password='guest', virtual_host='/', port=5672, channel_max=65535, frame_max=131072, heartbeat=0, lazy=False, **kwargs)
    class Channel(connection, channel_id)
    -class Message(body, props, info, channel)
    +class Message(channel, props, info, body)
    @@ -104,11 +104,16 @@
    +
    +
    +class Transport.Connection.Message(channel, props, info, body)
    +
    +
    -Transport.channel_errors = (<class 'kombu.exceptions.StdChannelError'>, <class '_pyrabbitmq.ChannelError'>)
    +Transport.channel_errors = (<class 'kombu.exceptions.StdChannelError'>, <class '_librabbitmq.ChannelError'>)
    @@ -119,7 +124,7 @@
    -Transport.connection_errors = (<class '_pyrabbitmq.ConnectionError'>, <class 'socket.error'>, <type 'exceptions.IOError'>, <type 'exceptions.OSError'>)
    +Transport.connection_errors = (<class '_librabbitmq.ConnectionError'>, <class 'socket.error'>, <type 'exceptions.IOError'>, <type 'exceptions.OSError'>)
    @@ -148,6 +153,26 @@

    Establish connection to the AMQP broker.

    +
    +
    +Transport.eventmap(connection)
    +
    + +
    +
    +Transport.nb_keep_draining = True
    +
    + +
    +
    +Transport.on_poll_init(poller)
    +
    + +
    +
    +Transport.on_poll_start()
    +
    +
    @@ -155,7 +180,7 @@

    Connection

    -class kombu.transport.librabbitmq.Connection(host='localhost', userid='guest', password='guest', virtual_host='/', port=5672, **kwargs)
    +class kombu.transport.librabbitmq.Connection(host='localhost', userid='guest', password='guest', virtual_host='/', port=5672, channel_max=65535, frame_max=131072, heartbeat=0, lazy=False, **kwargs)
    class Channel(connection, channel_id)
    @@ -166,7 +191,7 @@
    -class Message(body, props, info, channel)
    +class Message(channel, props, info, body)
    exception MessageStateError
    @@ -330,7 +355,7 @@ after transient reply message received.

    -Connection.Channel.basic_consume(queue='', consumer_tag=None, no_local=False, no_ack=False, exclusive=False, callback=None, nowait=False)
    +Connection.Channel.basic_consume(queue='', consumer_tag=None, no_local=False, no_ack=False, exclusive=False, callback=None, arguments=None, nowait=False)
    @@ -340,7 +365,7 @@ after transient reply message received.

    -Connection.Channel.basic_publish(message, exchange='', routing_key='', mandatory=False, immediate=False)
    +Connection.Channel.basic_publish(body, exchange='', routing_key='', mandatory=False, immediate=False, **properties)
    @@ -361,7 +386,16 @@ after transient reply message received.

    Connection.Channel.exchange_declare(exchange='', type='direct', passive=False, durable=False, auto_delete=False, arguments=None, nowait=False)
    -
    +

    Declare exchange.

    +
    +++ + + + +
    Parameters:auto_delete – Not recommended and so it is ignored.
    +
    @@ -370,7 +404,7 @@ after transient reply message received.

    -Connection.Channel.flow(enabled)
    +Connection.Channel.flow(active)
    @@ -416,24 +450,171 @@ after transient reply message received.

    -Connection.Channel.queue_unbind(queue='', exchange='', binding_key='', nowait=False)
    +Connection.Channel.queue_unbind(queue='', exchange='', binding_key='', arguments=None, nowait=False) +
    + +
    +
    +Connection.Channel.recover(requeue=True)
    +
    + +
    + +
    +
    +class Connection.Message(channel, props, info, body)
    +
    +
    +exception MessageStateError
    +

    The message has already been acknowledged.

    +
    +
    +args
    +
    + +
    +
    +message
    -
    -Connection.channel(channel_id=None)
    +
    +Connection.Message.ack()
    +

    Acknowledge this message as being processed., +This will remove the message from the queue.

    + +++ + + + + +
    Raises MessageStateError:
     If the message has already been +acknowledged/requeued/rejected.
    +
    + +
    +
    +Connection.Message.ack_log_error(logger, errors)
    -
    -Connection.channel_max = 65535
    +
    +Connection.Message.acknowledged
    +

    Set to true if the message has been acknowledged.

    +
    + +
    +
    +Connection.Message.body
    -
    -Connection.channels = {}
    +
    +Connection.Message.channel
    +
    + +
    +
    +Connection.Message.content_encoding
    +
    + +
    +
    +Connection.Message.content_type
    +
    + +
    +
    +Connection.Message.decode()
    +

    Deserialize the message body, returning the original +python structure sent by the publisher.

    +
    + +
    +
    +Connection.Message.delivery_info
    +
    + +
    +
    +Connection.Message.delivery_tag
    +
    + +
    +
    +Connection.Message.headers
    +
    + +
    +
    +Connection.Message.payload
    +

    The decoded message body.

    +
    + +
    +
    +Connection.Message.properties
    +
    + +
    +
    +Connection.Message.reject()
    +

    Reject this message.

    +

    The message will be discarded by the server.

    + +++ + + + + +
    Raises MessageStateError:
     If the message has already been +acknowledged/requeued/rejected.
    +
    + +
    +
    +Connection.Message.reject_log_error(logger, errors)
    +
    + +
    +
    +Connection.Message.requeue()
    +

    Reject this message and put it back on the queue.

    +

    You must not use this method as a means of selecting messages +to process.

    + +++ + + + + +
    Raises MessageStateError:
     If the message has already been +acknowledged/requeued/rejected.
    +
    + +
    + +
    +
    +Connection.callbacks
    +
    + +
    +
    +Connection.channel(channel_id=None)
    +
    + +
    +
    +Connection.channel_max
    @@ -441,19 +622,51 @@ after transient reply message received.

    Connection.close()
    +
    +
    +Connection.connect()
    +

    Establish connection to the broker.

    +
    + +
    +
    +Connection.connected
    +
    +
    Connection.drain_events(timeout=None)
    +
    +
    +Connection.fileno()
    +

    File descriptor number.

    +
    +
    -Connection.frame_max = 131072
    +Connection.frame_max
    -Connection.heartbeat = 0
    +Connection.heartbeat +
    + +
    +
    +Connection.hostname
    +
    + +
    +
    +Connection.password
    +
    + +
    +
    +Connection.port
    @@ -461,6 +674,16 @@ after transient reply message received.

    Connection.reconnect()
    +
    +
    +Connection.userid
    +
    + +
    +
    +Connection.virtual_host
    +
    + @@ -471,7 +694,7 @@ after transient reply message received.

    class kombu.transport.librabbitmq.Channel(connection, channel_id)
    -class Message(body, props, info, channel)
    +class Message(channel, props, info, body)
    @@ -487,7 +710,7 @@ after transient reply message received.

    Message

    -class kombu.transport.librabbitmq.Message(body, props, info, channel)
    +class kombu.transport.librabbitmq.Message(channel, props, info, body)
    @@ -555,13 +778,13 @@ after transient reply message received.

  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.transport.memory.html b/reference/kombu.transport.memory.html index 8b09aadc..5088cb42 100644 --- a/reference/kombu.transport.memory.html +++ b/reference/kombu.transport.memory.html @@ -7,7 +7,7 @@ - kombu.transport.memory — Kombu 2.1.3 documentation + kombu.transport.memory — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -105,7 +105,7 @@
    -Transport.state = <kombu.transport.virtual.BrokerState object at 0x104220890>
    +Transport.state = <kombu.transport.virtual.BrokerState object at 0x104270450>

    memory backend state is global.

    @@ -197,13 +197,13 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.transport.mongodb.html b/reference/kombu.transport.mongodb.html index 5080ab85..f966bffb 100644 --- a/reference/kombu.transport.mongodb.html +++ b/reference/kombu.transport.mongodb.html @@ -7,7 +7,7 @@ - kombu.transport.mongodb — Kombu 2.1.3 documentation + kombu.transport.mongodb — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -233,13 +233,13 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.transport.pika.html b/reference/kombu.transport.pika.html index c021e102..8d96d01a 100644 --- a/reference/kombu.transport.pika.html +++ b/reference/kombu.transport.pika.html @@ -7,7 +7,7 @@ - kombu.transport.pika — Kombu 2.1.3 documentation + kombu.transport.pika — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -110,13 +110,13 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.transport.pika2.html b/reference/kombu.transport.pika2.html index d30ba686..97fbc0f0 100644 --- a/reference/kombu.transport.pika2.html +++ b/reference/kombu.transport.pika2.html @@ -7,7 +7,7 @@ - kombu.transport.pika — Kombu 2.1.3 documentation + kombu.transport.pika — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -418,13 +418,13 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.transport.redis.html b/reference/kombu.transport.redis.html index 991beed4..d9eff3fc 100644 --- a/reference/kombu.transport.redis.html +++ b/reference/kombu.transport.redis.html @@ -7,7 +7,7 @@ - kombu.transport.redis — Kombu 2.1.3 documentation + kombu.transport.redis — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -86,59 +86,149 @@
    class Channel(*args, **kwargs)
    -
    +
    +
    +class QoS(*args, **kwargs)
    +
    +
    +ack(delivery_tag)
    +
    + +
    +
    +append(message, delivery_tag)
    +
    + +
    +
    +client
    +
    + +
    +
    +reject(delivery_tag, requeue=False)
    +
    + +
    +
    +restore_at_shutdown = True
    +
    + +
    +
    +restore_by_tag(tag)
    +
    + +
    +
    +restore_unacked()
    +
    + +
    +
    +restore_visible(start=0, num=10, interval=10)
    +
    + +
    +
    +unacked_index_key
    +
    + +
    +
    +unacked_key
    +
    + +
    +
    +visibility_timeout
    +
    + +
    + +
    -active_queues
    +Transport.Channel.active_queues
    -basic_cancel(consumer_tag)
    +Transport.Channel.basic_cancel(consumer_tag)
    -basic_consume(queue, *args, **kwargs)
    +Transport.Channel.basic_consume(queue, *args, **kwargs)
    -client
    +Transport.Channel.client
    -close()
    +Transport.Channel.close() +
    + +
    +
    +Transport.Channel.from_transport_options = ('body_encoding', 'deadletter_queue', 'unacked_key', 'unacked_index_key', 'visibility_timeout', 'priority_steps')
    -get_table(exchange)
    +Transport.Channel.get_table(exchange)
    -keyprefix_queue = '_kombu.binding.%s'
    +Transport.Channel.keyprefix_queue = '_kombu.binding.%s'
    -pipeline()
    +Transport.Channel.pipeline() +
    + +
    +
    +Transport.Channel.priority(n)
    +
    + +
    +
    +Transport.Channel.priority_steps = [0, 3, 6, 9]
    -sep = '\x06\x16'
    +Transport.Channel.sep = '\x06\x16'
    -subclient
    +Transport.Channel.subclient
    -supports_fanout = True
    +Transport.Channel.supports_fanout = True +
    + +
    +
    +Transport.Channel.unacked_index_key = 'unacked_index'
    +
    + +
    +
    +Transport.Channel.unacked_key = 'unacked'
    +
    + +
    +
    +Transport.Channel.visibility_timeout = 18000
    @@ -148,6 +238,21 @@ Transport.default_port = 6379
    +
    +
    +Transport.handle_event(fileno, event)
    +
    + +
    +
    +Transport.on_poll_init(poller)
    +
    + +
    +
    +Transport.on_poll_start()
    +
    +
    Transport.polling_interval = None
    @@ -161,59 +266,149 @@
    class kombu.transport.redis.Channel(*args, **kwargs)
    -
    +
    +
    +class QoS(*args, **kwargs)
    +
    +
    +ack(delivery_tag)
    +
    + +
    +
    +append(message, delivery_tag)
    +
    + +
    +
    +client
    +
    + +
    +
    +reject(delivery_tag, requeue=False)
    +
    + +
    +
    +restore_at_shutdown = True
    +
    + +
    +
    +restore_by_tag(tag)
    +
    + +
    +
    +restore_unacked()
    +
    + +
    +
    +restore_visible(start=0, num=10, interval=10)
    +
    + +
    +
    +unacked_index_key
    +
    + +
    +
    +unacked_key
    +
    + +
    +
    +visibility_timeout
    +
    + +
    + +
    -active_queues
    +Channel.active_queues
    -basic_cancel(consumer_tag)
    +Channel.basic_cancel(consumer_tag)
    -basic_consume(queue, *args, **kwargs)
    +Channel.basic_consume(queue, *args, **kwargs)
    -client
    +Channel.client
    -close()
    +Channel.close() +
    + +
    +
    +Channel.from_transport_options = ('body_encoding', 'deadletter_queue', 'unacked_key', 'unacked_index_key', 'visibility_timeout', 'priority_steps')
    -get_table(exchange)
    +Channel.get_table(exchange)
    -keyprefix_queue = '_kombu.binding.%s'
    +Channel.keyprefix_queue = '_kombu.binding.%s'
    -pipeline()
    +Channel.pipeline() +
    + +
    +
    +Channel.priority(n)
    +
    + +
    +
    +Channel.priority_steps = [0, 3, 6, 9]
    -sep = '\x06\x16'
    +Channel.sep = '\x06\x16'
    -subclient
    +Channel.subclient
    -supports_fanout = True
    +Channel.supports_fanout = True +
    + +
    +
    +Channel.unacked_index_key = 'unacked_index'
    +
    + +
    +
    +Channel.unacked_key = 'unacked'
    +
    + +
    +
    +Channel.visibility_timeout = 18000
    @@ -281,13 +476,13 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.transport.sqlalchemy.html b/reference/kombu.transport.sqlalchemy.html index cc9a0d0f..5a9e46de 100644 --- a/reference/kombu.transport.sqlalchemy.html +++ b/reference/kombu.transport.sqlalchemy.html @@ -7,7 +7,7 @@ - kombu.transport.sqlalchemy — Kombu 2.1.3 documentation + kombu.transport.sqlalchemy — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -172,13 +172,13 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.transport.sqlalchemy.models.html b/reference/kombu.transport.sqlalchemy.models.html index b5d7cf49..635dff72 100644 --- a/reference/kombu.transport.sqlalchemy.models.html +++ b/reference/kombu.transport.sqlalchemy.models.html @@ -7,7 +7,7 @@ - Models — Kombu 2.1.3 documentation + Models — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -170,13 +170,13 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.transport.virtual.exchange.html b/reference/kombu.transport.virtual.exchange.html index 65103c6a..09ffd496 100644 --- a/reference/kombu.transport.virtual.exchange.html +++ b/reference/kombu.transport.virtual.exchange.html @@ -7,7 +7,7 @@ - kombu.transport.virtual.exchange — Kombu 2.1.3 documentation + kombu.transport.virtual.exchange — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -291,13 +291,13 @@ for bindings to this exchange.

  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.transport.virtual.html b/reference/kombu.transport.virtual.html index d861f2c4..4aa9b80e 100644 --- a/reference/kombu.transport.virtual.html +++ b/reference/kombu.transport.virtual.html @@ -7,7 +7,7 @@ - kombu.transport.virtual — Kombu 2.1.3 documentation + kombu.transport.virtual — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -99,14 +99,12 @@
    Channel = <class 'kombu.transport.virtual.Channel'>
    -

    channel class used.

    -
    +
    Cycle = <class 'kombu.transport.virtual.scheduling.FairCycle'>
    -

    cycle class used.

    -
    +
    @@ -122,7 +120,7 @@
    -state = <kombu.transport.virtual.BrokerState object at 0x103d33d50>
    +state = <kombu.transport.virtual.BrokerState object at 0x103b5f550>

    BrokerState containing declared exchanges and bindings (set by constructor).

    @@ -230,7 +228,7 @@ goes out of scope.

    -queue_declare(queue, passive=False, auto_delete=False, **kwargs)
    +queue_declare(queue, passive=False, **kwargs)

    Declare queue.

    @@ -562,6 +560,12 @@ prefetch limits.

    Remove from transactional state and requeue message.

    +
    +
    +restore_at_shutdown = True
    +

    If disabled, unacked messages won’t be restored at shutdown.

    +
    +
    restore_unacked()
    @@ -571,7 +575,7 @@ prefetch limits.

    restore_unacked_once()
    -

    Restores all uncknowledged message at shutdown/gc collect.

    +

    Restores all unacknowledged message at shutdown/gc collect.

    Will only be done once for each instance.

    @@ -589,6 +593,11 @@ prefetch limits.

    active bindings.

    +
    +
    +clear()
    +
    +
    exchanges = None
    @@ -663,13 +672,13 @@ prefetch limits.

  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.transport.virtual.scheduling.html b/reference/kombu.transport.virtual.scheduling.html index e28eaf73..9b7f0cb4 100644 --- a/reference/kombu.transport.virtual.scheduling.html +++ b/reference/kombu.transport.virtual.scheduling.html @@ -7,7 +7,7 @@ - kombu.transport.virtual.scheduling — Kombu 2.1.3 documentation + kombu.transport.virtual.scheduling — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -147,13 +147,13 @@ an equal chance to be consumed from.

  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.utils.compat.html b/reference/kombu.utils.compat.html index 172e6fd4..d8356413 100644 --- a/reference/kombu.utils.compat.html +++ b/reference/kombu.utils.compat.html @@ -7,7 +7,7 @@ - Compat. utilities - kombu.utils.compat — Kombu 2.1.3 documentation + Compat. utilities - kombu.utils.compat — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -126,7 +126,7 @@
    -pop(key, default=<object object at 0x10264acf0>)
    +pop(key, default=<object object at 0x10264fdf0>)
    @@ -221,13 +221,13 @@ order if false.

  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.utils.debug.html b/reference/kombu.utils.debug.html index c5e16a06..61a757d7 100644 --- a/reference/kombu.utils.debug.html +++ b/reference/kombu.utils.debug.html @@ -7,7 +7,7 @@ - Debugging - kombu.utils.debug — Kombu 2.1.3 documentation + Debugging - kombu.utils.debug — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -151,13 +151,13 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.utils.encoding.html b/reference/kombu.utils.encoding.html index 91a3c828..1d31248c 100644 --- a/reference/kombu.utils.encoding.html +++ b/reference/kombu.utils.encoding.html @@ -7,7 +7,7 @@ - String Encoding - kombu.utils.encoding — Kombu 2.1.3 documentation + String Encoding - kombu.utils.encoding — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -183,13 +183,13 @@ exception.

  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.utils.finalize.html b/reference/kombu.utils.finalize.html index c3a07469..abf02ee5 100644 --- a/reference/kombu.utils.finalize.html +++ b/reference/kombu.utils.finalize.html @@ -7,7 +7,7 @@ - Finalize - kombu.utils.finalize — Kombu 2.1.3 documentation + Finalize - kombu.utils.finalize — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -159,13 +159,13 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.utils.functional.html b/reference/kombu.utils.functional.html index a5e4b181..daa2c882 100644 --- a/reference/kombu.utils.functional.html +++ b/reference/kombu.utils.functional.html @@ -7,7 +7,7 @@ - kombu.utils.functional — Kombu 2.1.3 documentation + kombu.utils.functional — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -134,13 +134,13 @@ memoized (see mp
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.utils.html b/reference/kombu.utils.html index 5728c23a..013d46c8 100644 --- a/reference/kombu.utils.html +++ b/reference/kombu.utils.html @@ -7,7 +7,7 @@ - Utilities - kombu.utils — Kombu 2.1.3 documentation + Utilities - kombu.utils — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -119,7 +119,7 @@ collision.

    -kombu.utils.retry_over_time(fun, catch, args=[], kwargs={}, errback=None, max_retries=None, interval_start=2, interval_step=2, interval_max=30)
    +kombu.utils.retry_over_time(fun, catch, args=[], kwargs={}, errback=None, max_retries=None, interval_start=2, interval_step=2, interval_max=30, callback=None)

    Retry the function over and over until max retries is exceeded.

    For each retry we sleep a for a while before we try again, this interval is increased for every retry until the max seconds is reached.

    @@ -260,13 +260,13 @@ context manager.

  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file diff --git a/reference/kombu.utils.limits.html b/reference/kombu.utils.limits.html index 2be6e719..5dc32004 100644 --- a/reference/kombu.utils.limits.html +++ b/reference/kombu.utils.limits.html @@ -7,7 +7,7 @@ - Rate limiting - kombu.utils.limits — Kombu 2.1.3 documentation + Rate limiting - kombu.utils.limits — Kombu 2.2.0rc2 documentation @@ -15,7 +15,7 @@ - + @@ -45,7 +45,7 @@
  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • @@ -190,13 +190,13 @@ available.

  • previous |
    • -
  • Kombu 2.1.3 documentation »
    • +
  • Kombu 2.2.0rc2 documentation »
  • API Reference »
    • © Copyright 2009-2012, Ask Solem. - Created using Sphinx 1.1.2. + Created using Sphinx 1.1.3.
    \ No newline at end of file -- cgit v1.2.1