Showing:

Attributes
Model
Properties
Complex Type tns:splitDefinition
Namespace http://camel.apache.org/schema/spring
Type extension of tns:expressionNode
Type hierarchy
Model
Children tns:aggregate, tns:aop, tns:bean, tns:choice, tns:constant, tns:convertBodyTo, tns:delay, tns:description, tns:doCatch, tns:doFinally, tns:doTry, tns:dynamicRouter, tns:el, tns:enrich, tns:exchangeProperty, tns:expressionDefinition, tns:filter, tns:groovy, tns:header, tns:idempotentConsumer, tns:inOnly, tns:inOut, tns:intercept, tns:interceptFrom, tns:interceptSendToEndpoint, tns:javaScript, tns:jsonpath, tns:jxpath, tns:language, tns:loadBalance, tns:log, tns:loop, tns:marshal, tns:method, tns:multicast, tns:mvel, tns:ognl, tns:onCompletion, tns:onException, tns:otherwise, tns:php, tns:pipeline, tns:policy, tns:pollEnrich, tns:process, tns:python, tns:recipientList, tns:ref, tns:removeHeader, tns:removeHeaders, tns:removeProperties, tns:removeProperty, tns:resequence, tns:restBinding, tns:rollback, tns:route, tns:routingSlip, tns:ruby, tns:sample, tns:script, tns:setBody, tns:setExchangePattern, tns:setFaultBody, tns:setHeader, tns:setOutHeader, tns:setProperty, tns:simple, tns:sort, tns:spel, tns:split, tns:sql, tns:stop, tns:terser, tns:threads, tns:throttle, tns:throwException, tns:to, tns:toD, tns:tokenize, tns:transacted, tns:transform, tns:unmarshal, tns:validate, tns:vtdxml, tns:when, tns:whenSkipSendToEndpoint, tns:wireTap, tns:xpath, tns:xquery, tns:xtokenize
Attributes
QName Type Use Annotation
customId xs:boolean optional
executorServiceRef xs:string optional
Refers to a custom Thread Pool to be used for parallel processing. Notice if you
set this option then parallel processing is automatic implied and you do not
have to enable that option as well.
id xs:string optional
Sets the id of this node
inheritErrorHandler xs:boolean optional
onPrepareRef xs:string optional
Uses the Processor when preparing the org.apache.camel.Exchange to be send. This
can be used to deep-clone messages that should be send or any custom logic
needed before the exchange is send.
parallelAggregate xs:boolean optional
If enabled then the aggregate method on AggregationStrategy can be called
concurrently. Notice that this would require the implementation of
AggregationStrategy to be implemented as thread-safe. By default this is false
meaning that Camel synchronizes the call to the aggregate method. Though in some
use-cases this can be used to archive higher performance when the
AggregationStrategy is implemented as thread-safe.
parallelProcessing xs:boolean optional
If enabled then processing each splitted messages occurs concurrently. Note the
caller thread will still wait until all messages has been fully processed before
it continues. Its only processing the sub messages from the splitter which
happens concurrently.
shareUnitOfWork xs:boolean optional
Shares the org.apache.camel.spi.UnitOfWork with the parent and each of the sub
messages. Splitter will by default not share unit of work between the parent
exchange and each splitted exchange. This means each splitted exchange has its
own individual unit of work.
stopOnException xs:boolean optional
Will now stop further processing if an exception or failure occurred during
processing of an org.apache.camel.Exchange and the caused exception will be
thrown. Will also stop if processing the exchange failed (has a fault message)
or an exception was thrown and handled by the error handler (such as using
onException). In all situations the splitter will stop further processing. This
is the same behavior as in pipeline which is used by the routing engine. The
default behavior is to not stop but continue processing till the end
strategyMethodAllowNull xs:boolean optional
If this option is false then the aggregate method is not used if there was no
data to enrich. If this option is true then null values is used as the
oldExchange (when no data to enrich) when using POJOs as the AggregationStrategy
strategyMethodName xs:string optional
This option can be used to explicit declare the method name to use when using
POJOs as the AggregationStrategy.
strategyRef xs:string optional
Sets a reference to the AggregationStrategy to be used to assemble the replies
from the splitted messages into a single outgoing message from the Splitter. By
default Camel will use the original incoming message to the splitter (leave it
unchanged). You can also use a POJO as the AggregationStrategy
streaming xs:boolean optional
When in streaming mode then the splitter splits the original message on-demand
and each splitted message is processed one by one. This reduces memory usage as
the splitter do not split all the messages first but then we do not know the
total size and therefore the link org.apache.camel.ExchangeSPLIT_SIZE is empty.
In non-streaming mode (default) the splitter will split each message first to
know the total size and then process each message one by one. This requires to
keep all the splitted messages in memory and therefore requires more memory. The
total size is provided in the link org.apache.camel.ExchangeSPLIT_SIZE header.
The streaming mode also affects the aggregation behavior. If enabled then Camel
will process replies out-of-order eg in the order they come back. If disabled
Camel will process replies in the same order as the messages was splitted.
timeout xs:long optional
Sets a total timeout specified in millis when using parallel processing. If the
Splitter hasn't been able to split and process all the sub messages within the
given timeframe then the timeout triggers and the Splitter breaks out and
continues. Notice if you provide a TimeoutAwareAggregationStrategy then the
timeout method is invoked before breaking out. If the timeout is reached with
running tasks still remaining certain tasks for which it is difficult for Camel
to shut down in a graceful manner may continue to run. So use this option with a
bit of care.
Wildcard: ANY attribute from ANY namespace OTHER than 'http://camel.apache.org/schema/spring'
Attribute tns:splitDefinition / @parallelProcessing
Namespace No namespace
Type xs:boolean
Properties
content simple
Attribute tns:splitDefinition / @strategyRef
Namespace No namespace
Type xs:string
Properties
content simple
Attribute tns:splitDefinition / @strategyMethodName
Namespace No namespace
Type xs:string
Properties
content simple
Attribute tns:splitDefinition / @strategyMethodAllowNull
Namespace No namespace
Type xs:boolean
Properties
content simple
Attribute tns:splitDefinition / @executorServiceRef
Namespace No namespace
Type xs:string
Properties
content simple
Attribute tns:splitDefinition / @streaming
Namespace No namespace
Type xs:boolean
Properties
content simple
Attribute tns:splitDefinition / @stopOnException
Namespace No namespace
Type xs:boolean
Properties
content simple
Attribute tns:splitDefinition / @timeout
Namespace No namespace
Type xs:long
Properties
content simple
Attribute tns:splitDefinition / @onPrepareRef
Namespace No namespace
Type xs:string
Properties
content simple
Attribute tns:splitDefinition / @shareUnitOfWork
Namespace No namespace
Type xs:boolean
Properties
content simple
Attribute tns:splitDefinition / @parallelAggregate
Namespace No namespace
Type xs:boolean
Properties
content simple