diff options
-rwxr-xr-x | scd4x | 8 |
1 files changed, 8 insertions, 0 deletions
@@ -4,6 +4,12 @@ import json import paho.mqtt.client as mqtt +def on_connect(client, userdata, flags, rc): + print("connected") + +def on_disconnect(client, userdata, rc): + print("disconnected") + def main(): if len(sys.argv) < 3: print(len(sys.argv)) @@ -14,6 +20,8 @@ def main(): mqtthost = sys.argv[2] client = mqtt.Client() + client.on_connect = on_connect + client.on_disconnect = on_disconnect client.connect(mqtthost, 1883) pvalues = {} |