Add support for MQTT client ID. #148

Koenkk · Jun 26, 2018 · ecc734c · ecc734c
1 parent 8a2e907
commit ecc734c
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/lib/mqtt.js b/lib/mqtt.js
@@ -18,6 +18,11 @@ class MQTT {
             options.password = mqttSettings.password;
         }
 
+        if (mqttSettings.client_id) {
+            logger.debug(`Using MQTT client ID: '${mqttSettings.client_id}'`);
+            options.clientId = mqttSettings.client_id;
+        }
+
         this.client = mqtt.connect(mqttSettings.server, options);
 
         // Register callbacks.