public class FilterProxyConsumerTask extends AbstractFilterTask
arrayCurrentFilterStage_, EMPTY_FILTERSTAGE
logger_
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, setCurrentFilterStage
checkInterrupt, copyMessage, dispose, getMessage, isRunnable, removeMessage, setMessage
getTaskExecutor, run, schedule, schedule, setTaskExecutor
setObjectPool
public FilterProxyConsumerTask(TaskFactory factory, TaskExecutor executor)
public java.lang.String toString()
toString
in class java.lang.Object
public void reset()
AbstractPoolable
reset
in class AbstractFilterTask
public boolean getSkip()
public void doFilter() throws java.lang.InterruptedException
doFilter
in class AbstractFilterTask
java.lang.InterruptedException
public void schedule()
AbstractFilterTask
schedule
in interface Schedulable
schedule
in class AbstractFilterTask