quickfix
Class ThreadedSocketAcceptor
java.lang.Object
quickfix.mina.SessionConnector
quickfix.mina.acceptor.AbstractSocketAcceptor
quickfix.ThreadedSocketAcceptor
- All Implemented Interfaces:
- Acceptor, Connector
public class ThreadedSocketAcceptor
- extends AbstractSocketAcceptor
Accepts connections and uses a separate thread per session to process messages.
Method Summary |
void |
block()
Start accepting connections. |
void |
start()
Start accepting connections. |
void |
stop()
Logout existing sessions, close their connections, and stop accepting new
connections. |
void |
stop(boolean forceDisconnect)
Stops all sessions, optionally waiting for logout completion. |
Methods inherited from class quickfix.mina.SessionConnector |
addDynamicSession, createSession, getIntSetting, getIoFilterChainBuilder, getManagedSessions, getScheduledExecutorService, getSessionMap, getSessions, getSettings, isLoggedOn, logError, logoutAllSessions, removeDynamicSession, setIoFilterChainBuilder, setSessions, startSessionTimer, stopSessionTimer, waitForLogout |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ThreadedSocketAcceptor
public ThreadedSocketAcceptor(Application application,
MessageStoreFactory messageStoreFactory,
SessionSettings settings,
LogFactory logFactory,
MessageFactory messageFactory)
throws ConfigError
- Throws:
ConfigError
ThreadedSocketAcceptor
public ThreadedSocketAcceptor(Application application,
MessageStoreFactory messageStoreFactory,
SessionSettings settings,
MessageFactory messageFactory)
throws ConfigError
- Throws:
ConfigError
ThreadedSocketAcceptor
public ThreadedSocketAcceptor(SessionFactory sessionFactory,
SessionSettings settings)
throws ConfigError
- Throws:
ConfigError
start
public void start()
throws ConfigError,
RuntimeError
- Description copied from interface:
Connector
- Start accepting connections. Returns immediately. See implementations of
this interface potential threading issues.
- Throws:
ConfigError
- Problem with acceptor configuration.
RuntimeError
- Other unspecified error
stop
public void stop()
- Description copied from interface:
Connector
- Logout existing sessions, close their connections, and stop accepting new
connections.
stop
public void stop(boolean forceDisconnect)
- Description copied from interface:
Connector
- Stops all sessions, optionally waiting for logout completion.
- Parameters:
forceDisconnect
- don't wait for logout before disconnect.
block
public void block()
throws ConfigError,
RuntimeError
- Description copied from interface:
Connector
- Start accepting connections. This method blocks until stop is called from
another thread.
- Throws:
ConfigError
- Problem with acceptor configuration.
RuntimeError
- Other unspecified error