def on_closed(self, connection, reply_code, reply_text, callback=None):
        self._channel = None
        logging.warning('Connection closed, reopening in 5 seconds: (%s) %s',
                        reply_code, reply_text)
        connection.add_timeout(5, partial(self.connect, callback=callback))
This method is invoked by pika when the connection to RabbitMQ is
dataset/ETHPy150Open mher/tornado-celery/tcelery/connection.py/Connection.on_closed