From 68eb0a3d53f0f0215653832d9edad95d44694a71 Mon Sep 17 00:00:00 2001 From: Thomas Dietrich Date: Sun, 4 Nov 2018 18:00:58 +0100 Subject: [PATCH 1/2] Respect barnaclesmqtt clientOptions during connect --- lib/services/barnaclesmqtt.js | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/lib/services/barnaclesmqtt.js b/lib/services/barnaclesmqtt.js index 0543fa9..3996bfa 100644 --- a/lib/services/barnaclesmqtt.js +++ b/lib/services/barnaclesmqtt.js @@ -34,12 +34,12 @@ function BarnaclesMQTT(options) { // Establish MQTT connection self.mqtt = require('mqtt'); - self.client = self.mqtt.connect('mqtt://' + self.hostname, options); + self.client = self.mqtt.connect('mqtt://' + self.hostname, self.clientOptions); self.client.on('connect', function () { self.client.subscribe(self.topic); }); self.client.on('error', function(err) { - console.log('Error with barnacles MQTT connection: ' + err); + console.log('Error with barnacles MQTT connection: ' + err + ''); self.client.end(); }); From b1b05d94cf532aef45a5fee8d07d5b041a00c8d0 Mon Sep 17 00:00:00 2001 From: Thomas Dietrich Date: Sun, 4 Nov 2018 18:02:08 +0100 Subject: [PATCH 2/2] Fix typo --- lib/services/barnaclesmqtt.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/services/barnaclesmqtt.js b/lib/services/barnaclesmqtt.js index 3996bfa..ffdf1a6 100644 --- a/lib/services/barnaclesmqtt.js +++ b/lib/services/barnaclesmqtt.js @@ -39,7 +39,7 @@ function BarnaclesMQTT(options) { self.client.subscribe(self.topic); }); self.client.on('error', function(err) { - console.log('Error with barnacles MQTT connection: ' + err + ''); + console.log('Error with barnacles MQTT connection: ' + err); self.client.end(); });