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