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.
|
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 void reset()
AbstractPoolable
reset
in class AbstractFilterTask
public void doFilter() throws InterruptedException
doFilter
in class AbstractFilterTask
InterruptedException
Copyright © 2016 JacORB. All rights reserved.