wn/digitaltwin1
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

retain event messages

Browse Source
This commit is contained in:
Wolfgang Hottgenroth 2021-08-24 13:33:52 +02:00
parent 92aeb8efdf
commit 1c8a3a2093
Signed by: wn
GPG Key ID: 6C1E5E531E0D5D7F
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/MqttEventPublisher.py
View File

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