From e1b19b9566eb1b0ecb39f50498bf5f16a59f333d Mon Sep 17 00:00:00 2001
From: Ask Solem <ask@celeryproject.org>
Date: Mon, 18 Jul 2011 16:38:40 +0100
Subject: [PATCH] compat ConsumerSet should auto declare new queues

---
 kombu/compat.py | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/kombu/compat.py b/kombu/compat.py
index 881d7b72..1ca7bb7e 100644
--- 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):