com.epam.cmefast.impl

Class ForcedGapFiller

java.lang.Object

com.epam.cmefast.impl.ForcedGapFiller

All Implemented Interfaces:

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

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

Created by IntelliJ IDEA. User: Alexander_Sereda Date: 23.12.11 Time: 11:35 To change this template use File | Settings | File Templates.

Field Summary

Fields

Modifier and Type	Field and Description
protected ApplicationContext	applicationContext
protected String	channelID
protected long	currentGapEnd
protected long	currentGapStart
protected static com.epam.common.logging.Log	log
protected int	recoveryBlockSize

Constructor Summary

Constructors

Modifier	Constructor and Description
	ForcedGapFiller(ApplicationContext applicationContext, String channelID)
protected	ForcedGapFiller(ApplicationContext applicationContext, String channelID, int recoveryBlockSize)

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 static final com.epam.common.logging.Log log

applicationContext

protected final ApplicationContext applicationContext

channelID

protected final String channelID

currentGapStart

protected long currentGapStart

currentGapEnd

protected long currentGapEnd

recoveryBlockSize

protected int recoveryBlockSize

Constructor Detail

ForcedGapFiller

public ForcedGapFiller(ApplicationContext applicationContext,
                       String channelID)

ForcedGapFiller

protected ForcedGapFiller(ApplicationContext applicationContext,
                          String channelID,
                          int recoveryBlockSize)

Method Detail

onGap

public void onGap(long start,
                  long end)

Specified by:

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

runForcedRecovery

protected void runForcedRecovery(long start,
                                 long end)

onChecked

public void onChecked(long lastChecked)

Specified by:

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