public class ForcedHistoricalRecoveryManager extends AbstractManager implements RecoveryManager, ForcedRecoveryListener
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 |
context, recoveryTransport
Constructor and Description |
---|
ForcedHistoricalRecoveryManager(ChannelContext context) |
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) |
getMessageQueue, isRun, setRun
protected RecoveryListener recoveryListener
protected StreamTransport transport
public static final int MAX_REQUEST_DELTA_1_6
public static final int MAX_REQUEST_DELTA_2_0
public ForcedHistoricalRecoveryManager(ChannelContext context)
public void setRecoveryListener(RecoveryListener recoveryListener)
setRecoveryListener
in interface RecoveryManager
public void startRecovery(Instrument instrument, long beginMsgSeqNum, long endMsgSeqNum, ReplayListener replayListener, com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper, boolean forceSnapshotRecovery)
startRecovery
in interface RecoveryManager
protected List<Request> getRequests(long beginMsgSeqNum, long endMsgSeqNum, ReplayListener replayListener)
public void stopRecovery(Instrument instrument)
stopRecovery
in interface RecoveryManager
public void stopSnapshotRecovery(Instrument instrument)
public void stop()
stop
in interface RecoveryManager
public void doRecovery(long startSeqNum34, long endSeqNum34)
doRecovery
in interface ForcedRecoveryListener
Copyright © 2000-2017 EPAM Systems. All Rights Reserved.