diff options
| -rw-r--r-- | mqtt_message.py | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/mqtt_message.py b/mqtt_message.py index 846c823..6efbd83 100644 --- a/mqtt_message.py +++ b/mqtt_message.py @@ -265,9 +265,9 @@ def tcp_message(flow: tcp.TCPFlow): ctx.log.info(log_message) # This way we can save topics - # if mqtt_message.packet_type == mqtt_message.PUBLISH: + # if mqtt_packet.packet_type == mqtt_packet.PUBLISH: # with open("topics.txt", "a") as f: - # f.write(f"{mqtt_message.topic_name}\n") - # elif mqtt_message.packet_type == mqtt_message.SUBSCRIBE: + # f.write(f"{mqtt_packet.topic_name}\n") + # elif mqtt_packet.packet_type == mqtt_packet.SUBSCRIBE: # with open("topics.txt", "a") as f: - # f.write(f"{mqtt_message.topic_filters}\n") + # f.write(f"{mqtt_packet.topic_filters}\n") |