Package com.epam.fixengine.session

Class AutoreconnectFIXSession

java.lang.Object

com.epam.fixengine.session.AbstractFIXSession

com.epam.fixengine.session.InitiatorFIXSession

com.epam.fixengine.session.AutoreconnectFIXSession

All Implemented Interfaces:

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

public class AutoreconnectFIXSession
extends InitiatorFIXSession
implements BackupFIXSession

Nested Class Summary

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

AbstractFIXSession.ConsumingControlTransportWrapper

Field Summary

Fields

Modifier and Type	Field	Description
protected static final int	NO_AUTORECONNECT

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
AutoreconnectFIXSession(FIXMessageFactory factory, SessionParameters sessionParameters, HandlerChain fixSessionListener)

Method Summary

Modifier and Type	Method	Description
protected void	connectInternal()
protected void	disconnect(DisconnectReason reasonType, String reasonDescription, boolean isGracefull, boolean isForced, boolean continueReading)
protected void	initTransport()
boolean	isRunningOnBackup()	Returns true, if session connected to backup host.
void	setFIXSessionListener(FIXSessionListener listener)	Sets FIXSession listener to monitor session status and receive incoming messages.
protected void	startSession()
void	switchToBackUp()	The method, switch current connection to backup.
void	switchToPrimary()	The method, switch current connection to primary.

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

connect, disconnect, dispose, getTransport, init, reject, setSessionState

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

addInSessionLevelMessageListener, addOutSessionLevelMessageListener, addSessionStateListener, addUserGlobalMessageHandler, backupStorages, checkHasSessionSendOrReceivedTestRequest, checkSessionInactiveAndSendHbt, clearQueue, disconnect, disconnect, disconnect, disconnectTestRequestIsLost, 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, getSessionParameters, getSessionParametersInstance, getSessionState, getSlowConsumerListener, getStorageFactory, hashCode, initSessionInternal, initSessionRuntimeState, isHbtControlInPumper, isResetSeqNumFlagRequiredForInitLogon, 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, setFIXSessionOutOfSyncListener, setInSeqNum, setLastDisconnectReason, setOutOfTurnMode, setOutSeqNum, setPreLogoffSessionState, setRejectMessageListener, setSequenceNumbers, setSlowConsumerListener, shutdown, shutdown, 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

Field Details

NO_AUTORECONNECT

protected static final int NO_AUTORECONNECT

Constructor Details

AutoreconnectFIXSession

public AutoreconnectFIXSession(FIXMessageFactory factory,
 SessionParameters sessionParameters,
 HandlerChain fixSessionListener)

Method Details

initTransport

protected void initTransport()

Overrides:

initTransport in class InitiatorFIXSession

setFIXSessionListener

public void setFIXSessionListener(FIXSessionListener listener)

Description copied from interface: FIXSession

Sets FIXSession listener to monitor session status and receive incoming messages.

Specified by:

setFIXSessionListener in interface FIXSession

Overrides:

setFIXSessionListener in class AbstractFIXSession

Parameters:

listener - the user specified listener

See Also:

• FIXSession.setFIXSessionListener(FIXSessionListener)

disconnect

protected void disconnect(DisconnectReason reasonType,
 String reasonDescription,
 boolean isGracefull,
 boolean isForced,
 boolean continueReading)

Overrides:

disconnect in class AbstractFIXSession

startSession

protected void startSession()
                     throws IOException

Overrides:

startSession in class AbstractFIXSession

Throws:

IOException

connectInternal

protected void connectInternal()

Overrides:

connectInternal in class InitiatorFIXSession

switchToBackUp

public void switchToBackUp()

Description copied from interface: BackupFIXSession

The method, switch current connection to backup.

Specified by:

switchToBackUp in interface BackupFIXSession

switchToPrimary

public void switchToPrimary()

Description copied from interface: BackupFIXSession

The method, switch current connection to primary.

Specified by:

switchToPrimary in interface BackupFIXSession

isRunningOnBackup

public boolean isRunningOnBackup()

Description copied from interface: BackupFIXSession

Returns true, if session connected to backup host.

Specified by:

isRunningOnBackup in interface BackupFIXSession