From 8a89176b2b563ad20c21eea6f31cef01c46582dc Mon Sep 17 00:00:00 2001
From: pks <pks@pks.rocks>
Date: Sun, 16 May 2021 18:23:12 +0200
Subject: restart

---
 mqtt-receiver.py | 27 ---------------------------
 1 file changed, 27 deletions(-)
 delete mode 100644 mqtt-receiver.py

(limited to 'mqtt-receiver.py')

diff --git a/mqtt-receiver.py b/mqtt-receiver.py
deleted file mode 100644
index 3d6cd8a..0000000
--- a/mqtt-receiver.py
+++ /dev/null
@@ -1,27 +0,0 @@
-import json
-import paho.mqtt.client as mqtt
-import sys
-
-
-def on_connect(client, userdata, flags, rc):
-    client.subscribe("#")  # Subscribe to all topics
-    sys.stderr.write("Connected with result code {}\n".format(rc))
-    sys.stderr.flush()
-
-
-def on_message(client, userdata, msg):
-    msg_as_str = msg.payload.decode('utf-8')
-    try:
-        print("{}\t{}\t{}".format(msg.timestamp, msg.topic, json.loads(msg_as_str)))
-        sys.stdout.flush()
-    except Exception as e:
-        sys.stderr.write("Cannot parse message: '{}'\n".format(msg_as_str))
-        sys.stderr.flush()
-
-
-if __name__ == "__main__":
-    client = mqtt.Client()
-    client.on_connect = on_connect
-    client.on_message = on_message
-    client.connect("localhost", 1883, 60)
-    client.loop_forever()
-- 
cgit v1.2.3