diff --git a/replit_river/server_transport.py b/replit_river/server_transport.py
index 82a7dd0..81c8119 100644
--- a/replit_river/server_transport.py
+++ b/replit_river/server_transport.py
@@ -93,8 +93,8 @@ async def establish_session(
                 error_msg = "Got invalid transport message, closing connection"
                 raise InvalidTransportMessageException(error_msg)
             logging.debug("handshake success on server: %r", handshake_request)
-            transport_id = msg.from_
-            to_id = msg.to
+            transport_id = msg.to
+            to_id = msg.from_
             instance_id = handshake_request.instanceId
             try:
                 session = await self.get_or_create_session(