com.epam.bovespafast.impl.manager.recovery

Class BovespaForcedGapFiller

java.lang.Object

com.epam.bovespafast.impl.manager.recovery.BovespaForcedGapFiller

All Implemented Interfaces:

com.epam.fast.full.coders.stream.GapListener

public class BovespaForcedGapFiller
extends Object
implements com.epam.fast.full.coders.stream.GapListener

Created by IntelliJ IDEA. User: wed Date: 27.03.12 Time: 6:25 To change this template use File | Settings | File Templates.

Field Summary

Fields

Modifier and Type	Field and Description
protected long	currentGapEnd
protected long	currentGapStart
protected com.epam.common.logging.Log	log
protected static int	RECOVERY_BLOCK_SIZE
protected int	recoveryBlockSize

Constructor Summary

Constructors

Constructor and Description
BovespaForcedGapFiller(String channelID, ForcedRecoveryListener recoveryListener)

Method Summary

Modifier and Type	Method and Description
void	onChecked(long lastChecked)
void	onGap(long start, long end)
protected void	runForcedRecovery(long start, long end)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

protected final com.epam.common.logging.Log log

RECOVERY_BLOCK_SIZE

protected static final int RECOVERY_BLOCK_SIZE

See Also:

Constant Field Values

currentGapStart

protected long currentGapStart

currentGapEnd

protected long currentGapEnd

recoveryBlockSize

protected int recoveryBlockSize

Constructor Detail

BovespaForcedGapFiller

public BovespaForcedGapFiller(String channelID,
                              ForcedRecoveryListener recoveryListener)

Method Detail

onGap

public void onGap(long start,
                  long end)

Specified by:

onGap in interface com.epam.fast.full.coders.stream.GapListener

onChecked

public void onChecked(long lastChecked)

Specified by:

onChecked in interface com.epam.fast.full.coders.stream.GapListener

runForcedRecovery

protected void runForcedRecovery(long start,
                                 long end)