--- core/src/main/java/quickfix/mina/initiator/AbstractSocketInitiator.java (original) +++ core/src/main/java/quickfix/mina/initiator/AbstractSocketInitiator.java @@ -71,17 +71,21 @@ protected AbstractSocketInitiator(SessionSettings settings, SessionFactory sessionFactory) throws ConfigError { super(settings, sessionFactory); - //try { + try { +// ry 2010-09-13: What the heck are the two ByteBuffer statements doing here? This s.b. static initialization. ByteBuffer.setAllocator(new SimpleByteBufferAllocator()); ByteBuffer.setUseDirectBuffers(false); -// } catch (FieldConvertError e) { -// throw new ConfigError(e); -// } +// ry 2010-09-13: Restore createSessions() to its old spot. + createSessions(); + } catch (FieldConvertError e) { + throw new ConfigError(e); + } } protected void createSessionInitiators(EventHandlingStrategy eventHandlingStrategy) throws ConfigError { try { - createSessions(); +// ry 2010-09-13: Restore createSessions() to its old spot. +// createSessions(); for (Session session : getSessionMap().values()) { SessionID sessionID = session.getSessionID(); int reconnectingInterval = getReconnectIntervalInSeconds(sessionID); --- core/src/main/java/quickfix/ThreadedSocketInitiator.java (original) +++ core/src/main/java/quickfix/ThreadedSocketInitiator.java @@ -48,6 +48,10 @@ public void start() throws ConfigError, RuntimeError { createSessionInitiators(eventHandlingStrategy); +// ry 2010-09-13: Restore createSessions() to its old spot, also impacts here. + for (Session session : getSessionMap().values()) { + Session.registerSession(session); + } startInitiators(); }