public class ThreadedSocketAcceptor 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 |
|---|
ThreadedSocketAcceptor(Application application,
MessageStoreFactory messageStoreFactory,
SessionSettings settings,
LogFactory logFactory,
MessageFactory messageFactory) |
ThreadedSocketAcceptor(Application application,
MessageStoreFactory messageStoreFactory,
SessionSettings settings,
LogFactory logFactory,
MessageFactory messageFactory,
int queueCapacity) |
ThreadedSocketAcceptor(Application application,
MessageStoreFactory messageStoreFactory,
SessionSettings settings,
MessageFactory messageFactory) |
ThreadedSocketAcceptor(Application application,
MessageStoreFactory messageStoreFactory,
SessionSettings settings,
MessageFactory messageFactory,
int queueCapacity) |
ThreadedSocketAcceptor(SessionFactory sessionFactory,
SessionSettings settings) |
ThreadedSocketAcceptor(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.
|
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 ThreadedSocketAcceptor(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, LogFactory logFactory, MessageFactory messageFactory, int queueCapacity) throws ConfigError
ConfigErrorpublic ThreadedSocketAcceptor(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, LogFactory logFactory, MessageFactory messageFactory) throws ConfigError
ConfigErrorpublic ThreadedSocketAcceptor(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, MessageFactory messageFactory, int queueCapacity) throws ConfigError
ConfigErrorpublic ThreadedSocketAcceptor(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, MessageFactory messageFactory) throws ConfigError
ConfigErrorpublic ThreadedSocketAcceptor(SessionFactory sessionFactory, SessionSettings settings, int queueCapacity) throws ConfigError
ConfigErrorpublic ThreadedSocketAcceptor(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.public void block()
throws ConfigError,
RuntimeError
ConnectorConfigError - Problem with acceptor configuration.RuntimeError - Other unspecified errorprotected EventHandlingStrategy getEventHandlingStrategy()
getEventHandlingStrategy in class AbstractSocketAcceptorCopyright © 2017. All rights reserved.