onConnected method

void onConnected()

The successful connect callback

Implementation

void onConnected() {
  appDebugPrint('MQTT::Mosquitto client connected....');
  _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);
    appDebugPrint(
        '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);
  appDebugPrint(
      'MQTT::OnConnected client callback - Client connection was sucessful');
}