From d5fe88f0077f1ff434966799c3757dc6e402aa4a Mon Sep 17 00:00:00 2001 From: Ask Solem Date: Wed, 20 Oct 2010 15:33:02 +0200 Subject: [PATCH] add_consumer_from_dict should return queue --- kombu/compat.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/kombu/compat.py b/kombu/compat.py index 50406348..cef10af6 100644 --- a/kombu/compat.py +++ b/kombu/compat.py @@ -190,7 +190,9 @@ class _CSet(messaging.Consumer): return self.purge() def add_consumer_from_dict(self, queue, **options): - self.queues.append(entry_to_queue(queue, **options)) + queue = entry_to_queue(queue, **options) + self.queues.append(queue) + return queue def add_consumer(self, consumer): self.queues.extend(consumer.queues)