quickfix.mina.acceptor
Class AbstractSocketAcceptor
java.lang.Object
quickfix.mina.SessionConnector
quickfix.mina.acceptor.AbstractSocketAcceptor
- All Implemented Interfaces:
- Acceptor, Connector
- Direct Known Subclasses:
- SocketAcceptor, ThreadedSocketAcceptor
public abstract class AbstractSocketAcceptor
- extends SessionConnector
- implements Acceptor
Abstract base class for socket acceptors.
Methods inherited from class quickfix.mina.SessionConnector |
addDynamicSession, createSession, getIntSetting, getIoFilterChainBuilder, getManagedSessions, getScheduledExecutorService, getSessionMap, getSessions, getSettings, isLoggedOn, logError, logoutAllSessions, removeDynamicSession, setIoFilterChainBuilder, setSessions, startSessionTimer, stopSessionTimer, waitForLogout |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AbstractSocketAcceptor
protected AbstractSocketAcceptor(SessionSettings settings,
SessionFactory sessionFactory)
throws ConfigError
- Throws:
ConfigError
AbstractSocketAcceptor
protected AbstractSocketAcceptor(Application application,
MessageStoreFactory messageStoreFactory,
SessionSettings settings,
MessageFactory messageFactory)
throws ConfigError
- Throws:
ConfigError
AbstractSocketAcceptor
protected AbstractSocketAcceptor(Application application,
MessageStoreFactory messageStoreFactory,
SessionSettings settings,
LogFactory logFactory,
MessageFactory messageFactory)
throws ConfigError
- Throws:
ConfigError
startAcceptingConnections
protected void startAcceptingConnections(EventHandlingStrategy eventHandlingStrategy)
throws ConfigError
- Throws:
ConfigError
stopAcceptingConnections
protected void stopAcceptingConnections()
getEndpoints
public java.util.Collection<org.apache.mina.common.IoAcceptor> getEndpoints()
getAcceptorAddresses
public java.util.Map<SessionID,java.net.SocketAddress> getAcceptorAddresses()
setSessionProvider
public void setSessionProvider(java.net.SocketAddress address,
AcceptorSessionProvider provider)
getQueueSize
public int getQueueSize()