public class SocketInitiator extends AbstractSocketInitiator
log
DEFAULT_QUEUE_CAPACITY, propertyChangeSupport, QF_SESSION, SESSIONS_PROPERTY
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 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) |
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, stopInitiators
addDynamicSession, addPropertyChangeListener, createSession, getIntSetting, getIoFilterChainBuilder, getManagedSessions, getScheduledExecutorService, getSessionMap, getSessions, getSettings, isLoggedOn, logError, logoutAllSessions, removeDynamicSession, removePropertyChangeListener, setIoFilterChainBuilder, setSessions, startSessionTimer, stopSessionTimer, waitForLogout
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getSessions, isLoggedOn
public SocketInitiator(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, MessageFactory messageFactory, int queueCapacity) throws ConfigError
ConfigError
public SocketInitiator(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, MessageFactory messageFactory) throws ConfigError
ConfigError
public SocketInitiator(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, LogFactory logFactory, MessageFactory messageFactory) throws ConfigError
ConfigError
public SocketInitiator(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, LogFactory logFactory, MessageFactory messageFactory, int queueCapacity) throws ConfigError
ConfigError
public SocketInitiator(SessionFactory sessionFactory, SessionSettings settings, int queueCapacity) throws ConfigError
ConfigError
public void block() throws ConfigError, RuntimeError
Connector
ConfigError
- Problem with acceptor configuration.RuntimeError
- Other unspecified errorpublic void start() throws ConfigError, RuntimeError
Connector
ConfigError
- Problem with acceptor configuration.RuntimeError
- Other unspecified errorpublic void stop()
Connector
public void stop(boolean forceDisconnect)
Connector
forceDisconnect
- don't wait for logout before disconnect.protected EventHandlingStrategy getEventHandlingStrategy()
getEventHandlingStrategy
in class AbstractSocketInitiator
Copyright © 2016. All rights reserved.