|
||||||||||
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.FilterConsumerAdminTask
public class FilterConsumerAdminTask
Field Summary | |
---|---|
protected FilterStage[] |
arrayCurrentFilterStage_
FilterStages to process. |
protected static FilterStage[] |
FILTERSTAGE_ARRAY_TEMPLATE
Template for internal use. |
protected java.util.List |
listOfFilterStageWithMessageConsumer_
this List contains FilterStages (ProxySuppliers) which have a MessageConsumer associated. |
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[] |
getFilterStagesWithMessageConsumer()
access the FilterStages that have a Event Consumer associated. |
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 other)
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 |
---|
protected java.util.List listOfFilterStageWithMessageConsumer_
protected static final FilterStage[] FILTERSTAGE_ARRAY_TEMPLATE
protected FilterStage[] arrayCurrentFilterStage_
Method Detail |
---|
public java.lang.String toString()
toString
in class java.lang.Object
public void setFilterStage(org.jacorb.notification.engine.AbstractFilterTask other)
public FilterStage[] getFilterStagesWithMessageConsumer()
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 |