Splitting a message, and processing and gathering responses
This recipe will show you how you how to split a message into individual fragments, process each fragment individually, and re-aggregate the processed exchanges back into a single exchange. In EIP terms, this is known as a Composed Message Processor, and is made up of a combination of a Splitter and an Aggregator.
Getting ready
Java code for this recipe is located in the org.camelcookbook.splitjoin.splitaggregate
package. The Spring XML examples are located under src/main/resources/META-INF/spring
and prefixed with splitAggregate
.
How to do it...
In order to split and aggregate (join) a message, combine a split
DSL statement with an associated AggregationStrategy
as follows:
Define an
AggregationStrategy
instance as described in the Aggregating related messages recipe. For this example, we will reuse theSetAggregationStrategy
implementation from that recipe:<bean id="setAggregationRepository" class="org.camelcookbook,splitjoin...