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_PROPERTY
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, waitForLogout
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
block, getSessions, isLoggedOn, start, stop, stop
protected AbstractSocketInitiator(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, LogFactory logFactory, MessageFactory messageFactory) throws ConfigError
ConfigError
protected AbstractSocketInitiator(SessionSettings settings, SessionFactory sessionFactory) throws ConfigError
ConfigError
protected void createSessionInitiators() throws ConfigError
ConfigError
protected void startInitiators()
protected void stopInitiators()
public Set<IoSessionInitiator> getInitiators()
public int getQueueSize()
protected abstract EventHandlingStrategy getEventHandlingStrategy()
Copyright © 2016. All rights reserved.