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 void	addFilterStage(FilterStage s)
protected void	addFilterStage(List s)
void	clearFilterStageToBeProcessed() clear the result of the previous run.
protected abstract void	doFilter()
void	doWork()
FilterStage[]	getFilterStageToBeProcessed() get the matching FilterStages of the previous run.
protected TaskFactory	getTaskFactory()
void	handleTaskError(AbstractTask task, Exception error)
protected boolean	isFilterStageListEmpty()
void	reset()
void	schedule() Schedule this Task on its default Executor for execution.
void	setCurrentFilterStage(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.