Kombu

======
: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:

=====
:release-date: 2014-01-13 05:30 P.M UTC
:release-by: Ask Solem

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

- Redis: Basic cancel for fanout based queues now sends a corresponding
``UNSUBSCRIBE`` command to the server.

This fixes an issue with pidbox where reply messages could be received
after the consumer was canceled, giving the ``"message to queue without
consumers"`` error.

- MongoDB: Improved connection string and options handling
(Issue 266 + Issue 120).

Contributed by Alex Koshelev.

- SQS: Limit the number of messages when receiving in batch to 10.

This is a hard limit enforced by Amazon so the sqs transport
must not exceeed this value.

Fix contributed by Eric Reynolds.

- ConsumerMixin: ``consume`` now checks heartbeat every time the
socket times out.

Contributed by Dustin J. Mitchell.

- Retry Policy: A max retries of 0 did not retry forever.

Fix contributed by Antoine Legrand.

- Simple: If passing a Queue object the simple utils will now take
default routing key from that queue.

Contributed by Fernando Jorge Mota.

- ``repr(producer)`` no longer evaluates the underlying channnel.

- Redis: The map of Redis error classes are now exposed at the module level
using the :func:`kombu.transport.redis.get_redis_error_classes` function.

- Async: ``Hub.close`` now sets ``.poller`` to None.

.. _version-3.0.8:

=====
:release-date: 2013-12-16 05:00 P.M UTC
:release-by: Ask Solem

- Serializer: loads and dumps now wraps exceptions raised into
:exc:`~kombu.exceptions.DecodeError` and
:exc:`kombu.exceptions.EncodeError` respectively.

Contributed by Ionel Cristian Maries

- Redis: Would attempt to read from the wrong connection if a select/epoll/kqueue
exception event happened.

Fix contributed by Michael Nelson.

- Redis: Disabling ack emulation now works properly.

Fix contributed by Michael Nelson.

- Redis: :exc:`IOError` and :exc:`OSError` are now treated as recoverable
connection errors.

- SQS: Improved performance by reading messages in bulk.

Contributed by Matt Wise.

- Connection Pool: Attempting to acquire from a closed pool will now
raise :class:`RuntimeError`.

.. _version-3.0.7: