diff options
author | Ask Solem <ask@celeryproject.org> | 2012-07-24 16:19:31 +0100 |
---|---|---|
committer | Ask Solem <ask@celeryproject.org> | 2012-07-24 16:19:31 +0100 |
commit | 7cde3ca517451351e5811801664cabdcfae9a0da (patch) | |
tree | 34a1dd11465197a9090b172bb80d477d529330bd | |
parent | f6c89b03e0fcb7d06aac989fc45b37fe24b362aa (diff) | |
download | kombu-7cde3ca517451351e5811801664cabdcfae9a0da.tar.gz |
Updates Changelog
-rw-r--r-- | Changelog | 68 | ||||
-rw-r--r-- | kombu/connection.py | 3 |
2 files changed, 71 insertions, 0 deletions
@@ -4,6 +4,74 @@ Change history ================ +.. _version-2.3.0: + +2.3.0 +===== +:release-date: 2012-07-24 03:50 P.M BST + +- New ``pyamqp://`` transport! + + The new :mod:`amqp` library is a fork of amqplib started with the + following goals: + + - Uses AMQP 0.9.1 instead of 0.8 + - Should support all RabbitMQ extensions + - API compatible with :mod:`librabbitmq` so that it can be used + as a pure-python replacement in environments where rabbitmq-c cannot + be compiled. + + If you start using use py-amqp instead of amqplib you can enjoy many + advantages including: + + - Heartbeat support (Issue #79 + Issue #131) + - Consumer Cancel Notifications (Issue #131) + - Publisher Confirms + + amqplib has not been updated in a long while, so maintaining our own fork + ensures that we can quickly roll out new features and fixes without + resorting to monkey patching. + + To use the py-amqp transport you must install the :mod:`amqp` library:: + + $ pip install amqp + + and change the connection URL to use the correct transport:: + + >>> conn = Connection('pyamqp://guest:guest@localhost//') + + + The ``pyamqp://`` transport will be the default fallback transport + in Kombu version 3.0, when :mod:`librabbitmq` is not installed, + and librabbitmq will also be updated to support the same features. + +- Connection now supports heartbeat argument. + + If enabled you must make sure to manually maintain heartbeats + by calling the ``Connection.heartbeat_check`` at twice the rate + of the specified heartbeat interval. + + E.g. if you have ``Connection(heartbeat=10)``, + then you must call ``Connection.heartbeat_check()`` every 5 seconds. + + if the server has not sent heartbeats at a suitable rate then + the heartbeat check method must raise an error that is listed + in ``Connection.connection_errors``. + + The attribute ``Connection.supports_heartbeats`` has been added + for the ability to inspect if a transport supports heartbeats + or not. + + Calling ``heartbeat_check`` on a transport that does + not support heartbeats results in a noop operation. + +- SQS: Fixed bug with invalid characters in queue names. + + Fix contributed by Zach Smith. + +- utils.reprcall: Fixed typo where kwargs argument was an empty tuple by + default, and not an empty dict. + .. _version-2.2.6: 2.2.6 diff --git a/kombu/connection.py b/kombu/connection.py index 9e4dcc13..911b0373 100644 --- a/kombu/connection.py +++ b/kombu/connection.py @@ -168,6 +168,9 @@ class Connection(object): def heartbeat_check(self, rate=2): """Verify that hartbeats are sent and received. + If the current transport does not support heartbeats then + this is a noop operation. + :keyword rate: Rate is how often the tick is called compared to the actual heartbeat value. E.g. if the heartbeat is set to 3 seconds, and the tick |