com.epam.bovespafast.impl.manager.recovery

Class GlobalTCPHistoricalRecoveryManager

java.lang.Object

com.epam.bovespafast.impl.manager.recovery.AbstractManager

com.epam.bovespafast.impl.manager.recovery.GlobalTCPHistoricalRecoveryManager

All Implemented Interfaces:

ForcedRecoveryListener, RecoveryManager

public class GlobalTCPHistoricalRecoveryManager
extends AbstractManager
implements RecoveryManager, ForcedRecoveryListener

The class which implements Global TCP Historical Replay functionality. The TCP Historical Replay feed allows querying messages up to 24 hours in the past, for charting purposes. The response time for this feed is considerably slower than TCP Recovery, as it should not be used for any other purpose than charting. The message format is exactly the same as TCP Recovery, without the 10000 message limitation (limited to what is available to the replay component.

Since:

2.0, 10.15.13

Author:

Alexander_Lukashevich

Field Summary

Fields

Modifier and Type	Field and Description
protected RecoveryListener	recoveryListener
protected StreamTransport	transport

Fields inherited from class com.epam.bovespafast.impl.manager.recovery.AbstractManager

context, recoveryTransport

Constructor Summary

Constructors

Constructor and Description
GlobalTCPHistoricalRecoveryManager(ChannelContext context)
GlobalTCPHistoricalRecoveryManager(ChannelContext context, StreamTransport transport, RecoveryListener recoveryListener)

Method Summary

Modifier and Type	Method and Description
void	doRecovery(long startSeqNum34, long endSeqNum34)
protected List<Request>	getRequests(long beginMsgSeqNum, long endMsgSeqNum, ReplayListener replayListener)
void	setRecoveryListener(RecoveryListener recoveryListener)
void	startRecovery(Instrument instrument, long beginMsgSeqNum, long endMsgSeqNum, ReplayListener replayListener, com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper, boolean forceSnapshotRecovery)
void	stop()
void	stopRecovery(Instrument instrument)
void	stopSnapshotRecovery(Instrument instrument)

Methods inherited from class com.epam.bovespafast.impl.manager.recovery.AbstractManager

getMessageQueue, isRun, setRun

Methods inherited from class java.lang.Object

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

Field Detail

recoveryListener

protected RecoveryListener recoveryListener

transport

protected StreamTransport transport

Constructor Detail

GlobalTCPHistoricalRecoveryManager

public GlobalTCPHistoricalRecoveryManager(ChannelContext context)

GlobalTCPHistoricalRecoveryManager

public GlobalTCPHistoricalRecoveryManager(ChannelContext context,
                                          StreamTransport transport,
                                          RecoveryListener recoveryListener)

Method Detail

setRecoveryListener

public void setRecoveryListener(RecoveryListener recoveryListener)

Specified by:

setRecoveryListener in interface RecoveryManager

startRecovery

public void startRecovery(Instrument instrument,
                          long beginMsgSeqNum,
                          long endMsgSeqNum,
                          ReplayListener replayListener,
                          com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper,
                          boolean forceSnapshotRecovery)

Specified by:

startRecovery in interface RecoveryManager

getRequests

protected List<Request> getRequests(long beginMsgSeqNum,
                                    long endMsgSeqNum,
                                    ReplayListener replayListener)

stopRecovery

public void stopRecovery(Instrument instrument)

Specified by:

stopRecovery in interface RecoveryManager

stopSnapshotRecovery

public void stopSnapshotRecovery(Instrument instrument)

stop

public void stop()

Specified by:

stop in interface RecoveryManager

doRecovery

public void doRecovery(long startSeqNum34,
                       long endSeqNum34)

Specified by:

doRecovery in interface ForcedRecoveryListener