Current

main.py

@@ -1,20 +1,37 @@
-import paho.mqtt.client as mqtt
+import paho.mqtt.client as mqtt
-
+import time
-
+
-def on_message(client, userdata, message):
+def on_message(client, userdata, message):
-    print(str(message.payload.decode("utf-8")))
+
-
+    lastMessage = userdata
-    client.publish("/repeat/", message.payload)
+
-
+    currentTime = time.time()
-
+    #
-mqttBroker = 'icyn30.duckdns.org'
+    print('ct - ' + str(currentTime))
-mqttPort = 1888
+    print('lm - ' + str(lastMessage))
-
+    print('dif - ' + str(currentTime - lastMessage))
-client = mqtt.Client("Notifier")
+    if currentTime - lastMessage > 15:
-
+        print(message.payload.decode())
-client.connect(mqttBroker, mqttPort)
+        client.publish("/repeat/", message.payload)
-
+        lastMessage = time.time()
-client.subscribe("/Test/test")
+        client.user_data_set(lastMessage)
-client.on_message = on_message
+
-
+    else:
-client.loop_forever()
+        print("too soon")
+        client.publish("/repeat/", "too soon test")
+        lastMessage = time.time()
+        client.user_data_set(lastMessage)
+
+
+
+mqttBroker = 'icyn30.duckdns.org'
+mqttPort = 1888
+
+client = mqtt.Client("Notifier1", userdata=time.time())
+
+client.connect(mqttBroker, mqttPort)
+
+client.subscribe("/Test/test")
+client.on_message = on_message
+
+client.loop_forever()

requirements.txt

@@ -1 +1 @@
-paho-mqtt==1.5.1
+paho-mqtt==1.5.1