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.