Package com.epam.fixengine.acceptor

Class SessionAcceptorStrategyHandler

java.lang.Object

com.epam.fixengine.acceptor.SessionAcceptorStrategyHandler

Direct Known Subclasses:

AllowNonRegisteredAcceptorStrategyHandler, DenyNonRegisteredAcceptorStrategyHandler

public abstract class SessionAcceptorStrategyHandler
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected com.epam.fixengine.acceptor.autostart.AutostartAcceptorSessions	autostartAcceptorSessions
protected com.epam.fixengine.manager.ConfiguredSessionRegister	configuredSessionRegister
protected FIXServerListener	listener
protected Map<SessionID,ExtendedFIXSession>	registeredAcceptorSessions

Constructor Summary

Constructors

Constructor	Description
SessionAcceptorStrategyHandler()

Method Summary

Modifier and Type	Method	Description
protected void	checkSessionParameters(SessionParameters newParams, SessionParameters registeredParams)
void	closeAllRegisteredSessions()
protected void	closeDeniedSession(ExtendedFIXSession session)
protected void	closeSession(DisconnectReason reason, String description, ExtendedFIXSession session)
protected void	createAdminSession(SessionParameters sessionParameters, FIXTransport fixTransport, SessionID sessionID)
abstract void	handleIncomingConnection(SessionParameters sessionParameters, FIXTransport fixTransport)
void	init(com.epam.fixengine.configuration.Configuration configuration, com.epam.fixengine.manager.ConfiguredSessionRegister configuredSessionRegister)
protected boolean	isAcceptorSessionRegistered(SessionID sessionID)
protected void	mergeSessionParameters(SessionParameters sessionParameters, SessionParameters registeredSessionParameters)
protected void	processIncomingAdminSession(FIXTransport fixTransport, SessionID sessionID, SessionParameters sessionParameters)
protected void	registerSession(SessionID sessionID, ExtendedFIXSession fixSession)
void	setSessionListener(FIXServerListener listener)

Methods inherited from class java.lang.Object

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

Field Details

registeredAcceptorSessions

protected Map<SessionID,ExtendedFIXSession> registeredAcceptorSessions

configuredSessionRegister

protected com.epam.fixengine.manager.ConfiguredSessionRegister configuredSessionRegister

autostartAcceptorSessions

protected com.epam.fixengine.acceptor.autostart.AutostartAcceptorSessions autostartAcceptorSessions

listener

protected FIXServerListener listener

Constructor Details

SessionAcceptorStrategyHandler

public SessionAcceptorStrategyHandler()

Method Details

setSessionListener

public void setSessionListener(FIXServerListener listener)

init

public void init(com.epam.fixengine.configuration.Configuration configuration,
 com.epam.fixengine.manager.ConfiguredSessionRegister configuredSessionRegister)

handleIncomingConnection

public abstract void handleIncomingConnection(SessionParameters sessionParameters,
 FIXTransport fixTransport)
                                       throws IOException

Throws:

IOException

isAcceptorSessionRegistered

protected boolean isAcceptorSessionRegistered(SessionID sessionID)

closeDeniedSession

protected void closeDeniedSession(ExtendedFIXSession session)
                           throws IOException

Throws:

IOException

closeSession

protected void closeSession(DisconnectReason reason,
 String description,
 ExtendedFIXSession session)
                     throws IOException

Throws:

IOException

registerSession

protected void registerSession(SessionID sessionID,
 ExtendedFIXSession fixSession)

closeAllRegisteredSessions

public void closeAllRegisteredSessions()
                                throws IOException

Throws:

IOException

checkSessionParameters

protected void checkSessionParameters(SessionParameters newParams,
 SessionParameters registeredParams)

mergeSessionParameters

protected void mergeSessionParameters(SessionParameters sessionParameters,
 SessionParameters registeredSessionParameters)

processIncomingAdminSession

protected void processIncomingAdminSession(FIXTransport fixTransport,
 SessionID sessionID,
 SessionParameters sessionParameters)
                                    throws IOException

Throws:

IOException

createAdminSession

protected void createAdminSession(SessionParameters sessionParameters,
 FIXTransport fixTransport,
 SessionID sessionID)
                           throws IOException

Throws:

IOException