QuickFIX/J - Update an Acceptor session during runtime

Question

I am using QuickFIX/J with Spring esanchezros/quickfixj-spring-boot-starter and I am trying to add a new session during the application runtime.

I create a Bean to initialise the ThreadSocketAcceptor then I add a SessionProvider. The application listens all the connections for FIX.4.2 sessions.

ThreadedSocketAcceptor threadedSocketAcceptor = new ThreadedSocketAcceptor(serverApplication, serverMessageStoreFactory, serverSessionSettings,
                serverLogFactory, serverMessageFactory);

SessionID anySession = new SessionID(BEGINSTRING_FIX42, WILDCARD, WILDCARD);

threadedSocketAcceptor.setSessionProvider(
                        new InetSocketAddress("0.0.0.0", 9878),
                        new DynamicAcceptorSessionProvider(serverSessionSettings, anySession, serverApplication, serverMessageStoreFactory,
                                serverLogFactory, serverMessageFactory)
                );

The application is running and during the runtime, I build the session settings and add the dynamic session

DefaultSessionFactory defaultSessionFactory = new DefaultSessionFactory(serverApplication, serverMessageStoreFactory, serverLogFactory, serverMessageFactory);
                SessionSettings sessionSettings = buildSessionSettings(session.get(), sessionID);
                Session quickfixSession = defaultSessionFactory.create(sessionID, sessionSettings);
                threadedSocketAcceptor.addDynamicSession(quickfixSession);

OnLogon, I send a query to my database to know if the session is stored in my own table. If it is not present, I log out the session.

[4.] Update the session settings : removeDynamicSession (with logout and close) then addDynamicSession.

Is it the good way to proceed? Because, I can't update the settings for my session.

Do you mean to add a session that is not known in your settings file? Otherwise I would do it like this: https://stackoverflow.com/a/61623972/4962355 Of course it could be that quickfixj-spring-boot-starter handles things a little differently, I don't know to be honest. — Christoph John, Jun 03 '22 at 08:29
I would like to add session during runtime. I did not know it before launching the application. — b-user, Jun 03 '22 at 08:35
OK, what means "can't update the settings for my session"? What happens if a counterparty tries to connect? — Christoph John, Jun 03 '22 at 08:41
There is a new session in the fix engine. I call removeDynamicSession (with logout and close) then I build new session settings with a new start time for example and I call addDynamicSession method. The problem is that the session has still the previous start time. — b-user, Jun 03 '22 at 08:52
OK, I'll add an answer with an ugly way to do it. Never got around to implement it cleaner since there was no need to do it. ;) — Christoph John, Jun 03 '22 at 08:54

score 1 · Answer 1 · answered Jun 03 '22 at 09:03

One (very) ugly way to do it is this:

Logout(), disconnect() and close() the old session.

Remove the dynamic session and clean up the old session settings:

    sessionConnector.removeDynamicSession( sessionID );
    try {
        Dictionary dictionary = sessionConnector.getSettings().get( sessionID );
        Map<Object, Object> map = dictionary.toMap();
        Set<Object> keySet = map.keySet();
        for ( Object object : keySet ) {
            sessionConnector.getSettings().removeSetting( sessionID, object.toString() );
        }
    } catch ( ConfigError e ) {
        // ignore
    }

Then add the new session settings:

    acceptor.getSettings().set( sessionID, newSessionSettings );

Then add the new session:

    Class<?> clazz = acceptor.getClass().getSuperclass().getSuperclass();
    Method createSessionMethod = clazz.getDeclaredMethod( "createSession", SessionID.class );
    createSessionMethod.setAccessible( true );
    Session newSession = ( Session )createSessionMethod.invoke( acceptor, sessionID );
    acceptor.addDynamicSession( newSession );

Hope that works for you. For me it did. ;)

QuickFIX/J - Update an Acceptor session during runtime

1 Answers1