diff options
| -rw-r--r-- | kombu/common.py | 2 | ||||
| -rw-r--r-- | t/unit/test_common.py | 4 |
2 files changed, 3 insertions, 3 deletions
diff --git a/kombu/common.py b/kombu/common.py index affebb5a..f86e01a6 100644 --- a/kombu/common.py +++ b/kombu/common.py @@ -87,7 +87,7 @@ 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()) + queue = queue or 'bcast.{0}'.format(uuid()) return super(Broadcast, self).__init__( alias=alias or name, queue=queue, diff --git a/t/unit/test_common.py b/t/unit/test_common.py index 2a8d1e22..2cbd3d1b 100644 --- a/t/unit/test_common.py +++ b/t/unit/test_common.py @@ -80,11 +80,11 @@ class test_Broadcast: assert q.exchange.type == 'fanout' q = Broadcast('test_Broadcast', 'explicit_queue_name') - assert q.name.startswith('explicit_queue_name.') + assert q.name == 'explicit_queue_name' assert q.exchange.name == 'test_Broadcast' q2 = q(Mock()) - assert q2.name.split('.')[0] == q.name.split('.')[0] + assert q2.name == q.name class test_maybe_declare: |