'Revive consumer after connection loss.'

def revive(self, channel):

    self._active_tags.clear()
    channel = self.channel = maybe_channel(channel)
    for (qname, queue) in list(items(self._queues)):
        self._queues.pop(qname, None)
        queue = self._queues[queue.name] = queue(self.channel)
        queue.revive(channel)
    if self.auto_declare:
        self.declare()
    if (self.prefetch_count is not None):
        self.qos(prefetch_count=self.prefetch_count)
