From 186c51014e00ae413b0633e8f15e906c89f2f3ca Mon Sep 17 00:00:00 2001 From: Luis Linares Date: Fri, 3 Jan 2025 15:40:31 +0100 Subject: [PATCH] fix(handler): set remote_* attributes of session object on connect They seem to have been forgotten when writing init_from_connect() --- amqtt/mqtt/protocol/broker_handler.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/amqtt/mqtt/protocol/broker_handler.py b/amqtt/mqtt/protocol/broker_handler.py index f7f6c5a..25d2771 100644 --- a/amqtt/mqtt/protocol/broker_handler.py +++ b/amqtt/mqtt/protocol/broker_handler.py @@ -201,6 +201,8 @@ class BrokerProtocolHandler(ProtocolHandler): incoming_session.will_message = connect.will_message incoming_session.username = connect.username incoming_session.password = connect.password + incoming_session.remote_address = remote_address + incoming_session.remote_port = remote_port if connect.keep_alive > 0: incoming_session.keep_alive = connect.keep_alive else: