fix(mqtt binding #65): correct handling of reconnections (#67)

Atos-Research-and-Innovation · May 8, 2019 · 0fa3165 · 0fa3165
1 parent 86459b9
commit 0fa3165
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/lib/bindings/mqttClient.js b/lib/bindings/mqttClient.js
@@ -58,6 +58,7 @@ class MqttClient {
         var options = {};
         options.username = this.username;
         options.password = this.password;
+        var connected = false;
 
         winston.info('Connecting to MQTT server %s with options:%s', host, JSON.stringify(options));
         this.mqttClient = mqtt.connect(
@@ -70,7 +71,10 @@ class MqttClient {
         this.mqttClient.on('message', this.listener);
         this.mqttClient.on('connect', function(object, binding) {
             winston.info('Connected to MQTT server');
-            return callback();
+            if (!connected) {
+                connected = true;
+                return callback();
+            }
         });
     }