def METHOD_NAME(self):
    while True:
        try:
            self._client.connect()
            self._client.loop_start()
            logger.info("Successfully connected to MQTT broker")
            return
        except (gaierror, ValueError) as e:
            logger.error(
                "Could not connect to MQTT broker, error was: %s."
                " Unable to get results from Notus.",
                e,
            )
            return
        # ConnectionRefusedError - when mqtt declines connection
        # timeout - when address is not reachable
        # OSError - in container when address cannot be assigned
        except (ConnectionRefusedError, timeout, OSError) as e:
            logger.warning(
                "Could not connect to MQTT broker, error was: %s."
                " Trying again in 10s.",
                e,
            )
            sleep(10)