|
|||||||||||
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.FilterSet
FilterSet. Composite element of GOF pattern. Note: Since it's just a container, it has been marked as final. No sub-classing should be required.
Constructor Summary | |
FilterSet()
Default constructor. |
Method Summary | |
void |
addNode(Filter f)
Add a new filter to the set. |
void |
addNode(Filter f,
Channel c)
Add a new filter to the set. |
ExceptionHandler |
getExceptionHandler()
|
java.lang.String |
getName()
Return the name of this Filter. |
void |
init(java.util.Properties p)
Initialize any local resources |
void |
markForDeath()
markForDeath sets a flag telling the Filter to shutdown at the next available opportunity. |
int |
numThreads()
Return the suggested number of threads to launch for this Filter. |
void |
process()
do filter processing. |
void |
reset()
Reset the filter so that it's ready to process records again. |
void |
run()
Runnable interface |
void |
setErrorChannel(Consumer err)
Set the holding bin used for errored records.. |
void |
setExceptionHandler(ExceptionHandler handler)
Set the exception handler mechanism. |
void |
setInbound(Supplier s)
Set the inbound delivery mechanism. |
void |
setOutbound(Consumer c)
Set the outbound delivery mechanism. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public FilterSet()
Method Detail |
public void init(java.util.Properties p) throws InitializationException
init
in interface Filter
p
-
InitializationException
public java.lang.String getName()
getName
in interface Filter
public void addNode(Filter f)
f
- Filter to be added to collectionpublic void addNode(Filter f, Channel c)
Channel
parameter can be provided as
the preferred Channel implementation for the outbound side of
this filter.
f
- Filter to be added to collectionc
- Channel to be used on outbound side of this filter.public void process() throws ProcessingException
process
in interface Filter
ProcessingException
public void markForDeath()
markForDeath
in interface Filter
public void reset()
reset
in interface Filter
public void run()
run
in interface java.lang.Runnable
public void setInbound(Supplier s)
setInbound
in interface Filter
s
- public void setOutbound(Consumer c)
setOutbound
in interface Filter
c
- public void setErrorChannel(Consumer err)
setErrorChannel
in interface Filter
err
- public void setExceptionHandler(ExceptionHandler handler)
setExceptionHandler
in interface Filter
handler
- public ExceptionHandler getExceptionHandler()
public int numThreads()
numThreads
in interface Filter
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |