You are right, I had the source but I was looking at the wrong spot. I have finished adapting the tests to my aggregator repository. All pass except 2 of them that require a recovery for the background task.
I do not know why but the doStart() method seems not to be called on my aggregator which extends ServiceSupport and implements RecoverableAggregationRepository. When I run the test for HawtDB the logs shows : [main ] INFO HawtDBAggregationRepository - On startup there are no existing aggregate exchanges (not completed) in repository: repo1 [main ] INFO HawtDBAggregationRepository - On startup there are no completed exchanges to be recovered in repository: repo1-completed [main ] INFO AggregateProcessor - Using RecoverableAggregationRepository by scheduling recover checker to run every 5000 millis. The third line comes from the aggregatorProcessor (aggregator2 implementation). It should start the aggregatorrepository before that by calling doStart(), which log the 2 first lines. Is there something I could have missed to register the aggregator as a service ? Thanks for your help! -- View this message in context: http://camel.465427.n5.nabble.com/Aggregator-Persistence-tp2800301p3270979.html Sent from the Camel - Users mailing list archive at Nabble.com.
