def _received_data(self, message):
        # type: (str) -> None
        try:
            if self._connection is not None:
                self._connection.sendall(bytearray(message.rstrip().encode()) + bytearray(b'\n'))
        except Exception:
            logger.exception('Exception forwarding maintenance data to socket connection.')
        for consumer_id in self._consumers.keys():
            callback = self._consumers.get(consumer_id)
            if callback is None:
                continue
            try:
                callback(message.rstrip())
            except Exception:
                logger.exception('Exception forwarding maintenance data to consumer %s', str(consumer_id))