public class ForcedGapFiller extends Object implements com.epam.fast.full.coders.stream.GapListener
Modifier and Type | Field and Description |
---|---|
protected ApplicationContext |
applicationContext |
protected String |
channelID |
protected long |
currentGapEnd |
protected long |
currentGapStart |
protected static Log |
log |
protected int |
recoveryBlockSize |
Modifier | Constructor and Description |
---|---|
|
ForcedGapFiller(ApplicationContext applicationContext,
String channelID) |
protected |
ForcedGapFiller(ApplicationContext applicationContext,
String channelID,
int recoveryBlockSize) |
Modifier and Type | Method and Description |
---|---|
void |
onChecked(long lastChecked) |
void |
onGap(long start,
long end) |
protected void |
runForcedRecovery(long start,
long end) |
protected static final Log log
protected final ApplicationContext applicationContext
protected final String channelID
protected long currentGapStart
protected long currentGapEnd
protected int recoveryBlockSize
public ForcedGapFiller(ApplicationContext applicationContext, String channelID)
protected ForcedGapFiller(ApplicationContext applicationContext, String channelID, int recoveryBlockSize)
public void onGap(long start, long end)
onGap
in interface com.epam.fast.full.coders.stream.GapListener
protected void runForcedRecovery(long start, long end)
public void onChecked(long lastChecked)
onChecked
in interface com.epam.fast.full.coders.stream.GapListener
Copyright © 2000-2017 EPAM Systems. All Rights Reserved.