Kombu

Latest version: v5.5.2

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

Scan your dependencies

Page 26 of 30

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:

1.3.4

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

* Fixes syntax error in pools.reset


.. _version-1.3.3:

1.3.3

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

* pools.reset did not support after forker arguments.

.. _version-1.3.2:

Page 26 of 30

© 2025 Safety CLI Cybersecurity Inc. All Rights Reserved.