quickfix

Class SocketInitiator

java.lang.Object

quickfix.mina.SessionConnector

quickfix.mina.initiator.AbstractSocketInitiator

quickfix.SocketInitiator

All Implemented Interfaces:

Connector, Initiator

public class SocketInitiator
extends AbstractSocketInitiator

Initiates connections and uses a single thread to process messages for all sessions.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SocketInitiator.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
SocketInitiator(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, LogFactory logFactory, MessageFactory messageFactory)
SocketInitiator(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, LogFactory logFactory, MessageFactory messageFactory, int queueCapacity)
SocketInitiator(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, MessageFactory messageFactory)
SocketInitiator(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, MessageFactory messageFactory, int queueCapacity)
SocketInitiator(SessionFactory sessionFactory, SessionSettings settings, int queueCapacity)

Method Summary

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

SocketInitiator

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

Throws:

ConfigError

SocketInitiator

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

Throws:

ConfigError

SocketInitiator

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

Throws:

ConfigError

SocketInitiator

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

Throws:

ConfigError

SocketInitiator

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

Throws:

ConfigError

Method Detail

newBuilder

public static SocketInitiator.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