> I'm having an issue as well, for which I have implemented the
> AggregationStrategy but am still facing issues.
This is how you can collect exchanges multicasted to the several endpoints.
from("direct:multicastMe")
.multicast(new GroupedExchangeAggregationStrategy()).parallelProcessing()
.to("bean:processor1").to("bean:processor2")
.end().
.setBody(property(Exchange.GROUPED_EXCHANGE));
Now you end up with a message which body consists of a List of
messages collected from the multicast endpoints (or processors).
--
Henryk Konsek
http://henryk-konsek.blogspot.com
