Kombu

Latest version: v5.4.2

Safety actively analyzes 706267 Python packages for vulnerabilities to keep your Python projects secure.

Scan your dependencies

Page 25 of 29

1.5.0

Not secure
=====
:release-date: 2011-11-27 06:00 P.M GMT
:release-by: Ask Solem

* kombu.pools: Fixed a bug resulting in resources not being properly released.

This was caused by the use of ``__hash__`` to distinguish them.

* Virtual transports: Dead-letter queue is now disabled by default.

The dead-letter queue was enabled by default to help application
authors, but now that Kombu is stable it should be removed.
There are after all many cases where messages should just be dropped
when there are no queues to buffer them, and keeping them without
supporting automatic cleanup is rather considered a resource leak
than a feature.

If wanted the dead-letter queue can still be enabled, by using
the ``deadletter_queue`` transport option:

.. code-block:: pycon

>>> x = Connection('redis://',
... transport_options={'deadletter_queue': 'ae.undeliver'})

In addition, an :class:`UndeliverableWarning` is now emitted when
the dead-letter queue is enabled and a message ends up there.

Contributed by Ionel Maries Cristian.

* MongoDB transport now supports Replicasets (Issue 81).

Contributed by Ivan Metzlar.

* The ``Connection.ensure`` methods now accepts a ``max_retries`` value
of 0.

A value of 0 now means *do not retry*, which is distinct from :const:`None`
which means *retry indefinitely*.

Contributed by Dan McGee.

* SQS Transport: Now has a lowercase ``sqs`` alias, so that it can be
used with broker URLs (Issue 82).

Fix contributed by Hong Minhee

* SQS Transport: Fixes KeyError on message acknowledgments (Issue 73).

The SQS transport now uses UUID's for delivery tags, rather than
a counter.

Fix contributed by Brian Bernstein.

* SQS Transport: Unicode related fixes (Issue 82).

Fix contributed by Hong Minhee.

* Redis version check could crash because of improper handling of types
(Issue 63).

* Fixed error with `Resource.force_close_all` when resources
were not yet properly initialized (Issue 78).

.. _version-1.4.3:

1.4.3

Not secure
=====
:release-date: 2011-10-27 10:00 P.M BST
:release-by: Ask Solem

* Fixes bug in ProducerPool where too many resources would be acquired.

.. _version-1.4.2:

1.4.2

Not secure
=====
:release-date: 2011-10-26 05:00 P.M BST
:release-by: Ask Solem

* Eventio: Polling should ignore `errno.EINTR`

* SQS: str.encode did only start accepting kwargs after Py2.7.

* simple_task_queue example didn't run correctly (Issue 72).

Fix contributed by Stefan Eletzhofer.

* Empty messages would not raise an exception not able to be handled
by `on_decode_error` (Issue 72)

Fix contributed by Christophe Chauvet.

* CouchDB: Properly authenticate if user/password set (Issue 70)

Fix contributed by Rafael Duran Castaneda

* Connection.Consumer had the wrong signature.

Fix contributed by Pavel Skvazh

.. _version-1.4.1:

1.4.1

Not secure
=====
:release-date: 2011-09-26 04:00 P.M BST
:release-by: Ask Solem

* 1.4.0 broke the producer pool, resulting in new connections being
established for every acquire.


.. _version-1.4.0:

1.4.0

Not secure
=====
:release-date: 2011-09-22 05:00 P.M BST
:release-by: Ask Solem

* Adds module :mod:`kombu.mixins`.

This module contains a :class:`~kombu.mixins.ConsumerMixin` class
that can be used to easily implement a message consumer
thread that consumes messages from one or more
:class:`kombu.Consumer` instances.

* New example: :ref:`task-queue-example`

Using the ``ConsumerMixin``, default channels and
the global connection pool to demonstrate new Kombu features.

* MongoDB transport did not work with MongoDB >= 2.0 (Issue 66)

Fix contributed by James Turk.

* Redis-py version check did not account for beta identifiers
in version string.

Fix contributed by David Ziegler.

* Producer and Consumer now accepts a connection instance as the
first argument.

The connections default channel will then be used.

In addition shortcut methods has been added to Connection:

.. code-block:: pycon

>>> connection.Producer(exchange)
>>> connection.Consumer(queues=..., callbacks=...)

* Connection has aquired a ``connected`` attribute that
can be used to check if the connection instance has established
a connection.

* ``ConnectionPool.acquire_channel`` now returns the connections
default channel rather than establising a new channel that
must be manually handled.

* Added ``kombu.common.maybe_declare``

``maybe_declare(entity)`` declares an entity if it has
not previously been declared in the same process.

* :func:`kombu.compat.entry_to_queue` has been moved to :mod:`kombu.common`

* New module :mod:`kombu.clocks` now contains an implementation
of Lamports logical clock.

.. _version-1.3.5:

1.3.5

Not secure
=====
:release-date: 2011-09-16 06:00 P.M BST
:release-by: Ask Solem

* Python 3: AMQP_PROTOCOL_HEADER must be bytes, not str.

.. _version-1.3.4:

Page 25 of 29

© 2025 Safety CLI Cybersecurity Inc. All Rights Reserved.