From fb09667f564b646bf02e0cf1813b5ea2400b12f6 Mon Sep 17 00:00:00 2001 From: Fredrik Olsson Date: Mon, 9 May 2022 13:02:09 +0200 Subject: [PATCH] Making sure to handle MQTTv5 properties correctly --- main.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/main.py b/main.py index fdb3089..5c88459 100644 --- a/main.py +++ b/main.py @@ -71,7 +71,9 @@ # on-message callbacks def publish_to_source(client, userdata, message): # pylint: disable=unused-argument """Publish to source broker""" - source.publish(message.topic, message.payload, message.qos, message.retain) + source.publish( + message.topic, message.payload, message.qos, message.retain, message.properties + ) remote.on_message = publish_to_source @@ -79,7 +81,9 @@ def publish_to_source(client, userdata, message): # pylint: disable=unused-argu def publish_to_remote(client, userdata, message): # pylint: disable=unused-argument """Publish to remote broker""" - remote.publish(message.topic, message.payload, message.qos, message.retain) + remote.publish( + message.topic, message.payload, message.qos, message.retain, message.properties + ) source.on_message = publish_to_remote