From d977adddab5298a1836aafca99667051a8017ae5 Mon Sep 17 00:00:00 2001 From: Michael Pivato Date: Tue, 15 Jan 2019 09:39:46 +1030 Subject: [PATCH] Updated mqtt example to work with messagepack. --- Messaging/clientEx copy.py | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) 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)