|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.rhi.architecture.parc.filter.AbstractFilter
com.rhi.architecture.parc.filter.PollingFilter
PollingFilter.java
Field Summary | |
static java.lang.String |
CYCLE_SLEEP_TIME_FLAG
time to sleep between polling. |
static java.lang.String |
DEFAULT_SLEEP_TIME
default sleep time between polls |
Constructor Summary | |
PollingFilter()
Constructor for PollingFilter. |
|
PollingFilter(int max)
Constructor for PollingFilter. |
Method Summary | |
void |
init(java.util.Properties p)
Initialize common Filter settings. |
void |
process()
Push a collection of records through the filter. |
Methods inherited from class com.rhi.architecture.parc.filter.AbstractFilter |
doWork, getErrorChannel, getExceptionHandler, getInbound, getMaxRecords, getName, getOutbound, isShutdown, log, markForDeath, numThreads, reset, run, setErrorChannel, setExceptionHandler, setInbound, setMaxRecords, setNumThreads, setOutbound, stats |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
public static final java.lang.String CYCLE_SLEEP_TIME_FLAG
public static final java.lang.String DEFAULT_SLEEP_TIME
Constructor Detail |
public PollingFilter()
public PollingFilter(int max)
max
- Method Detail |
public void init(java.util.Properties p) throws InitializationException
AbstractFilter
init
in interface Filter
init
in class AbstractFilter
p
-
InitializationException
Filter.init(Properties)
public void process() throws ProcessingException
InboundChannel.pull();
doWork()
OutboundChannel.push();
This method must be threadsafe as it is the fundamental multi-processing hook in the framework.
ProcessingException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |