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.
|
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 void reset()
AbstractPoolable
reset
in class AbstractFilterTask
public boolean getSkip()
public void doFilter() throws InterruptedException
doFilter
in class AbstractFilterTask
InterruptedException
public void schedule()
AbstractFilterTask
schedule
in interface Schedulable
schedule
in class AbstractFilterTask
Copyright © 2017 JacORB. All rights reserved.