async def METHOD_NAME(self):
    _LOGGER.info("Connecting1")
    client = mqtt.Client()
    client.on_connect = self.on_connect
    client.on_message = self.on_message
    if self._config["username"] is not None:
        client.username_pw_set(
            self._config["username"], password=self._config["password"]
        )
    client.connect_async(
        self._config["ip_address"], self._config["port"], 60
    )
    client.loop_start()
    _LOGGER.info(client)