|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jacorb.notification.interfaces.AbstractPoolable
org.jacorb.notification.engine.AbstractTask
org.jacorb.notification.engine.AbstractFilterTask
org.jacorb.notification.engine.FilterProxySupplierTask
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 |
public static final org.jacorb.notification.engine.FilterProxySupplierTask.AlternateMessageMap EMPTY_MAP
protected static final FilterStage[] FILTERSTAGE_ARRAY_TEMPLATE
protected FilterStage[] arrayCurrentFilterStage_
Method Detail |
public java.lang.String toString()
public void setFilterStage(org.jacorb.notification.engine.AbstractFilterTask task)
public void reset()
AbstractPoolable
public void doWork() throws java.lang.InterruptedException
AbstractTask
doWork
in class AbstractTask
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 handleTaskError(AbstractTask task, java.lang.Throwable error)
public void schedule() throws java.lang.InterruptedException
schedule
in class AbstractTask
java.lang.InterruptedException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |