Added Consumer.revive

2010-10-25 13:27:02 +02:00 · 2010-10-25 13:27:02 +02:00 · da0972ec20
parent a59cee238c
commit da0972ec20
1 changed files with 5 additions and 0 deletions
--- a/kombu/messaging.py
+++ b/kombu/messaging.py
@ -223,6 +223,11 @@ class Consumer(object):
        if self.auto_declare:
            self.declare()

+    def revive(self, channel):
+        for queue in self.queues:
+            queue.revive(channel)
+        self.channel = channel
+
    def declare(self):
        """Declare queues, exchanges and bindings.