Hi
Thanks for sharing your solution.
Looks nice with separate routes for the aggregation. Makes it easier
to test as well :)
On Mon, Nov 2, 2009 at 9:18 PM, kodcanavari <kodcanav...@gmail.com> wrote:
>
> I resolved my problem by this way:
>
> this.from(m_from_folder_url)
> .split(new SplitExpression())
> .process(new Processor())
> .choice()
> .when(header("type").isEqualTo("add"))
> .to("direct:addEntry")
> .when(header("type").isEqualTo("modify"))
> .to("direct:modifyEntry");
>
> from("direct:addEntry").aggregate(header("add"), new
> AggregationStrategy()).to(m_to_add_folder_url);
> from("direct:modifyEntry").aggregate(header("modify"), new
> AggregationStrategy()).to(m_to_modify_folder_url);
>
> so this is a route which:
> - reads a file
> - splits it's entities
> - processes each entry separately
> - according to their nature aggregating processed entries to the
> appropriate file.
>
>
>
> kodcanavari wrote:
>>
>> Hi,
>>
>> I want to use an aggregator in order to aggregate all messages comming.
>> On my route i'm making a split with a splitter , then i process every
>> messages in parallel
>> and then i want to aggregate them all into a single file.
>>
>> Here is my snippet :
>>
>>
>> this.from(FROM_FOLDER).split(new LdapEntitySplitExpression()).process(new
>> LdapModifyProcessor()).aggregate(header("LDIFRecord"),new
>> LdapAggregationStrategy()).to(TO_FOLDER);
>>
>>
>> and inside LdapModifyProcessor() i do:
>>
>> exchange.getOut().setHeader("type", "LDIFRecord");
>>
>> but it does not work.
>>
>> can anyone tellme how can i let every messages go thru aggregator?
>>
>> regards.
>>
>>
>>
>>
>
> --
> View this message in context:
> http://old.nabble.com/How-to-aggregate-all-messages-into-a-single-message--tp25908234p26157808.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
>
--
Claus Ibsen
Apache Camel Committer
Author of Camel in Action: http://www.manning.com/ibsen/
Open Source Integration: http://fusesource.com
Blog: http://davsclaus.blogspot.com/
Twitter: http://twitter.com/davsclaus
