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.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ThreadedSocketAcceptor.Builder

Field Summary

Fields inherited from class quickfix.mina.SessionConnector

DEFAULT_QUEUE_CAPACITY, log, longLivedExecutor, propertyChangeSupport, QF_SESSION, QFJ_RESET_IO_CONNECTOR, SESSIONS_PROPERTY, shortLivedExecutor

Fields inherited from interface quickfix.Acceptor

SETTING_ACCEPTOR_TEMPLATE, SETTING_SOCKET_ACCEPT_ADDRESS, SETTING_SOCKET_ACCEPT_PORT, SETTING_SOCKET_ACCEPT_PROTOCOL

Constructor Summary

Constructors

Constructor and Description
ThreadedSocketAcceptor(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, LogFactory logFactory, MessageFactory messageFactory)
ThreadedSocketAcceptor(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, LogFactory logFactory, MessageFactory messageFactory, int queueCapacity)
ThreadedSocketAcceptor(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, MessageFactory messageFactory)
ThreadedSocketAcceptor(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, MessageFactory messageFactory, int queueCapacity)
ThreadedSocketAcceptor(SessionFactory sessionFactory, SessionSettings settings)
ThreadedSocketAcceptor(SessionFactory sessionFactory, SessionSettings settings, int queueCapacity)

Method Summary

Modifier and Type	Method and Description
protected EventHandlingStrategy	getEventHandlingStrategy()
static ThreadedSocketAcceptor.Builder	newBuilder()
void	start() Start accepting connections.
void	stop(boolean forceDisconnect) Stops all sessions, optionally waiting for logout completion.

Methods inherited from class quickfix.mina.acceptor.AbstractSocketAcceptor

getAcceptorAddresses, getEndpoints, getQueueSize, setSessionProvider, startAcceptingConnections, stopAcceptingConnections

Methods inherited from class quickfix.mina.SessionConnector

addDynamicSession, addPropertyChangeListener, clearConnectorSessions, closeManagedSessionsAndDispose, createSession, getIntSetting, getIoFilterChainBuilder, getManagedSessions, getScheduledExecutorService, getSessionMap, getSessions, getSettings, isContinueInitOnError, isLoggedOn, logError, logoutAllSessions, removeDynamicSession, removePropertyChangeListener, setExecutorFactory, setIoFilterChainBuilder, setSessions, startSessionTimer, stopSessionTimer, waitForLogout

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface quickfix.Connector

getSessions, isLoggedOn, stop

Constructor Detail

ThreadedSocketAcceptor

public ThreadedSocketAcceptor(Application application,
                              MessageStoreFactory messageStoreFactory,
                              SessionSettings settings,
                              LogFactory logFactory,
                              MessageFactory messageFactory,
                              int queueCapacity)
                       throws ConfigError

Throws:

ConfigError

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,
                              int queueCapacity)
                       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,
                              int queueCapacity)
                       throws ConfigError

Throws:

ConfigError

ThreadedSocketAcceptor

public ThreadedSocketAcceptor(SessionFactory sessionFactory,
                              SessionSettings settings)
                       throws ConfigError

Throws:

ConfigError

Method Detail

newBuilder

public static ThreadedSocketAcceptor.Builder newBuilder()

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. This method must not be called by several threads concurrently.

Throws:

ConfigError - Problem with acceptor configuration.

RuntimeError - Other unspecified error

stop

public void stop(boolean forceDisconnect)

Description copied from interface: Connector

Stops all sessions, optionally waiting for logout completion. This method must not be called by several threads concurrently.

Parameters:

forceDisconnect - don't wait for logout before disconnect.

getEventHandlingStrategy

protected EventHandlingStrategy getEventHandlingStrategy()

Specified by:

getEventHandlingStrategy in class AbstractSocketAcceptor