Hi Arpit,
The aggregate should work for that. All depends on the "stopping condition".
Regards
JB
On 10/31/2016 11:04 PM, Goyal, Arpit wrote:
Hi Colleagues,
I want to read all file and aggregate into one single zip, but the batch
consumer always run in different thread. What needs to be done additionally to
get the response synchronously?
Regards,
Arpit.
DefaultCamelContext c = new DefaultCamelContext();
try {
c.addRoutes(new RouteBuilder() {
@Override
public void configure() throws Exception {
from("direct:start").from("file:/tmp/wiretap/6443391d-196a-4c75-b2f8-9c0696025b56/?include=.*&delete=true&maxMessagesPerPoll=2500")
.aggregate(body(), new
CustomZipAggregationStrategy()).completionFromBatchConsumer().to("file:/tmp/wiretap/aggregate");
}
});
ProducerTemplate template = c.createProducerTemplate();
c.start();
template.start();
template.requestBody("direct:start", "BEGIN"); //synchronously response
on completion of zip construction...
} finally {
c.stop();
}
--
Jean-Baptiste Onofré
jbono...@apache.org
http://blog.nanthrax.net
Talend - http://www.talend.com
