Thanks a lot dulanov, it worked :)
but can you tell me what exactly end() do and why i cant use the aggregator class ? dulanov wrote: > > Try to use this.from(FROM_FOLDER).split(new LdapEntitySplitExpression(), > new > LdapAggregationStrategy()).process(new > LdapModifyProcessor()).end().to(TO_FOLDER); > > On Thu, Oct 15, 2009 at 5:01 PM, kodcanavari <[email protected]> > 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://www.nabble.com/How-to-aggregate-all-messages-into-a-single-message--tp25908234p25908234.html >> Sent from the Camel - Users mailing list archive at Nabble.com. >> >> > > -- View this message in context: http://www.nabble.com/How-to-aggregate-all-messages-into-a-single-message--tp25908234p25909223.html Sent from the Camel - Users mailing list archive at Nabble.com.
