Add debug statement
This commit is contained in:
@@ -26,6 +26,7 @@ class MQTTForwarder:
|
|||||||
print(f"An error occurred while forwarding from {src_topic} to {dst_topic}: {e}")
|
print(f"An error occurred while forwarding from {src_topic} to {dst_topic}: {e}")
|
||||||
|
|
||||||
def __wrap_data(self, msg : str):
|
def __wrap_data(self, msg : str):
|
||||||
|
print(msg)
|
||||||
result = {}
|
result = {}
|
||||||
data = json.loads(msg)
|
data = json.loads(msg)
|
||||||
result["timestamp"] = int(time.time())
|
result["timestamp"] = int(time.time())
|
||||||
|
|||||||
Reference in New Issue
Block a user