code change

quickfixgo · Aug 8, 2024 · cefc34e · cefc34e
1 parent 2ccd8eb
commit cefc34e
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/acceptor.go b/acceptor.go
@@ -335,13 +335,14 @@ func (a *Acceptor) handleConnection(netConn net.Conn) {
 			a.globalLog.OnEventf("Session %v not found for incoming message: %s", sessID, msgBytes)
 			return
 		}
-		a.sessions[sessID], err = a.sessionFactory.createSession(sessID, a.storeFactory, a.settings.globalSettings.clone(), a.logFactory, a.app)
+		dynamicSession, err := a.sessionFactory.createSession(sessID, a.storeFactory, a.settings.globalSettings.clone(), a.logFactory, a.app)
 		if err != nil {
 			a.globalLog.OnEventf("Dynamic session %v failed to create: %v", sessID, err)
 			return
 		}
-		a.dynamicSessionChan <- a.sessions[sessID]
-		session = a.sessions[sessID]
+		a.sessions[sessID] = dynamicSession
+		a.dynamicSessionChan <- dynamicSession
+		session = dynamicSession
 	}
 
 	a.sessionAddr.Store(sessID, netConn.RemoteAddr())