From b80d4936ce1ce434a892d361413ec9e77d2b0a79 Mon Sep 17 00:00:00 2001 From: Evgeny Zinoviev Date: Mon, 15 Feb 2021 19:56:18 +0300 Subject: fix variable name --- mqtt_message.py | 8 ++++---- 1 file 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") -- cgit v1.2.3