public class FilterProxySupplierTask extends AbstractFilterTask
Modifier and Type | Field and Description |
---|---|
static org.jacorb.notification.engine.FilterProxySupplierTask.AlternateMessageMap |
EMPTY_MAP |
arrayCurrentFilterStage_, EMPTY_FILTERSTAGE
logger_
Constructor and Description |
---|
FilterProxySupplierTask(TaskFactory taskFactory,
TaskExecutor taskExecutor) |
Modifier and Type | Method and Description |
---|---|
void |
doFilter() |
void |
reset()
Reset the Object to an initial state.
|
java.lang.String |
toString() |
addFilterStage, addFilterStage, clearFilterStageToBeProcessed, doWork, getFilterStageToBeProcessed, getTaskFactory, handleTaskError, isFilterStageListEmpty, schedule, setCurrentFilterStage
checkInterrupt, copyMessage, dispose, getMessage, isRunnable, removeMessage, setMessage
getTaskExecutor, run, schedule, schedule, setTaskExecutor
setObjectPool
public static final org.jacorb.notification.engine.FilterProxySupplierTask.AlternateMessageMap EMPTY_MAP
public FilterProxySupplierTask(TaskFactory taskFactory, TaskExecutor taskExecutor)
public java.lang.String toString()
toString
in class java.lang.Object
public void reset()
AbstractPoolable
reset
in class AbstractFilterTask
public void doFilter() throws java.lang.InterruptedException
doFilter
in class AbstractFilterTask
java.lang.InterruptedException