SplitDefinition |
SplitDefinition.aggregationStrategy(Supplier<org.apache.camel.AggregationStrategy> aggregationStrategy) |
Sets the AggregationStrategy to be used to assemble the replies from the splitted messages, into a single
outgoing message from the Splitter.
|
SplitDefinition |
SplitDefinition.aggregationStrategy(org.apache.camel.AggregationStrategy aggregationStrategy) |
Sets the AggregationStrategy to be used to assemble the replies from the splitted messages, into a single
outgoing message from the Splitter.
|
SplitDefinition |
SplitDefinition.aggregationStrategyMethodAllowNull() |
If this option is false then the aggregate method is not used if there was no data to enrich.
|
SplitDefinition |
SplitDefinition.aggregationStrategyMethodAllowNull(boolean aggregationStrategyMethodAllowNull) |
If this option is false then the aggregate method is not used if there was no data to enrich.
|
SplitDefinition |
SplitDefinition.aggregationStrategyMethodAllowNull(String aggregationStrategyMethodAllowNull) |
If this option is false then the aggregate method is not used if there was no data to enrich.
|
SplitDefinition |
SplitDefinition.aggregationStrategyMethodName(String methodName) |
This option can be used to explicit declare the method name to use, when using POJOs as the AggregationStrategy.
|
SplitDefinition |
SplitDefinition.aggregationStrategyRef(String aggregationStrategyRef) |
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.
|
SplitDefinition |
SplitDefinition.delimiter(String delimiter) |
Delimiter used in splitting messages.
|
SplitDefinition |
SplitDefinition.executorService(ExecutorService executorService) |
To use a custom Thread Pool to be used for parallel processing.
|
SplitDefinition |
SplitDefinition.executorServiceRef(String executorServiceRef) |
Refers to a custom Thread Pool to be used for parallel processing.
|
SplitDefinition |
SplitDefinition.onPrepare(org.apache.camel.Processor onPrepare) |
Uses the Processor when preparing the Exchange to be send.
|
SplitDefinition |
SplitDefinition.onPrepareRef(String onPrepareRef) |
Uses the Processor when preparing the Exchange to be send.
|
SplitDefinition |
SplitDefinition.parallelAggregate() |
If enabled then the aggregate method on AggregationStrategy can be called concurrently.
|
SplitDefinition |
SplitDefinition.parallelAggregate(boolean parallelAggregate) |
If enabled then the aggregate method on AggregationStrategy can be called concurrently.
|
SplitDefinition |
SplitDefinition.parallelAggregate(String parallelAggregate) |
If enabled then the aggregate method on AggregationStrategy can be called concurrently.
|
SplitDefinition |
SplitDefinition.parallelProcessing() |
If enabled then processing each splitted messages occurs concurrently.
|
SplitDefinition |
SplitDefinition.parallelProcessing(boolean parallelProcessing) |
If enabled then processing each splitted messages occurs concurrently.
|
SplitDefinition |
SplitDefinition.parallelProcessing(String parallelProcessing) |
If enabled then processing each splitted messages occurs concurrently.
|
SplitDefinition |
SplitDefinition.shareUnitOfWork() |
Shares the UnitOfWork with the parent and each of the sub messages.
|
SplitDefinition |
SplitDefinition.shareUnitOfWork(boolean shareUnitOfWork) |
Shares the UnitOfWork with the parent and each of the sub messages.
|
SplitDefinition |
SplitDefinition.shareUnitOfWork(String shareUnitOfWork) |
Shares the UnitOfWork with the parent and each of the sub messages.
|
SplitDefinition |
ProcessorDefinition.split(org.apache.camel.Expression expression) |
Splitter EIP: Creates a splitter allowing you split a message
into a number of pieces and process them individually.
|
SplitDefinition |
ProcessorDefinition.split(org.apache.camel.Expression expression,
String delimiter) |
Splitter EIP: Creates a splitter allowing you split a message
into a number of pieces and process them individually.
|
SplitDefinition |
ProcessorDefinition.split(org.apache.camel.Expression expression,
org.apache.camel.AggregationStrategy aggregationStrategy) |
Splitter EIP: Creates a splitter allowing you split a message
into a number of pieces and process them individually.
|
SplitDefinition |
SplitDefinition.stopOnAggregateException() |
If enabled, unwind exceptions occurring at aggregation time to the error handler when parallelProcessing is used.
|
SplitDefinition |
SplitDefinition.stopOnAggregateException(boolean stopOnAggregateException) |
If enabled, unwind exceptions occurring at aggregation time to the error handler when parallelProcessing is used.
|
SplitDefinition |
SplitDefinition.stopOnAggregateException(String stopOnAggregateException) |
If enabled, unwind exceptions occurring at aggregation time to the error handler when parallelProcessing is used.
|
SplitDefinition |
SplitDefinition.stopOnException() |
Will now stop further processing if an exception or failure occurred during processing of an
Exchange and the caused exception will be thrown.
|
SplitDefinition |
SplitDefinition.stopOnException(boolean stopOnException) |
Will now stop further processing if an exception or failure occurred during processing of an
Exchange and the caused exception will be thrown.
|
SplitDefinition |
SplitDefinition.stopOnException(String stopOnException) |
Will now stop further processing if an exception or failure occurred during processing of an
Exchange and the caused exception will be thrown.
|
SplitDefinition |
SplitDefinition.streaming() |
When in streaming mode, then the splitter splits the original message on-demand, and each splitted message is
processed one by one.
|
SplitDefinition |
SplitDefinition.streaming(boolean streaming) |
When in streaming mode, then the splitter splits the original message on-demand, and each splitted message is
processed one by one.
|
SplitDefinition |
SplitDefinition.streaming(String streaming) |
When in streaming mode, then the splitter splits the original message on-demand, and each splitted message is
processed one by one.
|
SplitDefinition |
SplitDefinition.timeout(long timeout) |
Sets a total timeout specified in millis, when using parallel processing.
|
SplitDefinition |
SplitDefinition.timeout(String timeout) |
Sets a total timeout specified in millis, when using parallel processing.
|