diff --git a/Messaging/clientEx copy.py b/Messaging/clientEx copy.py index 38d6762..da0f213 100644 --- a/Messaging/clientEx copy.py +++ b/Messaging/clientEx copy.py @@ -14,9 +14,8 @@ def on_connect(client, userdata, flags, rc): client.subscribe('hello/test', qos=1) def on_message(client, userdata, message): - p = str(message.payload) - p = message.payload.decode('utf-8', errors="strict") - print("Received message '" + p + "' on topic '" + p = umsgpack.unpackb(message.payload) + print("Received message '" + p["message"] + "' on topic '" + message.topic + "' with QoS " + str(message.qos)) def on_disconnect(client, userdata, rc): @@ -41,7 +40,7 @@ pub = input("Enter something to publish: ") while pub != 'q': if(connected): - + pub = umsgpack.packb({"message":pub}) mqttc.publish('hello/test', pub) pub = input("Enter something to publish: ") print('Message is: ' + pub)