com.continuent.tungsten.replicator.pipeline
Interface StageTask

All Superinterfaces:

java.lang.Runnable

public interface StageTask
extends java.lang.Runnable

Denotes a Runnable task that implements stage processing. Set methods are called before the run() method.

Version:

1.0

Author:

Robert Hodges

Method Summary

void	setApplySkipCount(long applySkipCount) Sets number of apply operations to skip at start-up.
void	setApplySkipSeqnos(java.util.SortedSet<java.lang.Long> seqnosToBeSkipped)
void	setEventDispatcher(com.continuent.tungsten.fsm.event.EventDispatcher eventDispatcher) Provides an event dispatcher to log error.
void	setSchedule(Schedule schedule) Sets the schedule, which controls task cancellation.
void	setStage(Stage stage) Provides the stage instance that this runnable operates on.

Methods inherited from interface java.lang.Runnable

run

Method Detail

setStage

void setStage(Stage stage)

Provides the stage instance that this runnable operates on.

setEventDispatcher

void setEventDispatcher(com.continuent.tungsten.fsm.event.EventDispatcher eventDispatcher)

Provides an event dispatcher to log error.

setApplySkipCount

void setApplySkipCount(long applySkipCount)

Sets number of apply operations to skip at start-up.

setSchedule

void setSchedule(Schedule schedule)

Sets the schedule, which controls task cancellation.

setApplySkipSeqnos

void setApplySkipSeqnos(java.util.SortedSet<java.lang.Long> seqnosToBeSkipped)