I am using 2.5-SNAPSHOT I've updated my local repo this morning
timeout seems to have a problem even on your Unit test route:
from("direct:start")
.recipientList(header("slip")).aggregationStrategy(
new AggregationStrategy() {
public Exchange aggregate(Exchange oldExchange,
Exchange newExchange) {
if (oldExchange == null) {
return newExchange;
}
String body =
oldExchange.getIn().getBody(String.class);
oldExchange.getIn().setBody(body +
newExchange.getIn().getBody(String.class));
return oldExchange;
}
})
.parallelProcessing().timeout(2000)
.to("mock:result");
it looks fine on multicast route:
from("direct:start")
.multicast(new AggregationStrategy() {
public Exchange aggregate(Exchange
oldExchange, Exchange
newExchange) {
if (oldExchange == null) {
return newExchange;
}
String body =
oldExchange.getIn().getBody(String.class);
oldExchange.getIn().setBody(body +
newExchange.getIn().getBody(String.class));
return oldExchange;
}
})
.parallelProcessing().timeout(2000).to("direct:a", "direct:b",
"direct:c")
// use end to indicate end of multicast route
.end()
.to("mock:result");
--
View this message in context:
http://camel.465427.n5.nabble.com/camel-2-5-recipientList-aggregationStrategy-timeout-tp2265144p2265166.html
Sent from the Camel - Users mailing list archive at Nabble.com.
