Hi Jason, > Here is my AggregationStrategy:
Your custom aggregation strategy acts like
GroupedExchangeAggregationStrategy. Why don't use the latter then?
from("direct:aggregateMe").
aggregate(constant(true),new GroupedExchangeAggregationStrategy()).
completionSize(2).
.setBody(property(Exchange.GROUPED_EXCHANGE)).
to("mock:aggregated");
Kind regards.
--
Henryk Konsek
http://henryk-konsek.blogspot.com
