Hi, I'm not sure why you are using the mock endpoint. Can you just change the aggregate part like this ?
<route> <from uri="direct:start" /> <aggregate strategyRef="aggregationStrategy" completionTimeout="1500" completionSize="750" > <correlationExpression> <header>Exchange.FILE_NAME_ONLY</header> </correlationExpression> <to uri="file:F:/EbcConversion/Data/outbox/files/?fileExist=Append&fileName=output.txt" /> </aggregate> </route> -- Willem Jiang Red Hat, Inc. FuseSource is now part of Red Hat Web: http://www.fusesource.com | http://www.redhat.com Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/) (English) http://jnn.iteye.com (http://jnn.javaeye.com/) (Chinese) Twitter: willemjiang Weibo: 姜宁willem On Wednesday, February 6, 2013 at 11:28 AM, Gvvenkat wrote: > Thanks William for your quick response. > > I made the change as below..but still no difference.. Please let me know, I > did not understand your instructions correctly. > > Thanks > > <camelContext> > <route> > > <from > uri="file:F:/EbcConversion/Data/inbox/?delete=true&idempotent=true&readLock=changed&readLockCheckInterval=1500"/> > <split streaming="true"> > <method bean="byteSplitterBean" method="splitBody"/> > <process ref="decoder"/> > </split> > <to uri="direct:start" /> > </route> > <route> > <from uri="direct:start" /> > <aggregate strategyRef="aggregationStrategy" > completionTimeout="1500" completionSize="750" > > <correlationExpression> > <header>Exchange.FILE_NAME_ONLY</header> > </correlationExpression> > <to uri="mock:aggregated"/> > </aggregate> > <to > uri="file:F:/EbcConversion/Data/outbox/files/?fileExist=Append&fileName=output.txt" > /> > </route> > > > </camelContext> > > > > > > -- > View this message in context: > http://camel.465427.n5.nabble.com/Java-DSL-vs-Spring-Dsl-with-Splitter-and-Aggregator-tp5727007p5727017.html > Sent from the Camel - Users mailing list archive at Nabble.com > (http://Nabble.com).