Kombu

======
:release-date: 2014-04-15 09:00 P.M UTC
:release-by: Ask Solem

- Now depends on :mod:`amqp` 1.4.5.

- RabbitMQ 3.3 changes QoS semantics (Issue 339).

See the RabbitMQ release notes here:
http://www.rabbitmq.com/blog/2014/04/02/breaking-things-with-rabbitmq-3-3/

A new connection property has been added that can be used to detect
whether the remote server is using this new QoS behavior:

.. code-block:: pycon

>>> Connection('amqp://').qos_behavior_matches_spec
False

so if your application depends on the old semantics you can
use this to set the ``apply_global`` flag appropriately:

.. code-block:: python

def update_prefetch_count(channel, new_value):
channel.basic_qos(
0, new_value,
not channel.connection.client.qos_behavior_matches_spec,
)

- Users of :mod:`librabbitmq` is encouraged to upgrade to librabbitmq 1.5.0.

The ``kombu[librabbitmq]`` extra has been updated to depend on this
version.

- Pools: Now takes transport options into account when comparing connections
(Issue 333).

- MongoDB: Fixes Python 3 compatibility.

- Async: select: Ignore socket errors when attempting to unregister handles
from the loop.

- Pidbox: Can now be configured to use a serializer other than json,
but specifying a serializer argument to :class:`~kombu.pidbox.Mailbox`.

Contributed by Dmitry Malinovsky.

- Message decompression now works with Python 3.

Fix contributed by Adam Gaca.

.. _version-3.0.14:

======
:release-date: 2014-03-19 07:00 P.M UTC
:release-by: Ask Solem

- **MongoDB**: Now endures a connection failover (Issue 123).

Fix contributed by Alex Koshelev.

- **MongoDB**: Fixed ``KeyError`` when a replica set member is removed.

Also fixes celery971 and celery/898.

Fix contributed by Alex Koshelev.

- **MongoDB**: Fixed MongoDB broadcast cursor re-initialization bug.

Fix contributed by Alex Koshelev.

- **Async**: Fixed bug in lax semaphore implementation where in
some usage patterns the limit was not honored correctly.

Fix contributed by Ionel Cristian Mărieș.

- **Redis**: Fixed problem with fanout when using Python 3 (Issue 324).

- **Redis**: Fixed ``AttributeError`` from attempting to close a non-existing
connection (Issue 320).

.. _version-3.0.13:

======
:release-date: 2014-03-03 04:00 P.M UTC
:release-by: Ask Solem

- Redis: Fixed serious race condition that could lead to data loss.

The delivery tags were accidentally set to be an incremental number
local to the channel, but the delivery tags need to be globally
unique so that a message can not overwrite an older message
in the backup store.

This change is not backwards incompatible and you are encouraged
to update all your system using a previous version as soon as possible.

- Now depends on :mod:`amqp` 1.4.4.

- Pidbox: Now makes sure message encoding errors are handled by default,
so that a custom error handler does not need to be specified.

- Redis: The fanout exchange can now use AMQP patterns to route and filter
messages.

This change is backwards incompatible and must be enabled with
the ``fanout_patterns`` transport option:

.. code-block:: pycon

>>> conn = kombu.Connection('redis://', transport_options={
... 'fanout_patterns': True,
... })

When enabled the exchange will work like an amqp topic exchange
if the binding key is a pattern.

This is planned to be default behavior in the future.

- Redis: Fixed ``cycle`` no such attribute error.

.. _version-3.0.12:

======
:release-date: 2014-02-09 03:50 P.M UTC
:release-by: Ask Solem

- Now depends on :mod:`amqp` 1.4.3.

- Fixes Python 3.4 logging incompatibility (Issue 311).

- Redis: Now properly handles unknown pub/sub messages.

Fix contributed by Sam Stavinoha.

- amqplib: Fixed bug where more bytes were requested from the socket
than necessary.

Fix contributed by Ionel Cristian Mărieș.

.. _version-3.0.11:

======
:release-date: 2014-02-03 05:00 P.M UTC
:release-by: Ask Solem

- Now depends on :mod:`amqp` 1.4.2.

- Now always trusts messages of type `application/data` and `application/text`
or which have an unspecified content type (Issue 306).

- Compression errors are now handled as decode errors and will trigger
the ``Consumer.on_decode_error`` callback if specified.

- New ``kombu.Connection.get_heartbeat_interval()`` method that can be
used to access the negotiated heartbeat value.

- `kombu.common.oid_for` no longer uses the MAC address of the host, but
instead uses a process-wide UUID4 as a node id.

This avoids a call to `uuid.getnode()` at module scope.

- Hub.add: Now normalizes registered fileno.

Contributed by Ionel Cristian Mărieș.

- SQS: Fixed bug where the prefetch count limit was not respected.

.. _version-3.0.10:

======
:release-date: 2014-01-17 05:40 P.M UTC
:release-by: Ask Solem

- Now depends on :mod:`amqp` 1.4.1.

- ``maybe_declare`` now raises a "recoverable connection error" if
the channel is disconnected instead of a :exc:`ChannelError` so that
the operation can be retried.

- Redis: ``Consumer.cancel()`` is now thread safe.

This fixes an issue when using gevent/eventlet and a
message is handled after the consumer is canceled resulting
in a "message for queue without consumers" error.

- Retry operations would not always respect the interval_start
value when calculating the time to sleep for (Issue 303).

Fix contributed by Antoine Legrand.

- Timer: Fixed "unhashable type" error on Python 3.

- Hub: Do not attempt to unregister operations on an already closed
poller instance.

.. _version-3.0.9: