From 1c8a3a2093de5586e2627e5e4bbb508fee8d7eee Mon Sep 17 00:00:00 2001 From: Wolfgang Ludger Hottgenroth Date: Tue, 24 Aug 2021 13:33:52 +0200 Subject: [PATCH] retain event messages --- src/MqttEventPublisher.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/MqttEventPublisher.py b/src/MqttEventPublisher.py index 84300f9..eaf6075 100644 --- a/src/MqttEventPublisher.py +++ b/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)