aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorEvgeny Zinoviev <me@ch1p.io>2021-02-15 19:56:18 +0300
committerEvgeny Zinoviev <me@ch1p.io>2021-02-15 19:56:18 +0300
commitb80d4936ce1ce434a892d361413ec9e77d2b0a79 (patch)
treeaa48b28c0557771c507dea2cf981af09121fbdfb
parent8e848d50f465f5a4aaa2a727a44c12234fe39ed1 (diff)
fix variable name
-rw-r--r--mqtt_message.py8
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")