From da0972ec2003a5c9d59f39216ce4445a66a9708d Mon Sep 17 00:00:00 2001
From: Ask Solem <askh@opera.com>
Date: Mon, 25 Oct 2010 13:27:02 +0200
Subject: [PATCH] Added Consumer.revive

---
 kombu/messaging.py | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/kombu/messaging.py b/kombu/messaging.py
index b3db5c17..88c4d49c 100644
--- 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.