Splitter and Aggregator Query
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 -- View this message in context: http://camel.465427.n5.nabble.com/Splitter-and-Aggregator-Query-tp5727361.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Splitter and Aggregator Query
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.
Re: Splitter and Aggregator Query
On Tue, Feb 12, 2013 at 4:46 AM, boday ben.o...@initekconsulting.com wrote: 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)) Its often much easier to use the built-in aggregator in the splitter. See http://camel.apache.org/composed-message-processor.html And the section about using only a splitter. 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. -- Claus Ibsen - Red Hat, Inc. FuseSource is now part of Red Hat Email: cib...@redhat.com Web: http://fusesource.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen
