Merge pull request #8 from MO-RISE/properties_handling

Making sure to handle MQTTv5 properties correctly
MO-RISE · May 9, 2022 · 18e2233 · 18e2233
2 parents 8367448 + fb09667
commit 18e2233
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/main.py b/main.py
@@ -71,15 +71,19 @@
 # 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
 
 
 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