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