org.jacorb.notification.engine
Class FilterProxyConsumerTask

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

All Implemented Interfaces:

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

public class FilterProxyConsumerTask
extends AbstractTask

Version:

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

Author:

Alphonse Bendt

Field Summary

protected FilterStage[]	arrayCurrentFilterStage_ FilterStages to process.
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.
boolean	getSkip() access the Filter hint for next Stage. if the current FilterStage has InterFilterGroupOperator.OR_OP enabled and a filter matched the evaluation of the SupplierAdmin Filters can be skipped.
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.
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

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

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.

getSkip

public boolean getSkip()

access the Filter hint for next Stage. if the current FilterStage has InterFilterGroupOperator.OR_OP enabled and a filter matched the evaluation of the SupplierAdmin Filters can be skipped.

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

schedule

public void schedule()
              throws java.lang.InterruptedException

Schedule this Task on its default Executor for execution.

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)