<SYSTEM_TASK:>
Solve the following problem using Python, implementing the functions described below, one line at a time
<END_TASK>
<USER_TASK:>
Description:
 def _on_connection_error(self, connection, error_message):
 """ Callback invoked when the connection failed to be established. Args: connection (pika.connection.SelectConnection):
 The connection that failed to open. error_message (str):
 The reason the connection couldn't be opened. """

        self._channel = None
        if isinstance(error_message, pika_errs.AMQPConnectionError):
            error_message = repr(error_message.args[0])
        _log.error(error_message)
        self.call_later(1, self.reconnect)