Erweiterungen

lib/tools/mqtt_core.dart

@@ -88,8 +88,10 @@ class MqttCore {
 
     _cancelTrackTimer();
 
-    if (_mqttClient != null && _mqttClient!.connectionStatus == ConnectionStateEnum.connected) {
+    if (_mqttClient != null) {
       _mqttClient!.disconnect();
+
+      _mqttClient = null;
     }
 
     connectionState = ConnectionStateEnum.notConnected;
@@ -459,6 +461,8 @@ class MqttCore {
         var brokerUriAndPortArray = bootstrapResponsePayload.broker.replaceFirst("mqtt://", "").split(":");
         _brokerUri = brokerUriAndPortArray[0];
         _brokerPort = int.parse(brokerUriAndPortArray[1]);
+        //_brokerUri = "192.168.180.27";
+        //_brokerPort = 1883;
         _clientId = bootstrapResponsePayload.id;
         _fromServerTopic = bootstrapResponsePayload.fromServer;
         _toServerTopic = bootstrapResponsePayload.toServer;