public class SnapshotRecoveryStreamManager extends AbstractManager
Modifier and Type | Field and Description |
---|---|
protected RecoveryListener |
recoveryListener |
context, log, recoveryTransport
Constructor and Description |
---|
SnapshotRecoveryStreamManager(ChannelContext context) |
Modifier and Type | Method and Description |
---|---|
void |
setRecoveryListener(RecoveryListener recoveryListener) |
void |
startRecovery(Instrument instrument,
long beginMsgSeqNum34,
long endMsgSeqNum34,
ReplayListener recoveryListener,
com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper,
boolean forceSnapshotRecovery) |
void |
stop() |
void |
stopRecovery(Instrument instrument) |
getMessageQueue, isRun, setRun
protected RecoveryListener recoveryListener
public SnapshotRecoveryStreamManager(ChannelContext context)
public void setRecoveryListener(RecoveryListener recoveryListener)
public void startRecovery(Instrument instrument, long beginMsgSeqNum34, long endMsgSeqNum34, ReplayListener recoveryListener, com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper, boolean forceSnapshotRecovery)
public void stopRecovery(Instrument instrument)
public void stop()
Copyright © 2000-2017 EPAM Systems. All Rights Reserved.