|
||||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jacorb.notification.util.AbstractPoolable
org.jacorb.notification.engine.AbstractTask
org.jacorb.notification.engine.AbstractMessageTask
org.jacorb.notification.engine.AbstractFilterTask
Field Summary | |
---|---|
protected FilterStage[] |
arrayCurrentFilterStage_
FilterStages to process. |
protected static FilterStage[] |
EMPTY_FILTERSTAGE
empty default value for field arrayCurrentFilterStage_. its used instead of null |
Fields inherited from class org.jacorb.notification.util.AbstractPoolable |
---|
logger_ |
Constructor Summary | |
---|---|
protected |
AbstractFilterTask(TaskFactory taskFactory,
TaskExecutor taskExecutor)
|
Method Summary | |
---|---|
protected void |
addFilterStage(FilterStage s)
|
protected void |
addFilterStage(java.util.List s)
|
void |
clearFilterStageToBeProcessed()
clear the result of the previous run. |
protected abstract void |
doFilter()
|
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.Exception 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. |
Methods inherited from class org.jacorb.notification.engine.AbstractMessageTask |
---|
checkInterrupt, copyMessage, dispose, getMessage, isRunnable, removeMessage, setMessage |
Methods inherited from class org.jacorb.notification.engine.AbstractTask |
---|
getTaskExecutor, run, schedule, schedule, setTaskExecutor |
Methods inherited from class org.jacorb.notification.util.AbstractPoolable |
---|
setObjectPool |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected static final FilterStage[] EMPTY_FILTERSTAGE
protected FilterStage[] arrayCurrentFilterStage_
Constructor Detail |
protected AbstractFilterTask(TaskFactory taskFactory, TaskExecutor taskExecutor)
Method Detail |
public final void doWork() throws java.lang.InterruptedException
AbstractTask
doWork
in class AbstractTask
java.lang.InterruptedException
protected abstract void doFilter() throws java.lang.InterruptedException
java.lang.InterruptedException
protected TaskFactory getTaskFactory()
protected boolean isFilterStageListEmpty()
protected void addFilterStage(FilterStage s)
protected void addFilterStage(java.util.List s)
public void setCurrentFilterStage(FilterStage[] currentFilterStage)
public FilterStage[] getFilterStageToBeProcessed()
public void clearFilterStageToBeProcessed()
public void reset()
AbstractPoolable
reset
in class AbstractMessageTask
public void handleTaskError(AbstractTask task, java.lang.Exception error)
task
- the task that caused the error.error
- the exception that was thrown.public void schedule()
|
||||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |