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: