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');
  }
}