org.apache.hivemind.lib.pipeline
Class PipelineAssembler
java.lang.Object
org.apache.hivemind.impl.BaseLocatable
org.apache.hivemind.lib.pipeline.PipelineAssembler
- All Implemented Interfaces:
- org.apache.hivemind.Locatable, org.apache.hivemind.LocationHolder
public class PipelineAssembler
- extends org.apache.hivemind.impl.BaseLocatable
Used by the PipelineFactory to assemble the pipeline.
- Author:
- Howard Lewis Ship
|
Constructor Summary |
PipelineAssembler(org.apache.hivemind.ErrorLog errorLog,
java.lang.String serviceId,
java.lang.Class serviceInterface,
java.lang.Class filterInterface,
org.apache.hivemind.service.ClassFactory classFactory,
DefaultImplementationBuilder defaultBuilder)
|
|
Method Summary |
void |
addFilter(java.lang.String name,
java.lang.String prereqs,
java.lang.String postreqs,
java.lang.Object filter,
org.apache.hivemind.Location location)
|
java.lang.Object |
createPipeline()
Returns an object that implements the service interface, and integrates any filters for the
pipeline with the |
void |
setTerminator(java.lang.Object terminator,
org.apache.hivemind.Location terminatorLocation)
|
| Methods inherited from class org.apache.hivemind.impl.BaseLocatable |
getLocation, setLocation |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
PipelineAssembler
public PipelineAssembler(org.apache.hivemind.ErrorLog errorLog,
java.lang.String serviceId,
java.lang.Class serviceInterface,
java.lang.Class filterInterface,
org.apache.hivemind.service.ClassFactory classFactory,
DefaultImplementationBuilder defaultBuilder)
- Parameters:
errorLog - used for reporting recoverable errorsserviceInterface - the main interfacefilterInterface - the interface for filtersclassFactory - for creating new classesdefaultBuilder - used to provide a placeholder terminator if no real terminator is suppliedservceId - of the service being assembled
addFilter
public void addFilter(java.lang.String name,
java.lang.String prereqs,
java.lang.String postreqs,
java.lang.Object filter,
org.apache.hivemind.Location location)
setTerminator
public void setTerminator(java.lang.Object terminator,
org.apache.hivemind.Location terminatorLocation)
createPipeline
public java.lang.Object createPipeline()
- Returns an object that implements the service interface, and integrates any filters for the
pipeline with the