diff --git a/src/main.js b/src/main.js index 237257c..ca4ba39 100644 --- a/src/main.js +++ b/src/main.js @@ -1,10 +1,6 @@ let logger = require('./log'); let mqtt = require('./mqttHandler'); - -logger.info("Hello world!"); - - let HomematicDimmerItemClass = require('./HomematicDimmerItem'); let HomematicSwitchItemClass = require('./HomematicSwitchItem'); let M433SwitchItem = require('./M433SwitchItem'); diff --git a/src/mqttHandler.js b/src/mqttHandler.js index bc71e74..46ddbd0 100644 --- a/src/mqttHandler.js +++ b/src/mqttHandler.js @@ -24,10 +24,12 @@ function start() { }); logger.info('mqtt connection established'); }); - client.on('message', (topic, payload) => { - payload = payload.toString('UTF-8'); - logger.info(`message received on topic ${topic}: ${payload}`); - processMessage(topic, payload); + client.on('message', (topic, payload, packet) => { + if (! packet.retain) { + payload = payload.toString('UTF-8'); + logger.info(`message received on topic ${topic}: ${payload}`); + processMessage(topic, payload); + } }); }