public class GlobalTCPHistoricalRecoveryManager extends AbstractManager implements RecoveryManager, ForcedRecoveryListener
Modifier and Type | Field and Description |
---|---|
protected RecoveryListener |
recoveryListener |
protected StreamTransport |
transport |
context, recoveryTransport
Constructor and Description |
---|
GlobalTCPHistoricalRecoveryManager(ChannelContext context) |
GlobalTCPHistoricalRecoveryManager(ChannelContext context,
StreamTransport transport,
RecoveryListener recoveryListener) |
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 GlobalTCPHistoricalRecoveryManager(ChannelContext context)
public GlobalTCPHistoricalRecoveryManager(ChannelContext context, StreamTransport transport, RecoveryListener recoveryListener)
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.