diff options
author | Evgeny Zinoviev <me@ch1p.io> | 2021-02-15 19:56:18 +0300 |
---|---|---|
committer | Evgeny Zinoviev <me@ch1p.io> | 2021-02-15 19:56:18 +0300 |
commit | b80d4936ce1ce434a892d361413ec9e77d2b0a79 (patch) | |
tree | aa48b28c0557771c507dea2cf981af09121fbdfb | |
parent | 8e848d50f465f5a4aaa2a727a44c12234fe39ed1 (diff) |
fix variable name
-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") |