wn/dispatcher_ng
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix in mqtt clientId

Browse Source
This commit is contained in:
Wolfgang Hottgenroth
2018-05-16 16:41:03 +02:00
parent 7e78a5724b
commit d4636f550c
3 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
dispatcher_ng.conf
View File

@ -1,5 +1,5 @@
{ {
"brokerUrl": "mqtt://127.0.0.1:1883", "brokerUrl": "mqtt://172.16.2.16:1883",
"brokerUser": "", "brokerUser": "",
"brokerPass": "", "brokerPass": "",
"brokerCa": "", "brokerCa": "",

1
dist/MqttDispatcher.js vendored
View File

@ -8,6 +8,7 @@ class MqttHandler {
constructor() { constructor() {
this.mqttOptions = {}; this.mqttOptions = {};
this.mqttBrokerUrl = config.dict.brokerUrl; this.mqttBrokerUrl = config.dict.brokerUrl;
this.mqttOptions.clientId = 'dispatcher';
if (config.dict.brokerUser && config.dict.brokerPass) { if (config.dict.brokerUser && config.dict.brokerPass) {
this.mqttOptions.username = config.dict.brokerUser; this.mqttOptions.username = config.dict.brokerUser;
this.mqttOptions.password = config.dict.brokerPass; this.mqttOptions.password = config.dict.brokerPass;

1
src/MqttDispatcher.ts
View File

@ -25,6 +25,7 @@ class MqttHandler {
constructor() { constructor() {
this.mqttBrokerUrl = config.dict.brokerUrl this.mqttBrokerUrl = config.dict.brokerUrl
this.mqttOptions.clientId = 'dispatcher'
if (config.dict.brokerUser && config.dict.brokerPass) { if (config.dict.brokerUser && config.dict.brokerPass) {
this.mqttOptions.username = config.dict.brokerUser this.mqttOptions.username = config.dict.brokerUser
this.mqttOptions.password = config.dict.brokerPass this.mqttOptions.password = config.dict.brokerPass