Revize 92a4128a

Re #8489 - (basic) MQTTSubscriber

aswi2021vochomurka/service/subscriber.py

@@ +1 @@
+import paho.mqtt.client as mqtt
+
+
+class MQTTSubscriber:
+
+    # 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))
+        # Subscribing in on_connect() means that if we lose the connection and
+        # reconnect then subscriptions will be renewed.
+        client.subscribe("#")
+
+    # The callback for when a PUBLISH message is received from the server.
+    def on_message(self, client, userdata, message):
+        print(message.topic + " " + str(message.payload.decode("utf-8")))
+
+    def start(self):
+        client = mqtt.Client()
+        client.on_connect = self.on_connect
+        client.on_message = self.on_message
+
+        client.connect("localhost", 1883, 60)
+
+        # Blocking call that processes network traffic, dispatches callbacks and
+        # handles reconnecting.
+        # Other loop*() functions are available that give a threaded interface and a
+        # manual interface.
+        client.loop_forever()