diff --git a/lib/mqtt.js b/lib/mqtt.js index d6e5d23f7..fcbc21282 100644 --- a/lib/mqtt.js +++ b/lib/mqtt.js @@ -30,6 +30,11 @@ class MQTT { options.clientId = mqttSettings.client_id; } + if (mqttSettings.hasOwnProperty('reject_unauthorized') && !mqttSettings.reject_unauthorized) { + logger.debug(`MQTT reject_unauthorized set false, ignoring certificate warnings.`); + options.rejectUnauthorized = false; + } + this.client = mqtt.connect(mqttSettings.server, options); // Register callbacks.