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

export prepared

Browse Source
This commit is contained in:
Wolfgang Hottgenroth
2018-03-27 21:50:48 +02:00
parent 4f2e74bddb
commit cc930e6bbc
7 changed files with 40 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
dist/MqttDispatcher.js vendored
View File

@ -43,7 +43,7 @@ class MqttHandler {
this.mqttClient.on('message', (topic, payload, packet) => {
if (!packet.retain) {
let payloadStr = payload.toString('UTF-8');
logger.info(`Message received on topic ${topic}: ${payload}`);
// logger.info(`Message received on topic ${topic}: ${payload}`)
this.processMessage(topic, payloadStr);
}
});
@ -76,7 +76,7 @@ class MqttHandler {
// sent = this.processMessage(topic, payload)
//}
//if (! sent) {
logger.info(`External sending required: ${topic}`);
logger.info(`External sending required: ${topic} ${payload}`);
let options = { retain: true, qos: 0 };
this.mqttClient.publish(topic, payload, options);
//} else {