From 6118ab39d4653a3a8eac4acdbeaddb41bb53dbaa Mon Sep 17 00:00:00 2001
From: Wolfgang Hottgenroth <wolfgang@hottgenroth.net>
Date: Thu, 4 Jan 2018 22:59:08 +0100
Subject: [PATCH] do not handle retained messages

---
 src/main.js        |  4 ----
 src/mqttHandler.js | 10 ++++++----
 2 files changed, 6 insertions(+), 8 deletions(-)

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);
+        }
     });
 }