public class ThreadedSocketAcceptor extends AbstractSocketAcceptor
DEFAULT_QUEUE_CAPACITY, log, propertyChangeSupport, QF_SESSION, SESSIONS_PROPERTY
SETTING_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, stopAcceptingConnections
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
getSessions, isLoggedOn
public ThreadedSocketAcceptor(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, LogFactory logFactory, MessageFactory messageFactory, int queueCapacity) throws ConfigError
ConfigError
public ThreadedSocketAcceptor(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, LogFactory logFactory, MessageFactory messageFactory) throws ConfigError
ConfigError
public ThreadedSocketAcceptor(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, MessageFactory messageFactory, int queueCapacity) throws ConfigError
ConfigError
public ThreadedSocketAcceptor(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, MessageFactory messageFactory) throws ConfigError
ConfigError
public ThreadedSocketAcceptor(SessionFactory sessionFactory, SessionSettings settings, int queueCapacity) throws ConfigError
ConfigError
public ThreadedSocketAcceptor(SessionFactory sessionFactory, SessionSettings settings) throws ConfigError
ConfigError
public void start() throws ConfigError, RuntimeError
Connector
ConfigError
- Problem with acceptor configuration.RuntimeError
- Other unspecified errorpublic void stop()
Connector
public void stop(boolean forceDisconnect)
Connector
forceDisconnect
- don't wait for logout before disconnect.public void block() throws ConfigError, RuntimeError
Connector
ConfigError
- Problem with acceptor configuration.RuntimeError
- Other unspecified errorprotected EventHandlingStrategy getEventHandlingStrategy()
getEventHandlingStrategy
in class AbstractSocketAcceptor
Copyright © 2016. All rights reserved.