Hi,
I am usign all camel core and components as of 2.17.3.
This issue seems to be still up.
Under examples/camel-example-aggregator i can test it is working.
as of route below; aggregation is not completed and not output file is
getting generated. (btw, if i do aggregate without persistence, it is
working.)
from("amq:queue:jms.myqueue")
.startupOrder(initialStartupOrder)
.shutdownRoute(ShutdownRoute.Defer)
.aggregate(simple(myId.toString()),
new AggregationStrategy() {
@Override
public Exchange
aggregate(Exchange oldExchange, Exchange
newExchange) {
if (oldExchange
== null) {
newExchange.getIn().setBody(new
StringBuilder(newExchange.getIn().getBody(MyObject.class).asLine("|")));
return
newExchange;
}
oldExchange.getIn().getBody(StringBuilder.class).append(newExchange.getIn().getBody(MyObject.class).asLine("|"));
return
oldExchange;
}
})
.eagerCheckCompletion()
.forceCompletionOnStop()
.completeAllOnStop()
.completionSize(500)
.completionInterval(60000)
.parallelProcessing(true)
.aggregationRepository(myRepo)
.to("file:myfile");
--
View this message in context:
http://camel.465427.n5.nabble.com/Aggregator-LevelDB-or-HawtDB-for-persistency-incorrect-behavior-tp5765524p5789810.html
Sent from the Camel - Users mailing list archive at Nabble.com.
