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://servicemix.396122.n5.nabble.com/OnCompletion-issue-in-Fuse-SMX-tp5718319.html
Sent from the ServiceMix - User mailing list archive at Nabble.com.
