initializeMQTTClient method

void initializeMQTTClient()

Implementation

void initializeMQTTClient() {
  _client = MqttBrowserClient(_host, _identifier)
    ..setProtocolV311()
    ..autoReconnect = true
    ..port = _port
    ..keepAlivePeriod = 200
    ..websocketProtocols = MqttClientConstants.protocolsSingleDefault
    ..logging(on: true)

    /// Add the successful connection callback
    ..onConnected = onConnected
    ..onDisconnected = onDisconnected
    ..onAutoReconnected = onReConnected
    ..onSubscribed = onSubscribed;

  final MqttConnectMessage connMess = MqttConnectMessage()
      .withClientIdentifier(_identifier)
      // .withWillTopic(
      //     'willtopic') // If you set this you must set a will message
      // .withWillMessage('My Will message')
      // .startClean() // Non persistent session for testing
      .withWillQos(MqttQos.atMostOnce);
  appDebugPrint('MQTT::Mosquitto client connecting....');
  _client!.connectionMessage = connMess;
}