in my route i want to aggregate exchanges based on a header value (a
processor extracts it from the body and sets the header)
the route looks like this:
from(direct).process(new SetCorrelationHeader).aggregate(header("id"), new
CustomAggregator).completion<What to set here?>.to(mock)
I want to aggregate all messages with same correlation key. How to achieve
this? (i can't make any assumptions about time or size)
Within the processor for each new group the oldExchange==null. So at the
moment i know that the prevoius group is complete the old exchange is sent
out already.
So how to implement the completion in this case? Probably
eagerCheckCompletion could help - but how?
(i am using camel 2.14.3 - upgrading is no option)
--
View this message in context:
http://camel.465427.n5.nabble.com/aggreagator-completion-based-on-correlation-key-tp5772332.html
Sent from the Camel - Users mailing list archive at Nabble.com.
