public class FilterProxyConsumerTask extends AbstractFilterTask
arrayCurrentFilterStage_, EMPTY_FILTERSTAGElogger_| Constructor and Description |
|---|
FilterProxyConsumerTask(TaskFactory factory,
TaskExecutor executor) |
| Modifier and Type | Method and Description |
|---|---|
void |
doFilter() |
boolean |
getSkip()
access the Filter hint for next Stage.
|
void |
reset()
Reset the Object to an initial state.
|
void |
schedule()
Schedule this Task on its default Executor for execution.
|
java.lang.String |
toString() |
addFilterStage, addFilterStage, clearFilterStageToBeProcessed, doWork, getFilterStageToBeProcessed, getTaskFactory, handleTaskError, isFilterStageListEmpty, setCurrentFilterStagecheckInterrupt, copyMessage, dispose, getMessage, isRunnable, removeMessage, setMessagegetTaskExecutor, run, schedule, schedule, setTaskExecutorsetObjectPoolpublic FilterProxyConsumerTask(TaskFactory factory, TaskExecutor executor)
public java.lang.String toString()
toString in class java.lang.Objectpublic void reset()
AbstractPoolablereset in class AbstractFilterTaskpublic boolean getSkip()
public void doFilter()
throws java.lang.InterruptedException
doFilter in class AbstractFilterTaskjava.lang.InterruptedExceptionpublic void schedule()
AbstractFilterTaskschedule in interface Schedulableschedule in class AbstractFilterTask