com.epam.cmemdp.impl
Class ForcedGapFiller

java.lang.Object
  com.epam.cmemdp.impl.ForcedGapFiller

All Implemented Interfaces:

com.epam.mdp.full.coders.stream.GapListener

public class ForcedGapFiller
extends java.lang.Object
implements com.epam.mdp.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

protected ApplicationContext	applicationContext
protected java.lang.String	channelID
protected long	currentGapEnd
protected long	currentGapStart
protected static Log	log
protected int	recoveryBlockSize

Constructor Summary

	ForcedGapFiller(ApplicationContext applicationContext, java.lang.String channelID)
protected	ForcedGapFiller(ApplicationContext applicationContext, java.lang.String channelID, int recoveryBlockSize)

Method Summary

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 Log log

applicationContext

protected final ApplicationContext applicationContext

channelID

protected final java.lang.String channelID

currentGapStart

protected long currentGapStart

currentGapEnd

protected long currentGapEnd

recoveryBlockSize

protected int recoveryBlockSize

Constructor Detail

ForcedGapFiller

public ForcedGapFiller(ApplicationContext applicationContext,
                       java.lang.String channelID)

ForcedGapFiller

protected ForcedGapFiller(ApplicationContext applicationContext,
                          java.lang.String channelID,
                          int recoveryBlockSize)

Method Detail

onGap

public void onGap(long start,
                  long end)

Specified by:

onGap in interface com.epam.mdp.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.mdp.full.coders.stream.GapListener