diff --git a/Messaging/clientEx copy.py b/Messaging/clientEx copy.py index d91e0c4..38d6762 100644 --- a/Messaging/clientEx copy.py +++ b/Messaging/clientEx copy.py @@ -1,7 +1,7 @@ +import umsgpack import paho.mqtt.client as mqtt import time import ssl -import umsgpack connected = False @@ -35,11 +35,13 @@ mqttc.connect('172.16.13.128', 1883, 60) mqttc.loop_start() +mqttc.will_set("hello/test", "Disconnected", ) + pub = input("Enter something to publish: ") while pub != 'q': if(connected): - + mqttc.publish('hello/test', pub) pub = input("Enter something to publish: ") print('Message is: ' + pub)