public class HistoricalRecoveryManager extends AbstractManager implements RecoveryManager
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 |
context, log, recoveryTransport
Constructor and Description |
---|
HistoricalRecoveryManager(ChannelContext context) |
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) |
getMessageQueue, isRun, setRun
public static final int UNLIMITED_GAP
public static final int MAX_REQUEST_DELTA_1_6
public static final int MAX_REQUEST_DELTA_2_0
protected RecoveryListener recoveryListener
protected StreamTransport transport
public HistoricalRecoveryManager(ChannelContext context)
public void setRecoveryListener(RecoveryListener recoveryListener)
setRecoveryListener
in interface RecoveryManager
public void setMaxRequestDelta(long maxRequestDelta)
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, com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper)
public void stopRecovery(Instrument instrument)
stopRecovery
in interface RecoveryManager
public void stopSnapshotRecovery(Instrument instrument)
public void stop()
stop
in interface RecoveryManager
Copyright © 2000-2017 EPAM Systems. All Rights Reserved.