@Metadata(label="ipf,eip")
public class SplitterDefinition
extends org.apache.camel.model.OutputDefinition<org.apache.camel.model.RouteDefinition>
OutputDefinition
for the Splitter
processor
This class is needed to create a Splitter
that hands on the
sub exchanges to a specified processor. The Splitter
requires
explicit definition of this processor because it has to send multiple
exchanges to the processor. Usually processors only send a single exchange
to the next processor in the route, which is done automatically by Camel.Constructor and Description |
---|
SplitterDefinition() |
SplitterDefinition(org.apache.camel.Expression expression)
Creates a split definition, i.e.
|
SplitterDefinition(String expressionBean)
Creates a split type, i.e.
|
Modifier and Type | Method and Description |
---|---|
SplitterDefinition |
aggregationStrategy(org.apache.camel.processor.aggregate.AggregationStrategy aggregationStrategy)
Defines the aggregation logic for the split results via a strategy interface
|
SplitterDefinition |
aggregationStrategy(groovy.lang.Closure aggregationStrategy)
Defines the aggregation logic for the split results as a closure
|
org.apache.camel.Processor |
createProcessor(org.apache.camel.spi.RouteContext routeContext) |
protected Splitter |
createSplitterInstance(org.apache.camel.Expression expression,
org.apache.camel.Processor processor) |
String |
getShortName() |
String |
toString() |
getOutputs, isOutputSupported, setOutputs
addInterceptStrategies, addInterceptStrategy, addOutput, addRoutes, aggregate, aggregate, aggregate, aggregate, aop, attribute, bean, bean, bean, bean, bean, bean, bean, bean, beanRef, beanRef, beanRef, beanRef, beanRef, choice, claimCheck, claimCheck, claimCheck, claimCheck, clearOutput, configureChild, convertBodyTo, convertBodyTo, createChannel, createChildProcessor, createCompositeProcessor, createOutputsProcessor, createOutputsProcessor, createOutputsProcessorImpl, createProcessor, delay, delay, delay, doTry, dynamicRouter, dynamicRouter, end, endChoice, endDoTry, endHystrix, endParent, endRest, enrich, enrich, enrich, enrich, enrich, enrichRef, enrichRef, enrichRef, enrichWith, enrichWith, enrichWith, filter, filter, filter, filter, getIndex, getInterceptStrategies, getLabel, getOtherAttributes, getParent, hystrix, id, idempotentConsumer, idempotentConsumer, idempotentConsumer, idempotentConsumer, inheritErrorHandler, inOnly, inOnly, inOnly, inOnly, inOnly, inOnly, inOut, inOut, inOut, inOut, inOut, inOut, isAbstract, isInheritErrorHandler, isTopLevelOnly, isWrappingEntireOutput, loadBalance, loadBalance, log, log, log, log, log, log, loop, loop, loop, loopDoWhile, loopDoWhile, makeProcessor, markRollbackOnly, markRollbackOnlyLast, marshal, marshal, marshal, marshal, multicast, multicast, multicast, onCompletion, onException, onException, pipeline, pipeline, pipeline, pipeline, placeholder, policy, policy, pollEnrich, pollEnrich, pollEnrich, pollEnrich, pollEnrich, pollEnrich, pollEnrich, pollEnrich, pollEnrich, pollEnrichRef, pollEnrichRef, pollEnrichWith, pollEnrichWith, pollEnrichWith, preCreateProcessor, process, process, process, processRef, recipientList, recipientList, recipientList, recipientList, removeFaultHeader, removeHeader, removeHeaders, removeHeaders, removeProperties, removeProperties, removeProperty, resequence, resequence, rollback, rollback, routeDescription, routeId, routingSlip, routingSlip, routingSlip, routingSlip, routingSlip, routingSlip, routingSlip, saga, sample, sample, sample, script, script, serviceCall, serviceCall, serviceCall, setBody, setBody, setBody, setBody, setExchangePattern, setFaultBody, setFaultHeader, setHeader, setHeader, setHeader, setInheritErrorHandler, setOtherAttributes, setOutHeader, setOutHeader, setParent, setProperty, setProperty, sort, sort, sort, split, split, split, startupOrder, stop, threads, threads, threads, threads, throttle, throttle, throttle, throwException, throwException, to, to, to, to, to, to, to, to, to, to, toD, toD, toF, transacted, transacted, transform, transform, unmarshal, unmarshal, unmarshal, unmarshal, validate, validate, validate, wireTap, wireTap, wireTap, wireTap, wireTap, wireTap, wireTap, wireTap, wireTap, wrapChannel, wrapChannel, wrapInErrorHandler, wrapProcessor
public SplitterDefinition()
public SplitterDefinition(org.apache.camel.Expression expression)
Splitter
.expression
- The expression to be passed to the Splitter
upon
creation.public org.apache.camel.Processor createProcessor(org.apache.camel.spi.RouteContext routeContext) throws Exception
createProcessor
in class org.apache.camel.model.ProcessorDefinition<org.apache.camel.model.RouteDefinition>
Exception
protected Splitter createSplitterInstance(org.apache.camel.Expression expression, org.apache.camel.Processor processor)
public String getShortName()
getShortName
in interface org.apache.camel.NamedNode
getShortName
in class org.apache.camel.model.OptionalIdentifiedDefinition<org.apache.camel.model.RouteDefinition>
public String toString()
toString
in class org.apache.camel.model.OutputDefinition<org.apache.camel.model.RouteDefinition>
public SplitterDefinition aggregationStrategy(groovy.lang.Closure aggregationStrategy)
aggregationStrategy
- the aggregation strategypublic SplitterDefinition aggregationStrategy(org.apache.camel.processor.aggregate.AggregationStrategy aggregationStrategy)
aggregationStrategy
- the aggregation strategyCopyright © 2018 Open eHealth Foundation. All rights reserved.