quickfix
Class SocketInitiator

java.lang.Object
  extended by quickfix.mina.SessionConnector
      extended by quickfix.mina.initiator.AbstractSocketInitiator
          extended by 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.


Field Summary
 
Fields inherited from class quickfix.mina.initiator.AbstractSocketInitiator
log
 
Fields inherited from class quickfix.mina.SessionConnector
QF_SESSION
 
Fields inherited from interface quickfix.Initiator
SETTING_RECONNECT_INTERVAL, SETTING_SOCKET_CONNECT_HOST, SETTING_SOCKET_CONNECT_PORT, SETTING_SOCKET_CONNECT_PROTOCOL
 
Constructor Summary
SocketInitiator(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, LogFactory logFactory, MessageFactory messageFactory)
           
SocketInitiator(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, MessageFactory messageFactory)
           
SocketInitiator(SessionFactory sessionFactory, SessionSettings settings)
           
 
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.initiator.AbstractSocketInitiator
createSessionInitiators, getInitiators, getQueueSize, startInitiators, stopInitiators
 
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
 
Methods inherited from interface quickfix.Connector
getSessions, isLoggedOn
 

Constructor Detail

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(SessionFactory sessionFactory,
                       SessionSettings settings)
                throws ConfigError
Throws:
ConfigError
Method Detail

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

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.