compat ConsumerSet should auto declare new queues

2011-07-18 16:38:40 +01:00 · 2011-07-18 16:38:40 +01:00 · e1b19b9566
parent f4fea5d27c
commit e1b19b9566
1 changed files with 4 additions and 2 deletions
--- a/kombu/compat.py
+++ b/kombu/compat.py
@ -234,8 +234,10 @@ class ConsumerSet(messaging.Consumer):
        return self.purge()

    def add_consumer_from_dict(self, queue, **options):
-        queue = entry_to_queue(queue, **options)
-        self.queues.append(queue(self.channel))
+        queue = entry_to_queue(queue, **options)(self.channel)
+        if self.auto_declare:
+            queue.declare()
+        self.queues.append(queue)
        return queue

    def add_consumer(self, consumer):