public abstract class AbstractSocketInitiator extends SessionConnector implements Initiator
| Modifier and Type | Field and Description |
|---|---|
protected org.slf4j.Logger |
log |
DEFAULT_QUEUE_CAPACITY, longLivedExecutor, propertyChangeSupport, QF_SESSION, QFJ_RESET_IO_CONNECTOR, SESSIONS_PROPERTY, shortLivedExecutorSETTING_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| 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 |
|---|---|
void |
createDynamicSession(SessionID sessionID) |
protected void |
createSessionInitiators() |
protected abstract EventHandlingStrategy |
getEventHandlingStrategy() |
Set<IoSessionInitiator> |
getInitiators() |
int |
getQueueSize() |
protected void |
startInitiators() |
protected void |
stopInitiators() |
addDynamicSession, addPropertyChangeListener, clearConnectorSessions, closeManagedSessionsAndDispose, createSession, getIntSetting, getIoFilterChainBuilder, getManagedSessions, getScheduledExecutorService, getSessionMap, getSessions, getSettings, isLoggedOn, logError, logoutAllSessions, removeDynamicSession, removePropertyChangeListener, setExecutorFactory, setIoFilterChainBuilder, setSessions, startSessionTimer, stopSessionTimer, waitForLogoutclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetSessions, 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
ConfigErrorpublic void createDynamicSession(SessionID sessionID) throws ConfigError
ConfigErrorprotected void startInitiators()
protected void stopInitiators()
public Set<IoSessionInitiator> getInitiators()
public int getQueueSize()
protected abstract EventHandlingStrategy getEventHandlingStrategy()
Copyright © 2018. All rights reserved.