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