OnCompletion issue in Camel-ActiveMQ

[jay]

Hi Guys,
 
I have a requirement to call some bean/pojo or processor to clean some stuff
once all the messages are processed from the queue (_from). 

But my on completion is getting invoked for every single message. Could
someone let me know your views on what is wrong i am doing here. 

below is my code : 
onCompletion().beanRef("MyBean", "xyzMethod"); 
        from(_from).routeId("myRouteID") 
                .process(new MyProcessor()) 
                .choice() 
                   .when(header("VALID_MSG").isEqualTo("false" )) 
                   .log(" Error") 
                   .otherwise() 
                   .aggregate( header("ID"), new
MyAggregator()).completionTimeout(getAggregationTimeout()) 
                   .process(processor);



--
View this message in context: 
http://camel.465427.n5.nabble.com/OnCompletion-issue-in-Camel-ActiveMQ-tp5742771.html
Sent from the Camel - Users mailing list archive at Nabble.com.