the splitter sets the CamelSplitSize header that you should be able to use as your aggregator completion predicate...
something like this... from("direct:start") .split(body()) .aggregate(constant(true), new BodyInAggregatingStrategy()).completionSize(header("CamelSplitSize")) gilboy wrote > Hi > > If I am using the aggregator EIP in conjunction with the Splitter EIP do I > have to specify a completion condition. > > In my case, when I split I don't know how many messages I am splitting. > After splitting I need to aggregate all the messages again. Hence, unclear > which completion condition I can use > > Thanks > Joe ----- Ben O'Day IT Consultant -http://consulting-notes.com -- View this message in context: http://camel.465427.n5.nabble.com/Splitter-and-Aggregator-Query-tp5727361p5727375.html Sent from the Camel - Users mailing list archive at Nabble.com.