com.epam.fixengine.session
Class BackupFIXSession

java.lang.Object
  com.epam.fixengine.session.AbstractFIXSession
      com.epam.fixengine.session.InitiatorFIXSession
          com.epam.fixengine.session.BackupFIXSession

All Implemented Interfaces:

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

public abstract class BackupFIXSession
extends InitiatorFIXSession

The BackupFIXSession provides ability to switch the connection from the primary host to backup and vice versa.
The backup session should configured by engine.properties and default.properties configuration files.

Field Summary

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

configuration, listener, log, messageFactory, queue, sessionLock, sessionParameters, transport

Constructor Summary

BackupFIXSession(FIXMessageFactory factory, SessionParameters sessionParameters, HandlerChain fixSessionListener)

Method Summary

void	connect() Connects to remote counterparty, if initiator or accepts incoming connection if acceptor.
protected int	getAttempt() Gets current connection attempts.
protected void	incrementAttempt() The synchronized method to increment attempt.
protected boolean	isBackupInitiator()
boolean	isRunningOnBackup() Returns true, if session connected to backup host.
protected void	setAttempt(int attempt) Sets current connection attempts.
protected void	setBackupInitiator(boolean backupInitiator)
void	setFIXSessionListener(FIXSessionListener listener) Sets FIXSession listener to monitor session status and receive incoming messages.
protected void	setRunningOnBackup(Boolean value) Sets the connection state.
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

connectInternal, disconnect, dispose, getTransport

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

addSessionStateListener, checkHasSessionSendOrReceivedTestRequest, clearQueue, disconnectTestRequestIsLost, equals, getAttribute, getBytesRead, getBytesSent, getEncryption, getErrorHandler, getEstablished, getExtendedFIXSessionListener, getIncomingMessageStorage, getLastInMessageTimestamp, getLastOutMessageTimestamp, getMessageFactory, getMessageHandlers, getMessageValidator, getNoOfInMessages, getNoOfOutMessages, getOutgoingMessageStorage, getRejectMessageListener, getSequenceManager, getSessionParameters, getSessionParametersInstance, getSessionState, getStorageFactory, hashCode, initSession, initSessionInternal, isResetTimeMissed, loadSessionParametersFromFile, markShutdownAsGraceful, removeAttribute, removeSessionStateListener, resetSequenceNumbers, resetSequenceNumbers, restoreSessionAfterReceivedTestRequest, restoreSessionParameters, saveSessionParameters, sendAsIs, sendMessage, sendMessage, sendMessageOutOfTurn, sendTestRequest, sendWithChanges, setAttribute, setErrorHandler, setOutOfTurnMode, setRejectMessageListener, setSessionState, shutdown, startSession, storeProcessedSeqNumber, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

BackupFIXSession

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

Method Detail

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

Overrides:

connect in class InitiatorFIXSession

Throws:

IOException - I/O exception if error occurred

getAttempt

protected int getAttempt()

Gets current connection attempts.

setAttempt

protected void setAttempt(int attempt)

Sets current connection attempts.

Parameters:

attempt - the current connection attempt

incrementAttempt

protected void incrementAttempt()

The synchronized method to increment attempt.

isBackupInitiator

protected boolean isBackupInitiator()

setBackupInitiator

protected void setBackupInitiator(boolean backupInitiator)

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)

isRunningOnBackup

public boolean isRunningOnBackup()

Returns true, if session connected to backup host.

setRunningOnBackup

protected void setRunningOnBackup(Boolean value)

Sets the connection state.

Parameters:

value - the new value

switchToBackUp

public void switchToBackUp()

The method, switch current connection to backup.

switchToPrimary

public void switchToPrimary()

The method, switch current connection to primary.