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

do not handle retained messages

Browse Source
This commit is contained in:
Wolfgang Hottgenroth
2018-01-04 22:59:08 +01:00
parent a24ae9f691
commit 6118ab39d4
2 changed files with 6 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/main.js
View File

@ -1,10 +1,6 @@
let logger = require('./log'); let logger = require('./log');
let mqtt = require('./mqttHandler'); let mqtt = require('./mqttHandler');
logger.info("Hello world!");
let HomematicDimmerItemClass = require('./HomematicDimmerItem'); let HomematicDimmerItemClass = require('./HomematicDimmerItem');
let HomematicSwitchItemClass = require('./HomematicSwitchItem'); let HomematicSwitchItemClass = require('./HomematicSwitchItem');
let M433SwitchItem = require('./M433SwitchItem'); let M433SwitchItem = require('./M433SwitchItem');

10
src/mqttHandler.js
View File

@ -24,10 +24,12 @@ function start() {
}); });
logger.info('mqtt connection established'); logger.info('mqtt connection established');
}); });
client.on('message', (topic, payload) => { client.on('message', (topic, payload, packet) => {
payload = payload.toString('UTF-8'); if (! packet.retain) {
logger.info(`message received on topic ${topic}: ${payload}`); payload = payload.toString('UTF-8');
processMessage(topic, payload); logger.info(`message received on topic ${topic}: ${payload}`);
processMessage(topic, payload);
}
}); });
} }