public class PipelineAssembler extends org.apache.hivemind.impl.BaseLocatable
PipelineFactory
to assemble the pipeline.Constructor and Description |
---|
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) |
Modifier and Type | Method and Description |
---|---|
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) |
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)
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 assembledpublic void addFilter(java.lang.String name, java.lang.String prereqs, java.lang.String postreqs, java.lang.Object filter, org.apache.hivemind.Location location)
public void setTerminator(java.lang.Object terminator, org.apache.hivemind.Location terminatorLocation)
public java.lang.Object createPipeline()