Revize 08d37139

Re #8731 - schedule task to close topics

aswi2021vochomurka/service/mqtt/mqtt_subscriber.py

@@ -2 +2 @@
 
 from aswi2021vochomurka.service.message_parser import parse_mqtt_message, ParseException
 from aswi2021vochomurka.service.subscriber import Subscriber
+from apscheduler.schedulers.background import BackgroundScheduler
 
 
 class MQTTSubscriber(Subscriber):
+    sched = BackgroundScheduler()
 
     # The callback for when the client receives a CONNACK response from the server.
     def on_connect(self, client, userdata, flags, rc, properties=None):
         print("Connected with result code " + str(rc))
         self.callback.onConnected()
+
+        # start scheduler to check closed topics
+        self.sched.add_job(self.check_closed_topics, 'interval', seconds=self.params.closeLimit)
+        self.sched.start()
+
         # Subscribing in on_connect() means that if we lose the connection and
         # reconnect then subscriptions will be renewed.
         for topic in self.params.topics:
@@ -29 +36 @@
 
     def on_disconnect(self, client, userdata, rc):
         self.callback.onDisconnected()
+        self.sched.shutdown()
+
+    def check_closed_topics(self):
+        print('checking closed topics')
+        pass
 
     def start(self):
         client = mqtt.Client()

aswi2021vochomurka/view/main_view.py

@@ -17 +17 @@
 
     params = SubscriberParams(
         ["/home/1", "/home/2"],
-        120,
+        10,
         ConnectionParams("localhost", 1883, 60),
         True
     )