quickfix

Class ThreadedSocketInitiator

java.lang.Object

quickfix.mina.SessionConnector

quickfix.mina.initiator.AbstractSocketInitiator

quickfix.ThreadedSocketInitiator

All Implemented Interfaces:

Connector, Initiator

public class ThreadedSocketInitiator
extends AbstractSocketInitiator

Initiates connections and uses a separate thread per session to process messages.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ThreadedSocketInitiator.Builder

Field Summary

Fields inherited from class quickfix.mina.initiator.AbstractSocketInitiator

log, QFJ_RECONNECT_THREAD_PREFIX

Fields inherited from class quickfix.mina.SessionConnector

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

Fields inherited from interface quickfix.Initiator

SETTING_DYNAMIC_SESSION, SETTING_PROXY_DOMAIN, SETTING_PROXY_HOST, SETTING_PROXY_PASSWORD, SETTING_PROXY_PORT, SETTING_PROXY_TYPE, SETTING_PROXY_USER, SETTING_PROXY_VERSION, SETTING_PROXY_WORKSTATION, SETTING_RECONNECT_INTERVAL, SETTING_SOCKET_CONNECT_HOST, SETTING_SOCKET_CONNECT_PORT, SETTING_SOCKET_CONNECT_PROTOCOL, SETTING_SOCKET_LOCAL_HOST, SETTING_SOCKET_LOCAL_PORT

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected EventHandlingStrategy	getEventHandlingStrategy()
static ThreadedSocketInitiator.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.initiator.AbstractSocketInitiator

createDynamicSession, createSessionInitiators, getInitiators, getQueueSize, startInitiators, stopInitiators

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

ThreadedSocketInitiator

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

Throws:

ConfigError

ThreadedSocketInitiator

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

Throws:

ConfigError

ThreadedSocketInitiator

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

Throws:

ConfigError

ThreadedSocketInitiator

public ThreadedSocketInitiator(Application application,
                               MessageStoreFactory messageStoreFactory,
                               SessionSettings settings,
                               MessageFactory messageFactory)
                        throws ConfigError

Throws:

ConfigError

ThreadedSocketInitiator

public ThreadedSocketInitiator(SessionFactory sessionFactory,
                               SessionSettings settings,
                               int queueCapacity)
                        throws ConfigError

Throws:

ConfigError

ThreadedSocketInitiator

public ThreadedSocketInitiator(SessionFactory sessionFactory,
                               SessionSettings settings)
                        throws ConfigError

Throws:

ConfigError

Method Detail

newBuilder

public static ThreadedSocketInitiator.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 AbstractSocketInitiator