diff --git a/dispatcher_ng.conf b/dispatcher_ng.conf index 92f28a9..05b43ef 100644 --- a/dispatcher_ng.conf +++ b/dispatcher_ng.conf @@ -1,5 +1,5 @@ { - "brokerUrl": "mqtt://127.0.0.1:1883", + "brokerUrl": "mqtt://172.16.2.16:1883", "brokerUser": "", "brokerPass": "", "brokerCa": "", diff --git a/dist/MqttDispatcher.js b/dist/MqttDispatcher.js index e15691b..cdbeeb5 100644 --- a/dist/MqttDispatcher.js +++ b/dist/MqttDispatcher.js @@ -8,6 +8,7 @@ class MqttHandler { constructor() { this.mqttOptions = {}; this.mqttBrokerUrl = config.dict.brokerUrl; + this.mqttOptions.clientId = 'dispatcher'; if (config.dict.brokerUser && config.dict.brokerPass) { this.mqttOptions.username = config.dict.brokerUser; this.mqttOptions.password = config.dict.brokerPass; diff --git a/src/MqttDispatcher.ts b/src/MqttDispatcher.ts index 8746699..dfc248c 100644 --- a/src/MqttDispatcher.ts +++ b/src/MqttDispatcher.ts @@ -25,6 +25,7 @@ class MqttHandler { constructor() { this.mqttBrokerUrl = config.dict.brokerUrl + this.mqttOptions.clientId = 'dispatcher' if (config.dict.brokerUser && config.dict.brokerPass) { this.mqttOptions.username = config.dict.brokerUser this.mqttOptions.password = config.dict.brokerPass