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.

Field Summary

Fields inherited from class quickfix.mina.SessionConnector

DEFAULT_QUEUE_CAPACITY, log, longLivedExecutor, propertyChangeSupport, QF_SESSION, QFJ_RESET_IO_CONNECTOR, SESSIONS_PROPERTY, shortLivedExecutor

Fields inherited from interface quickfix.Acceptor

SETTING_ACCEPTOR_TEMPLATE, SETTING_SOCKET_ACCEPT_ADDRESS, SETTING_SOCKET_ACCEPT_PORT, SETTING_SOCKET_ACCEPT_PROTOCOL

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractSocketAcceptor(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, LogFactory logFactory, MessageFactory messageFactory)
protected	AbstractSocketAcceptor(Application application, MessageStoreFactory messageStoreFactory, SessionSettings settings, MessageFactory messageFactory)
protected	AbstractSocketAcceptor(SessionSettings settings, SessionFactory sessionFactory)

Method Summary

Modifier and Type	Method and Description
Map<SessionID,SocketAddress>	getAcceptorAddresses()
Collection<org.apache.mina.core.service.IoAcceptor>	getEndpoints()
protected abstract EventHandlingStrategy	getEventHandlingStrategy()
int	getQueueSize()
void	setSessionProvider(SocketAddress address, AcceptorSessionProvider provider)
protected void	startAcceptingConnections()
protected void	stopAcceptingConnections()

Methods inherited from class quickfix.mina.SessionConnector

addDynamicSession, addPropertyChangeListener, clearConnectorSessions, closeManagedSessionsAndDispose, createSession, getIntSetting, getIoFilterChainBuilder, getManagedSessions, getScheduledExecutorService, getSessionMap, getSessions, getSettings, isContinueInitOnError, isLoggedOn, logError, logoutAllSessions, removeDynamicSession, removePropertyChangeListener, setExecutorFactory, setIoFilterChainBuilder, setSessions, startSessionTimer, stopSessionTimer, waitForLogout

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface quickfix.Connector

getSessions, isLoggedOn, start, stop, stop

Constructor Detail

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

Method Detail

startAcceptingConnections

protected void startAcceptingConnections()
                                  throws ConfigError

Throws:

ConfigError

stopAcceptingConnections

protected void stopAcceptingConnections()

getEndpoints

public Collection<org.apache.mina.core.service.IoAcceptor> getEndpoints()

getAcceptorAddresses

public Map<SessionID,SocketAddress> getAcceptorAddresses()

setSessionProvider

public void setSessionProvider(SocketAddress address,
                               AcceptorSessionProvider provider)

getQueueSize

public int getQueueSize()

getEventHandlingStrategy

protected abstract EventHandlingStrategy getEventHandlingStrategy()