From aad115f7b0240bc3b7ae5511809d9ab5bb6bdd75 Mon Sep 17 00:00:00 2001
From: Wolfgang Hottgenroth <wolfgang.hottgenroth@icloud.com>
Date: Mon, 9 Apr 2018 15:56:46 +0200
Subject: [PATCH] evaluate retained messages too

---
 src/MqttDispatcher.ts | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/MqttDispatcher.ts b/src/MqttDispatcher.ts
index 3801f98..8746699 100644
--- a/src/MqttDispatcher.ts
+++ b/src/MqttDispatcher.ts
@@ -70,11 +70,11 @@ class MqttHandler {
             })
         })
         this.mqttClient.on('message', (topic: string, payload: Buffer, packet : Mqtt.IPublishPacket): void => {
-            if (! packet.retain) {
+            // if (! packet.retain) {
                 let payloadStr : string = payload.toString('UTF-8')
                 // logger.info(`Message received on topic ${topic}: ${payload}`)
                 this.processMessage(topic, payloadStr)
-            }
+            // }
         })
     }