onConnected method
void
onConnected()
The successful connect callback
Implementation
void onConnected() {
if (_allowPrintLog) print('MQTT::Mosquitto client connected....');
_subscription?.cancel();
_subscription = null;
_subscription =
client!.updates!.listen((List<MqttReceivedMessage<MqttMessage?>>? c) {
// ignore: avoid_as
final MqttPublishMessage recMess = c![0].payload as MqttPublishMessage;
// final MqttPublishMessage recMess = c![0].payload;
final String payload =
MqttPublishPayload.bytesToStringAsString(recMess.payload.message);
if (_allowPrintLog) {
print(
'MQTT::Change notification:: topic is <${c[0].topic}>, payload is <-- $payload -->');
}
if (onMQTTMessage != null) onMQTTMessage!(c[0].topic, payload);
// AppUtils.toast(payload);
});
if (onMQTTConnected != null) onMQTTConnected!(false);
if (_allowPrintLog) {
print(
'MQTT::OnConnected client callback - Client connection was sucessful');
}
}