diff options
| author | Omer Katz <omer.drow@gmail.com> | 2019-03-13 12:03:30 +0200 |
|---|---|---|
| committer | Omer Katz <omer.drow@gmail.com> | 2019-03-13 12:03:30 +0200 |
| commit | 4fd3ccc875d703a24d3e74b47d1f6b6cde8a3b16 (patch) | |
| tree | 0303b8fb5c1c8d363122ca90bf020ec4e6f26a75 | |
| parent | e9e1edf3966803b06a75480c372992a005b64100 (diff) | |
| download | kombu-broadcast-queues.tar.gz | |
Generate unique queues when providing a queue name instead of a queue object.broadcast-queues
| -rw-r--r-- | kombu/common.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/kombu/common.py b/kombu/common.py index affebb5a..2a6117db 100644 --- a/kombu/common.py +++ b/kombu/common.py @@ -87,7 +87,8 @@ class Broadcast(Queue): def __init__(self, name=None, queue=None, auto_delete=True, exchange=None, alias=None, **kwargs): - queue = '{0}.{1}'.format(queue or 'bcast', uuid()) + if queue is None: + queue = '{0}.{1}'.format(name or 'bcast', uuid()) return super(Broadcast, self).__init__( alias=alias or name, queue=queue, |