Hi,
I have setup my aggregator as follows.
LevelDBAggregationRepository repository = new
LevelDBAggregationRepository(REPO_NAME, repoLocation+"/"+REPO_NAME+".dat");
repository.setUseRecovery(true);
repository.setMaximumRedeliveries(3);
repository.setRecoveryInterval(3000);
repository.setDeadLetterUri("mock:dead");
from(UPDATE_ENDPOINT)
.aggregate(header("fileId"), new
ESSessionAggregationStrategy()) // aggregates into an arraylist
.aggregationRepository(repository)
.completionPredicate(constant(false))
.to("es://bulk") // my elasticsearch component
I am flushing all the aggregates by sending a message with the header
Exchange.AGGREGATION_COMPLETE_ALL_GROUPS=true.
If elasticsearch component is not available, I would like to stop the route
with all messages in the repository. Is there any way to do this?
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-Aggregator-how-to-stop-route-on-first-failed-Message-tp5758837.html
Sent from the Camel - Users mailing list archive at Nabble.com.
