public class ThreadedSocketInitiator extends AbstractSocketInitiator
logDEFAULT_QUEUE_CAPACITY, propertyChangeSupport, QF_SESSION, SESSIONS_PROPERTYSETTING_RECONNECT_INTERVAL, SETTING_SOCKET_CONNECT_HOST, SETTING_SOCKET_CONNECT_PORT, SETTING_SOCKET_CONNECT_PROTOCOL, SETTING_SOCKET_LOCAL_HOST, SETTING_SOCKET_LOCAL_PORT| 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) |
| Modifier and Type | Method and Description |
|---|---|
void |
block()
Start accepting connections.
|
protected EventHandlingStrategy |
getEventHandlingStrategy() |
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.
|
createSessionInitiators, getInitiators, getQueueSize, startInitiators, stopInitiatorsaddDynamicSession, addPropertyChangeListener, createSession, getIntSetting, getIoFilterChainBuilder, getManagedSessions, getScheduledExecutorService, getSessionMap, getSessions, getSettings, isLoggedOn, logError, logoutAllSessions, removeDynamicSession, removePropertyChangeListener, setIoFilterChainBuilder, setSessions, startSessionTimer, stopSessionTimer, waitForLogoutclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetSessions, isLoggedOnpublic ThreadedSocketInitiator(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, LogFactory logFactory, MessageFactory messageFactory, int queueCapacity) throws ConfigError
ConfigErrorpublic ThreadedSocketInitiator(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, LogFactory logFactory, MessageFactory messageFactory) throws ConfigError
ConfigErrorpublic ThreadedSocketInitiator(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, MessageFactory messageFactory, int queueCapacity) throws ConfigError
ConfigErrorpublic ThreadedSocketInitiator(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, MessageFactory messageFactory) throws ConfigError
ConfigErrorpublic ThreadedSocketInitiator(SessionFactory sessionFactory, SessionSettings settings, int queueCapacity) throws ConfigError
ConfigErrorpublic ThreadedSocketInitiator(SessionFactory sessionFactory, SessionSettings settings) throws ConfigError
ConfigErrorpublic void start()
throws ConfigError,
RuntimeError
ConnectorConfigError - Problem with acceptor configuration.RuntimeError - Other unspecified errorpublic void stop()
Connectorpublic void stop(boolean forceDisconnect)
ConnectorforceDisconnect - don't wait for logout before disconnect.public void block()
throws ConfigError,
RuntimeError
ConnectorConfigError - Problem with acceptor configuration.RuntimeError - Other unspecified errorprotected EventHandlingStrategy getEventHandlingStrategy()
getEventHandlingStrategy in class AbstractSocketInitiatorCopyright © 2016. All rights reserved.