adding session in the session list of acceptor when created

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