retain event messages

Dockerfile

@@ -27,5 +27,5 @@ WORKDIR ${APP_DIR}
 VOLUME ${CONF_DIR}
 
 
-CMD "python digitaltwin1.py -f ./config/config.ini" 
+CMD [ "/usr/local/bin/python", "digitaltwin1.py", "-f",  "./config/config.ini" ]
 

src/ModbusHandler.py

@@ -12,7 +12,7 @@ def modbusStart(config, processImage):
 
 def modbusHandler(config, processImage):
     modbusClient = config["modbus"]["client"]
-    modbusRefreshPeriod = config["modbus"]["scanrate"]
+    modbusRefreshPeriod = float(config["modbus"]["scanrate"])
 
 
     client = ModbusClient(modbusClient)

src/MqttCoilSubscriber.py

@@ -15,7 +15,7 @@ class MqttCoilSubscriber(AbstractMqttPublisher):
 
     def localLoop(self):
         while True:
-            sleep(self.config["analogInputPublishPeriod"])
+            sleep(float(self.config["analogInputPublishPeriod"]))
 
     def onMessage(self, topic, payload):
         logger.warning("mqtt message received: {} -> {}".format(topic, str(payload)))

src/MqttEventPublisher.py

@@ -27,7 +27,8 @@ class MqttEventPublisher(AbstractMqttPublisher):
                                        discreteInputChangeItem[1][1],
                                        discreteInputChangeItem[1][0]))
                 self.client.publish("{}/{}".format(self.config["digitalInputTopicPrefix"], str(discreteInputChangeItem[0])),
-                                    str(discreteInputChangeItem[1][0]))
+                                    str(discreteInputChangeItem[1][0]),
+                                    retain=True)
 
             for analogInputChangeItem in analogInputChangeset:
                 logger.debug("Analog input {} changed from {} to {}"
@@ -36,6 +37,7 @@ class MqttEventPublisher(AbstractMqttPublisher):
                                        analogInputChangeItem[1][0]))
                         
                 self.client.publish("{}/{}".format(self.config["analogInputEventTopicPrefix"], str(analogInputChangeItem[0])),
-                                    str(analogInputChangeItem[1][0]))
+                                    str(analogInputChangeItem[1][0]),
+                                    retain=True)
 
 

src/MqttPeriodPublisher.py

@@ -28,5 +28,5 @@ class MqttPeriodPublisher(AbstractMqttPublisher):
                 self.client.publish("{}/{}".format(self.config["analogInputPeriodicTopicPrefix"], str(analogInputItem[0])),
                                     str(analogInputItem[1]))
 
-            sleep(self.config["analogInputPublishPeriod"])
+            sleep(float(self.config["analogInputPublishPeriod"]))