You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by gilboy <jo...@gmail.com> on 2013/02/11 18:32:52 UTC

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

Posted by Claus Ibsen <cl...@gmail.com>.
On Tue, Feb 12, 2013 at 4:46 AM, boday <be...@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: cibsen@redhat.com
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen

Re: Splitter and Aggregator Query

Posted by boday <be...@initekconsulting.com>.
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.