wn/opcua-with-python
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

thread names added

Browse Source
This commit is contained in:
Wolfgang Hottgenroth 2022-03-03 17:16:52 +01:00
parent 695594fd1c
commit 72f9d97402
2 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/MqttPublish.py
View File

@ -11,6 +11,7 @@ LOOP_SLICE = 0.1 # seconds
class MqttPublish(AbstractMqttPublisher): class MqttPublish(AbstractMqttPublisher):
def __init__(self, config, stats, queue): def __init__(self, config, stats, queue):
super().__init__(config) super().__init__(config)
self.name = 'mqtt'
self.queue = queue self.queue = queue
self.stats = stats self.stats = stats
self.topicPre = self.config["publishTopicPrefix"] self.topicPre = self.config["publishTopicPrefix"]

1
src/Statistics.py
View File

@ -18,6 +18,7 @@ class StatisticsCollector(threading.Thread):
def __init__(self, config, queue): def __init__(self, config, queue):
super().__init__() super().__init__()
self.name = 'stats'
self.config = config['stats'] self.config = config['stats']
self.period = self.config['period'] self.period = self.config['period']
self.topic = self.config['topic'] self.topic = self.config['topic']