Package 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.ConsumingControlTransportWrapper

Field Summary

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

configuration, graceful, listener, messageFactory, preferredSendingMode, queue, runtimeState, sentTRNum, sequenceManager, sessionLock, sessionParameters, testRequestTime, transport

Fields inherited from interface com.epam.fixengine.FIXSession

DEFAULT_SENDING_OPTIONS, SEND_ASYNC, SEND_SYNC

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	connect()	Connects to remote counterparty, if initiator or accepts incoming connection if acceptor.
SessionParameters	getSessionParameters()	The returned value is cloned.
boolean	isLastResetOccurredAfterPeriodBegin()
boolean	isLastResetOccurredAfterPeriodEnd()
boolean	isLastResetOccurredInTradingPeriod()
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

addInSessionLevelMessageListener, addOutSessionLevelMessageListener, addSessionStateListener, addUserGlobalMessageHandler, backupStorages, checkHasSessionSendOrReceivedTestRequest, checkSessionInactiveAndSendHbt, clearQueue, disconnect, disconnect, disconnect, disconnect, disconnect, disconnectTestRequestIsLost, dispose, equals, forcedDisconnect, getAttribute, getAttribute, getAttributeAsBool, getAttributeAsLong, getBytesRead, getBytesSent, getConfiguration, getEncryption, getErrorHandler, getEstablished, getExtendedFIXSessionListener, getFIXSessionOutOfSyncListener, getIncomingMessageStorage, getInSeqNum, getLastDisconnectReason, getLastInMessageTimestamp, getLastOutMessageTimestamp, getMessageFactory, getMessageHandlers, getMessageQueue, getMessageValidator, getMessageValidator, getMessageValidator, getNoOfInMessages, getNoOfOutMessages, getOutgoingMessageStorage, getOutSeqNum, getQueuedMessagesCount, getRejectMessageListener, getRuntimeState, getSequenceManager, getSessionParametersInstance, getSessionState, getSlowConsumerListener, getStorageFactory, hashCode, init, initSessionInternal, initSessionRuntimeState, isHbtControlInPumper, isStatisticEnabled, lockSending, markShutdownAsGraceful, onDisconnect, prepareForConnect, prepareMessage, prepareMessage, prepareMessage, prepareMessageFromString, prepareMessageFromString, reinit, removeAttribute, removeAttribute, removeLongAttribute, removeSessionStateListener, resetInitialization, resetSequenceNumbers, resetSequenceNumbers, resetTestRequestFlags, restoreSessionAfterReceivedTestRequest, saveSessionParameters, sendAsIs, sendAsIs, sendMessage, sendMessage, sendMessage, sendMessage, sendMessageAndGetQueueSize, sendMessageAndGetQueueSize, sendMessageOutOfTurn, sendTestRequest, sendWithChanges, sendWithChanges, sendWithChangesAndGetQueueSize, sendWithChangesAndGetQueueSize, setAttribute, setAttribute, setAttribute, setAttribute, setErrorHandler, setFIXSessionListener, setFIXSessionOutOfSyncListener, setInSeqNum, setLastDisconnectReason, setOutOfTurnMode, setOutSeqNum, setPreLogoffSessionState, setRejectMessageListener, setSequenceNumbers, setSessionState, setSlowConsumerListener, shutdown, shutdown, startSession, subscribeForAttributeChanges, toString, unlockSending

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.epam.fixengine.session.ExtendedFIXSession

getAndRemoveAttribute

Constructor Details

AcceptorFIXSession

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

Method Details

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

isLastResetOccurredInTradingPeriod

public boolean isLastResetOccurredInTradingPeriod()

isLastResetOccurredAfterPeriodBegin

public boolean isLastResetOccurredAfterPeriodBegin()

isLastResetOccurredAfterPeriodEnd

public boolean isLastResetOccurredAfterPeriodEnd()