org.jacorb.notification.engine

Class AbstractFilterTask

public abstract class AbstractFilterTask extends AbstractMessageTask

Version: $Id: AbstractFilterTask.java,v 1.17 2005/11/11 19:37:44 alphonse.bendt Exp $

Author: Alphonse Bendt

Field Summary
protected FilterStage[]arrayCurrentFilterStage_
FilterStages to process.
protected static FilterStage[]EMPTY_FILTERSTAGE
empty default value for field arrayCurrentFilterStage_. its used instead of null
Constructor Summary
protected AbstractFilterTask(TaskFactory taskFactory, TaskExecutor taskExecutor)
Method Summary
protected voidaddFilterStage(FilterStage s)
protected voidaddFilterStage(List s)
voidclearFilterStageToBeProcessed()
clear the result of the previous run.
protected abstract voiddoFilter()
voiddoWork()
FilterStage[]getFilterStageToBeProcessed()
get the matching FilterStages of the previous run.
protected TaskFactorygetTaskFactory()
voidhandleTaskError(AbstractTask task, Exception error)
protected booleanisFilterStageListEmpty()
voidreset()
voidschedule()
Schedule this Task on its default Executor for execution.
voidsetCurrentFilterStage(FilterStage[] currentFilterStage)
set the FilterStages for the next run.

Field Detail

arrayCurrentFilterStage_

protected FilterStage[] arrayCurrentFilterStage_
FilterStages to process.

EMPTY_FILTERSTAGE

protected static final FilterStage[] EMPTY_FILTERSTAGE
empty default value for field arrayCurrentFilterStage_. its used instead of null

Constructor Detail

AbstractFilterTask

protected AbstractFilterTask(TaskFactory taskFactory, TaskExecutor taskExecutor)

Method Detail

addFilterStage

protected void addFilterStage(FilterStage s)

addFilterStage

protected void addFilterStage(List s)

clearFilterStageToBeProcessed

public void clearFilterStageToBeProcessed()
clear the result of the previous run.

doFilter

protected abstract void doFilter()

doWork

public final void doWork()

getFilterStageToBeProcessed

public FilterStage[] getFilterStageToBeProcessed()
get the matching FilterStages of the previous run.

getTaskFactory

protected TaskFactory getTaskFactory()

handleTaskError

public void handleTaskError(AbstractTask task, Exception error)

isFilterStageListEmpty

protected boolean isFilterStageListEmpty()

reset

public void reset()

schedule

public void schedule()
Schedule this Task on its default Executor for execution.

setCurrentFilterStage

public void setCurrentFilterStage(FilterStage[] currentFilterStage)
set the FilterStages for the next run.