docs: def on_connection_open_error(self, connection, error):
          """Invoked if the connection to RabbitMQ can not be made.
  
          :type connection: pika.TornadoConnection
          :param Exception error: The exception indicating failure
  
          """
          LOGGER.critical('Could not connect to RabbitMQ (%s): %r',
                          connection, error)
          self.state = self.STATE_CLOSED
          self._reconnect()