RecipientListDefinition<Type> |
RecipientListDefinition.aggregationStrategy(Supplier<org.apache.camel.AggregationStrategy> aggregationStrategy) |
Sets the AggregationStrategy to be used to assemble the replies from the recipients, into a single outgoing
message from the RecipientList.
|
RecipientListDefinition<Type> |
RecipientListDefinition.aggregationStrategy(org.apache.camel.AggregationStrategy aggregationStrategy) |
Sets the AggregationStrategy to be used to assemble the replies from the recipients, into a single outgoing
message from the RecipientList.
|
RecipientListDefinition<Type> |
RecipientListDefinition.aggregationStrategyMethodAllowNull() |
If this option is false then the aggregate method is not used if there was no data to enrich.
|
RecipientListDefinition<Type> |
RecipientListDefinition.aggregationStrategyMethodName(String methodName) |
This option can be used to explicit declare the method name to use, when using POJOs as the AggregationStrategy.
|
RecipientListDefinition<Type> |
RecipientListDefinition.aggregationStrategyRef(String aggregationStrategyRef) |
Sets a reference to the AggregationStrategy to be used to assemble the replies from the recipients, into a single
outgoing message from the RecipientList.
|
RecipientListDefinition<Type> |
RecipientListDefinition.cacheSize(int cacheSize) |
Sets the maximum size used by the ProducerCache which is used to cache and reuse
producers when using this recipient list, when uris are reused.
|
RecipientListDefinition<Type> |
RecipientListDefinition.cacheSize(String cacheSize) |
Sets the maximum size used by the ProducerCache which is used to cache and reuse
producers when using this recipient list, when uris are reused.
|
RecipientListDefinition<Type> |
RecipientListDefinition.delimiter(String delimiter) |
Delimiter used if the Expression returned multiple endpoints.
|
RecipientListDefinition<Type> |
RecipientListDefinition.executorService(ExecutorService executorService) |
To use a custom Thread Pool to be used for parallel processing.
|
RecipientListDefinition<Type> |
RecipientListDefinition.executorServiceRef(String executorServiceRef) |
Refers to a custom Thread Pool to be used for parallel processing.
|
RecipientListDefinition<Type> |
RecipientListDefinition.ignoreInvalidEndpoints() |
Ignore the invalidate endpoint exception when try to create a producer with that endpoint
|
RecipientListDefinition<Type> |
RecipientListDefinition.onPrepare(org.apache.camel.Processor onPrepare) |
Uses the Processor when preparing the Exchange to be used send.
|
RecipientListDefinition<Type> |
RecipientListDefinition.onPrepareRef(String onPrepareRef) |
Uses the Processor when preparing the Exchange to be send.
|
RecipientListDefinition<Type> |
RecipientListDefinition.parallelAggregate() |
If enabled then the aggregate method on AggregationStrategy can be called concurrently.
|
RecipientListDefinition<Type> |
RecipientListDefinition.parallelProcessing() |
If enabled then sending messages to the recipients occurs concurrently.
|
RecipientListDefinition<Type> |
RecipientListDefinition.parallelProcessing(boolean parallelProcessing) |
If enabled then sending messages to the recipients occurs concurrently.
|
RecipientListDefinition<Type> |
ProcessorDefinition.recipientList(org.apache.camel.Expression recipients) |
Recipient List EIP: Creates a dynamic recipient list
allowing you to route messages to a number of dynamically specified recipients.
|
RecipientListDefinition<Type> |
ProcessorDefinition.recipientList(org.apache.camel.Expression recipients,
String delimiter) |
Recipient List EIP: Creates a dynamic recipient list
allowing you to route messages to a number of dynamically specified recipients
|
RecipientListDefinition<Type> |
RecipientListDefinition.shareUnitOfWork() |
Shares the UnitOfWork with the parent and each of the sub messages.
|
RecipientListDefinition<Type> |
RecipientListDefinition.stopOnAggregateException() |
If enabled, unwind exceptions occurring at aggregation time to the error handler when parallelProcessing is used.
|
RecipientListDefinition<Type> |
RecipientListDefinition.stopOnException() |
Will now stop further processing if an exception or failure occurred during processing of an
Exchange and the caused exception will be thrown.
|
RecipientListDefinition<Type> |
RecipientListDefinition.streaming() |
If enabled then Camel will process replies out-of-order, eg in the order they come back.
|
RecipientListDefinition<Type> |
RecipientListDefinition.timeout(long timeout) |
Sets a total timeout specified in millis, when using parallel processing.
|