add_consumer_from_dict should return queue

2010-10-20 15:33:02 +02:00 · 2010-10-20 15:33:02 +02:00 · d5fe88f007
parent 1372e68d17
commit d5fe88f007
1 changed files with 3 additions and 1 deletions
--- 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)