org.jacorb.notification.engine
Class FilterProxySupplierTask

java.lang.Object
  org.jacorb.notification.interfaces.AbstractPoolable
      org.jacorb.notification.engine.AbstractTask
          org.jacorb.notification.engine.FilterProxySupplierTask

All Implemented Interfaces:

java.lang.Runnable, org.apache.avalon.framework.configuration.Configurable, Disposable

public class FilterProxySupplierTask
extends AbstractTask

Version:

$Id: FilterProxySupplierTask.java,v 1.12 2004/05/06 12:39:59 nicolas Exp $

Author:

Alphonse Bendt

Field Summary

protected FilterStage[]	arrayCurrentFilterStage_ FilterStages to process.
static org.jacorb.notification.engine.FilterProxySupplierTask.AlternateMessageMap	EMPTY_MAP
protected static FilterStage[]	FILTERSTAGE_ARRAY_TEMPLATE Template for internal use.

Fields inherited from class org.jacorb.notification.engine.AbstractTask

message_

Fields inherited from class org.jacorb.notification.interfaces.AbstractPoolable

logger_

Method Summary

protected void	addFilterStage(FilterStage s)
protected void	addFilterStage(java.util.List s)
void	clearFilterStageToBeProcessed() clear the result of the previous run.
void	doWork() Override this Method in Subclasses to do the "real work".
FilterStage[]	getFilterStageToBeProcessed() get the matching FilterStages of the previous run.
protected TaskFactory	getTaskFactory()
void	handleTaskError(AbstractTask task, java.lang.Throwable error)
protected boolean	isFilterStageListEmpty()
void	reset() Reset the Object to an initial state.
void	schedule() Schedule this Task on its default Executor for execution.
void	setCurrentFilterStage(FilterStage[] currentFilterStage) set the FilterStages for the next run.
void	setFilterStage(org.jacorb.notification.engine.AbstractFilterTask task) Initialize this FilterOutgoingTask with the Configuration of another FilterTask.
java.lang.String	toString()

Methods inherited from class org.jacorb.notification.engine.AbstractTask

checkInterrupt, copyMessage, getTaskExecutor, getTaskProcessor, removeMessage, run, schedule, schedule, setMessage, setTaskExecutor

Methods inherited from class org.jacorb.notification.interfaces.AbstractPoolable

configure, dispose, setObjectPool

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

EMPTY_MAP

public static final org.jacorb.notification.engine.FilterProxySupplierTask.AlternateMessageMap EMPTY_MAP

FILTERSTAGE_ARRAY_TEMPLATE

protected static final FilterStage[] FILTERSTAGE_ARRAY_TEMPLATE

Template for internal use.

arrayCurrentFilterStage_

protected FilterStage[] arrayCurrentFilterStage_

FilterStages to process.

Method Detail

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

setFilterStage

public void setFilterStage(org.jacorb.notification.engine.AbstractFilterTask task)

Initialize this FilterOutgoingTask with the Configuration of another FilterTask.

reset

public void reset()

Description copied from class: AbstractPoolable

Reset the Object to an initial state. Subclasses should override this method appropiately to reset the instance to an initial state.

doWork

public void doWork()
            throws java.lang.InterruptedException

Description copied from class: AbstractTask

Override this Method in Subclasses to do the "real work".

Specified by:

doWork in class AbstractTask

Throws:

java.lang.InterruptedException

getTaskFactory

protected TaskFactory getTaskFactory()

isFilterStageListEmpty

protected boolean isFilterStageListEmpty()

addFilterStage

protected void addFilterStage(FilterStage s)

addFilterStage

protected void addFilterStage(java.util.List s)

setCurrentFilterStage

public void setCurrentFilterStage(FilterStage[] currentFilterStage)

set the FilterStages for the next run.

getFilterStageToBeProcessed

public FilterStage[] getFilterStageToBeProcessed()

get the matching FilterStages of the previous run.

clearFilterStageToBeProcessed

public void clearFilterStageToBeProcessed()

clear the result of the previous run.

handleTaskError

public void handleTaskError(AbstractTask task,
                            java.lang.Throwable error)

schedule

public void schedule()
              throws java.lang.InterruptedException

Schedule this Task on its default Executor for execution.

Specified by:

schedule in class AbstractTask

Throws:

java.lang.InterruptedException