@override Future<bool> subscribe(String topic) async { Log().debug('MQTT:: Subscribing to topic -> $topic'); client.subscribe(topic, MqttQos.atMostOnce); return true; }