public class SocketAcceptor extends AbstractSocketAcceptor
DEFAULT_QUEUE_CAPACITY, log, longLivedExecutor, propertyChangeSupport, QF_SESSION, QFJ_RESET_IO_CONNECTOR, SESSIONS_PROPERTY, shortLivedExecutorSETTING_ACCEPTOR_TEMPLATE, SETTING_SOCKET_ACCEPT_ADDRESS, SETTING_SOCKET_ACCEPT_PORT, SETTING_SOCKET_ACCEPT_PROTOCOL| Constructor and Description |
|---|
SocketAcceptor(Application application,
MessageStoreFactory messageStoreFactory,
SessionSettings settings,
LogFactory logFactory,
MessageFactory messageFactory) |
SocketAcceptor(Application application,
MessageStoreFactory messageStoreFactory,
SessionSettings settings,
LogFactory logFactory,
MessageFactory messageFactory,
int queueCapacity) |
SocketAcceptor(Application application,
MessageStoreFactory messageStoreFactory,
SessionSettings settings,
MessageFactory messageFactory) |
SocketAcceptor(Application application,
MessageStoreFactory messageStoreFactory,
SessionSettings settings,
MessageFactory messageFactory,
int queueCapacity) |
SocketAcceptor(SessionFactory sessionFactory,
SessionSettings settings) |
SocketAcceptor(SessionFactory sessionFactory,
SessionSettings settings,
int queueCapacity) |
| Modifier and Type | Method and Description |
|---|---|
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.
|
getAcceptorAddresses, getEndpoints, getQueueSize, setSessionProvider, startAcceptingConnections, stopAcceptingConnectionsaddDynamicSession, addPropertyChangeListener, 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, isLoggedOnpublic SocketAcceptor(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, LogFactory logFactory, MessageFactory messageFactory, int queueCapacity) throws ConfigError
ConfigErrorpublic SocketAcceptor(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, LogFactory logFactory, MessageFactory messageFactory) throws ConfigError
ConfigErrorpublic SocketAcceptor(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, MessageFactory messageFactory, int queueCapacity) throws ConfigError
ConfigErrorpublic SocketAcceptor(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, MessageFactory messageFactory) throws ConfigError
ConfigErrorpublic SocketAcceptor(SessionFactory sessionFactory, SessionSettings settings, int queueCapacity) throws ConfigError
ConfigErrorpublic SocketAcceptor(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.protected EventHandlingStrategy getEventHandlingStrategy()
getEventHandlingStrategy in class AbstractSocketAcceptorCopyright © 2017. All rights reserved.