com.epam.bovespafast.impl.manager.recovery

Class HistoricalRecoveryManager

java.lang.Object

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

com.epam.bovespafast.impl.manager.recovery.HistoricalRecoveryManager

All Implemented Interfaces:

RecoveryManager

public class HistoricalRecoveryManager
extends AbstractManager
implements RecoveryManager

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_REQUEST_DELTA_1_6
static int	MAX_REQUEST_DELTA_2_0
protected RecoveryListener	recoveryListener
protected StreamTransport	transport
static int	UNLIMITED_GAP

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

context, log, recoveryTransport

Constructor Summary

Constructors

Constructor and Description
HistoricalRecoveryManager(ChannelContext context)

Method Summary

Modifier and Type	Method and Description
protected List<Request>	getRequests(long beginMsgSeqNum, long endMsgSeqNum, ReplayListener replayListener, com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper)
void	setMaxRequestDelta(long maxRequestDelta)
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

UNLIMITED_GAP

public static final int UNLIMITED_GAP

See Also:

Constant Field Values

MAX_REQUEST_DELTA_1_6

public static final int MAX_REQUEST_DELTA_1_6

See Also:

Constant Field Values

MAX_REQUEST_DELTA_2_0

public static final int MAX_REQUEST_DELTA_2_0

See Also:

Constant Field Values

recoveryListener

protected RecoveryListener recoveryListener

transport

protected StreamTransport transport

Constructor Detail

HistoricalRecoveryManager

public HistoricalRecoveryManager(ChannelContext context)

Method Detail

setRecoveryListener

public void setRecoveryListener(RecoveryListener recoveryListener)

Specified by:

setRecoveryListener in interface RecoveryManager

setMaxRequestDelta

public void setMaxRequestDelta(long maxRequestDelta)

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,
                                    com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper)

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