public abstract class AbstractSocketInitiator extends SessionConnector implements Initiator
| Modifier and Type | Field and Description |
|---|---|
protected org.slf4j.Logger |
log |
DEFAULT_QUEUE_CAPACITY, propertyChangeSupport, QF_SESSION, SESSIONS_PROPERTYSETTING_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| Modifier | Constructor and Description |
|---|---|
protected |
AbstractSocketInitiator(Application application,
MessageStoreFactory messageStoreFactory,
SessionSettings settings,
LogFactory logFactory,
MessageFactory messageFactory) |
protected |
AbstractSocketInitiator(SessionSettings settings,
SessionFactory sessionFactory) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
createSessionInitiators() |
protected abstract EventHandlingStrategy |
getEventHandlingStrategy() |
Set<IoSessionInitiator> |
getInitiators() |
int |
getQueueSize() |
protected void |
startInitiators() |
protected void |
stopInitiators() |
addDynamicSession, 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, waitblock, getSessions, isLoggedOn, start, stop, stopprotected AbstractSocketInitiator(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, LogFactory logFactory, MessageFactory messageFactory) throws ConfigError
ConfigErrorprotected AbstractSocketInitiator(SessionSettings settings, SessionFactory sessionFactory) throws ConfigError
ConfigErrorprotected void createSessionInitiators()
throws ConfigError
ConfigErrorprotected void startInitiators()
protected void stopInitiators()
public Set<IoSessionInitiator> getInitiators()
public int getQueueSize()
protected abstract EventHandlingStrategy getEventHandlingStrategy()
Copyright © 2016. All rights reserved.