fix(mqtt): More .disconnect() fixes

Hypfer · Dec 19, 2021 · 322efcc · 322efcc
1 parent 82bc46b
commit 322efcc
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/backend/lib/mqtt/MqttController.js b/backend/lib/mqtt/MqttController.js
@@ -395,7 +395,8 @@ class MqttController {
 
 
         if (this.client && !this.client.disconnected) {
-            throw new Error("MQTT.js is pretending to be disconnected");
+            Logger.warn("MQTT.js is pretending to be disconnected");
+            this.client.end(true);
         }
 
         this.client = null;