org.jacorb.notification.engine
Class FilterProxyConsumerTask

java.lang.Object
  extended byorg.jacorb.notification.interfaces.AbstractPoolable
      extended byorg.jacorb.notification.engine.AbstractTask
          extended byorg.jacorb.notification.engine.AbstractFilterTask
              extended byorg.jacorb.notification.engine.FilterProxyConsumerTask
All Implemented Interfaces:
org.apache.avalon.framework.configuration.Configurable, Disposable, java.lang.Runnable

public class FilterProxyConsumerTask
extends org.jacorb.notification.engine.AbstractFilterTask

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()

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
Description copied from class: org.jacorb.notification.engine.AbstractFilterTask
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)