com.epam.bovespafast.impl.manager.recovery

Class ForcedHistoricalRecoveryManager

java.lang.Object

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

com.epam.bovespafast.impl.manager.recovery.ForcedHistoricalRecoveryManager

All Implemented Interfaces:

ForcedRecoveryListener, RecoveryManager

public class ForcedHistoricalRecoveryManager
extends AbstractManager
implements RecoveryManager, ForcedRecoveryListener

Created by IntelliJ IDEA. User: wed Date: 21.03.12 Time: 12:11 To change this template use File | Settings | File Templates.

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

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

context, recoveryTransport

Constructor Summary

Constructors

Constructor and Description
ForcedHistoricalRecoveryManager(ChannelContext context)

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

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

Constructor Detail

ForcedHistoricalRecoveryManager

public ForcedHistoricalRecoveryManager(ChannelContext context)

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