com.epam.fixengine.session
Class AcceptorFIXSession

java.lang.Object
  com.epam.fixengine.session.AbstractFIXSession
      com.epam.fixengine.session.AcceptorFIXSession

All Implemented Interfaces:

FIXSession, ExtendedFIXSession, com.epam.fixengine.session.SessionStateListenSupport

public final class AcceptorFIXSession
extends AbstractFIXSession

Nested Class Summary

Nested classes/interfaces inherited from class com.epam.fixengine.session.AbstractFIXSession

AbstractFIXSession.SessionParametersProxyAdaptorListener

Field Summary

Fields inherited from class com.epam.fixengine.session.AbstractFIXSession

configuration, graceful, listener, messageFactory, queue, sessionLock, sessionParameters, TRACE_ENABLED, transport

Fields inherited from interface com.epam.fixengine.FIXSession

DEFAULT_SENDING_OPTIONS, SEND_ASYNC, SEND_SYNC

Constructor Summary

AcceptorFIXSession(FIXMessageFactory messageFactory, SessionParameters sessionParameters, HandlerChain fixSessionListener, FIXTransport transport)

Method Summary

void	connect() Connects to remote counterparty, if initiator or accepts incoming connection if acceptor.
SessionParameters	getSessionParameters() The returned value is cloned.
protected boolean	isResetSeqNumFlagRequiredForInitLogon()
void	reinitSession(SessionParameters inSessionParameters, FIXTransport transport)
void	reject(String reason) Reject incoming connection for acceptor.
protected void	updateSessionParameters(SessionParameters newParams, SessionParameters oldParams)

Methods inherited from class com.epam.fixengine.session.AbstractFIXSession

addSessionStateListener, checkHasSessionSendOrReceivedTestRequest, clearQueue, configureStateBeforeReset, disconnect, disconnect, disconnect, disconnect, disconnectTestRequestIsLost, dispose, equals, forcedDisconnect, getAttribute, getAttributeAsBool, getAttributeAsLong, getBytesRead, getBytesSent, getEncryption, getErrorHandler, getEstablished, getExtendedFIXSessionListener, getIncomingMessageStorage, getLastDisconnectReason, getLastInMessageTimestamp, getLastOutMessageTimestamp, getMessageFactory, getMessageHandlers, getMessageValidator, getNoOfInMessages, getNoOfOutMessages, getOutgoingMessageStorage, getQueuedMessagesCount, getRejectMessageListener, getSequenceManager, getSessionParametersInstance, getSessionState, getStorageFactory, hashCode, initSession, initSessionInternal, isResetTimeMissed, isStatisticEnabled, loadSessionParametersFromFile, markShutdownAsGraceful, prepareMessage, prepareMessage, prepareMessage, prepareMessageFromString, prepareMessageFromString, removeAttribute, removeAttribute, removeLongAttribute, removeSessionStateListener, resetSeqNumIfConfigured, resetSequenceNumbers, resetSequenceNumbers, resetTestRequestFlags, restoreSessionAfterReceivedTestRequest, restoreSessionParameters, saveSessionParameters, sendAsIs, sendAsIs, sendMessage, sendMessage, sendMessage, sendMessage, sendMessageAndGetQueueSize, sendMessageAndGetQueueSize, sendMessageOutOfTurn, sendTestRequest, sendWithChanges, sendWithChanges, sendWithChangesAndGetQueueSize, sendWithChangesAndGetQueueSize, setAttribute, setAttribute, setAttribute, setErrorHandler, setFIXSessionListener, setLastDisconnectReason, setOutOfTurnMode, setPreLoggofSessionState, setRejectMessageListener, setSequenceNumbers, setSessionState, shutdown, shutdown, startSession, storeProcessedSeqNumber, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

AcceptorFIXSession

public AcceptorFIXSession(FIXMessageFactory messageFactory,
                          SessionParameters sessionParameters,
                          HandlerChain fixSessionListener,
                          FIXTransport transport)

Method Detail

reinitSession

public void reinitSession(SessionParameters inSessionParameters,
                          FIXTransport transport)

updateSessionParameters

protected void updateSessionParameters(SessionParameters newParams,
                                       SessionParameters oldParams)

getSessionParameters

public SessionParameters getSessionParameters()

Description copied from class: AbstractFIXSession

The returned value is cloned.

Specified by:

getSessionParameters in interface FIXSession

Overrides:

getSessionParameters in class AbstractFIXSession

Returns:

SessionParameters - session parameters

See Also:

FIXSession.getSessionParameters()

connect

public void connect()
             throws IOException

Description copied from interface: FIXSession

Connects to remote counterparty,
if initiator or accepts incoming connection if acceptor.

Specified by:

connect in interface FIXSession

Specified by:

connect in class AbstractFIXSession

Throws:

IOException - I/O exception if error occurred

See Also:

FIXSession.connect()

reject

public void reject(String reason)
            throws IOException

Description copied from interface: FIXSession

Reject incoming connection for acceptor.
Not applicable for initiator.

Specified by:

reject in interface FIXSession

Specified by:

reject in class AbstractFIXSession

Throws:

IOException - I/O exception if error occurred

See Also:

FIXSession.reject(String)

isResetSeqNumFlagRequiredForInitLogon

protected boolean isResetSeqNumFlagRequiredForInitLogon()

Overrides:

isResetSeqNumFlagRequiredForInitLogon in class AbstractFIXSession