kombu

kombu copied to clipboard

Order of the release tags is broken

2

Since version of kombu 4.5.0 the tag naming convention is changed which broke ordering of releases: ``` $ git tag -l | head -n 20 4.6.0 4.6.1 4.6.2 4.6.3 4.6.4...

matusvalo

Add must_get_event_loop

1

We'll use `must_get_event_loop` where we assume a non-`None` hub in the following code.

ikonst

[WIP] added initial redis cluster transport support code

21

working on new tests

auvipy

[second try] Fixed error when `query` dict has keyname equal to `virtual_host` on `kombu.utils.url.parse_url`

3

Due to the request for help in https://github.com/celery/celery/issues/5180 I added a test for the change proposed by @mavriq in #911 To confess, I don't really know whether this makes sense...

larsrinn

- Bugfix: when create a Queue object, can't create binding with Exchange object.

3

If i create a Queue with list of Exchange object, it will cause exception, because two bind function have incompatible parameters.

cha-messy

adding support for exclusive consumers

4

This adds support to amqp for creating an exclusive consumer. I didn't write any tests because I wanted to see if there was support for merging this. I have successfully...

plockaby

Added revive() method to kombo.simple.SimpleQueue

2

kombu.connection.Connection.ensure() calls revive on the object after a connection is re-established. This method is needed to allow SimpleQueue to withstand re-connections. kombu.entity.Queue can withstand re-connections because it has the same...

anilaratna2

Mailbox constructor got queue and reply_queue TTL and Expires options

12

New `Mailbox.__init__()` options: `queue_ttl`, `queue_expires`, `reply_queue_ttl` and `reply_queue_expires` `utils.maybe_s_to_ms` and `utils.functional.dictfilter` were copied-over from Celery implementation (from actual master)

alanjds

Connect to a random host in a multi-broker config

8

Add a feature to Kombu that allows it to connect to a random host in a list of brokers instead of always using the first node. This allows kombu to...

ginoledesma

Cache declared entities using a unique key instead of hash.

3

Also build the key for Queues using bindings so that bindings are properly declared. This is a fix for celery/kombu#396

rectalogic