Kombu

Latest version: v5.4.2

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

Scan your dependencies

Page 26 of 29

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:

1.3.2

Not secure
=====
:release-date: 2011-09-10 01:00 P.M BST
:release-by: Mher Movsisyan

* Broke Python 2.5 compatibility by importing ``parse_qsl`` from ``urlparse``

* Connection.default_channel is now closed when connection is revived
after connection failures.

* Pika: Channel now supports the ``connection.client`` attribute
as required by the simple interface.

* pools.set_limit now raises an exception if the limit is lower
than the previous limit.

* pools.set_limit no longer resets the pools.

.. _version-1.3.1:

1.3.1

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

* Last release broke after fork for pool reinitialization.

* Producer/Consumer now has a ``connection`` attribute,
giving access to the :class:`Connection` of the
instance.

* Pika: Channels now have access to the underlying
:class:`Connection` instance using ``channel.connection.client``.

This was previously required by the ``Simple`` classes and is now
also required by :class:`Consumer` and :class:`Producer`.

* Connection.default_channel is now closed at object revival.

* Adds kombu.clocks.LamportClock.

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

.. _version-1.3.0:

1.3.0

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

* Broker connection info can be now be specified using URLs

The broker hostname can now be given as a URL instead, of the format:

.. code-block:: text

transport://user:passwordhostname:port/virtual_host

for example the default broker is expressed as:

.. code-block:: pycon

>>> Connection('amqp://guest:guestlocalhost:5672//')

Transport defaults to amqp, and is not required.
user, password, port and virtual_host is also not mandatory and
will default to the corresponding transports default.

.. note::

Note that the path component (virtual_host) always starts with a
forward-slash. This is necessary to distinguish between the virtual
host '' (empty) and '/', which are both acceptable virtual host names.

A virtual host of '/' becomes::

.. code-block:: text

amqp://guest:guestlocalhost:5672//

and a virtual host of '' (empty) becomes:

.. code-block:: text

amqp://guest:guestlocalhost:5672/

So the leading slash in the path component is **always required**.

* Now comes with default global connection and producer pools.

The acquire a connection using the connection parameters
from a :class:`Connection`:

.. code-block:: pycon

>>> from kombu import Connection, connections
>>> connection = Connection('amqp://guest:guestlocalhost//')
>>> with connections[connection].acquire(block=True):
... do something with connection

To acquire a producer using the connection parameters
from a :class:`Connection`:

.. code-block:: pycon

>>> from kombu import Connection, producers
>>> connection = Connection('amqp://guest:guestlocalhost//')
>>> with producers[connection].acquire(block=True):
... producer.publish({'hello': 'world'}, exchange='hello')

Acquiring a producer will in turn also acquire a connection
from the associated pool in ``connections``, so you the number
of producers is bound the same limit as number of connections.

The default limit of 100 connections per connection instance
can be changed by doing:

.. code-block:: pycon

>>> from kombu import pools
>>> pools.set_limit(10)

The pool can also be forcefully closed by doing:

.. code-block:: pycon

>>> from kombu import pools
>>> pool.reset()

* SQS Transport: Persistence using SimpleDB is now disabled by default,
after reports of unstable SimpleDB connections leading to errors.

* :class:`Producer` can now be used as a context manager.

* ``Producer.__exit__`` now properly calls ``release`` instead of close.

The previous behavior would lead to a memory leak when using
the :class:`kombu.pools.ProducerPool`

* Now silences all exceptions from `import ctypes` to match behaviour
of the standard Python uuid module, and avoid passing on MemoryError
exceptions on SELinux-enabled systems (Issue 52 + Issue 53)

* ``amqp`` is now an alias to the ``amqplib`` transport.

* ``kombu.syn.detect_environment`` now returns 'default', 'eventlet', or
'gevent' depending on what monkey patches have been installed.

* Serialization registry has new attribute ``type_to_name`` so it is
possible to lookup serializater name by content type.

* Exchange argument to ``Producer.publish`` can now be an :class:`Exchange`
instance.

* ``compat.Publisher`` now supports the ``channel`` keyword argument.

* Acking a message on some transports could lead to :exc:`KeyError` being
raised (Issue 57).

* Connection pool: Connections are no long instantiated when the pool is
created, but instantiated as needed instead.

* Tests now pass on PyPy.

* ``Connection.as_uri`` now includes the password if the keyword argument
``include_password`` is set.

* Virtual transports now comes with a default ``default_connection_params``
attribute.

.. _version-1.2.1:

1.2.1

Not secure
=====
:release-date: 2011-07-29 12:52 P.M BST
:release-by: Ask Solem

* Now depends on amqplib >= 1.0.0.

* Redis: Now automatically deletes auto_delete queues at ``basic_cancel``.

* ``serialization.unregister`` added so it is possible to remove unwanted
seralizers.

* Fixes MemoryError while importing ctypes on SELinux (Issue 52).

* ``Connection.autoretry`` is a version of ``ensure`` that works
with arbitrary functions (i.e. it does not need an associated object
that implements the ``revive`` method.

Example usage:

.. code-block:: python

channel = connection.channel()
try:
ret, channel = connection.autoretry(send_messages, channel=channel)
finally:
channel.close()

* ``ConnectionPool.acquire`` no longer force establishes the connection.

The connection will be established as needed.

* ``Connection.ensure`` now supports an ``on_revive`` callback
that is applied whenever the connection is re-established.

* ``Consumer.consuming_from(queue)`` returns True if the Consumer is
consuming from ``queue``.

* ``Consumer.cancel_by_queue`` did not remove the queue from ``queues``.

* ``compat.ConsumerSet.add_queue_from_dict`` now automatically declared
the queue if ``auto_declare`` set.

.. _version-1.2.0:

Page 26 of 29

© 2024 Safety CLI Cybersecurity Inc. All Rights Reserved.