I've digged little bit more and found possible cause of my problem. I try to simulate unavailability of HawtDBAggregationRepository persistentFile by killing session which was established by one of MQ node to the share location. After than i found in mq logs the following entry which was repeated many times:
------------------------------------------------------ 2013-08-01 16:27:46,794 | WARN | Exception occurred during purge task. This exception will be ignored. | org.apache.camel.processor.aggregate.AggregateProcessor$AggregationTimeoutMap | Camel (camel) thread #3 - AggregateTimeoutChecker java.lang.RuntimeException: Error getting key 222AAA from repository futuresAggregatorRepository ---------------------------------------------------------- It seems that this entry is loged almost like in infinite loop till activemq service is restarted. Moreover I've notice that session to the file location is not re established till activemq service is restarted. Do you have any suggestions how to handle this IO.Exception and configure activemq to reestablish connection. I have tried to use default error handler in route with defined redelivery policy but is seems that is doesn't work -- View this message in context: http://camel.465427.n5.nabble.com/Aggregator-message-redelivery-issues-tp5736445p5736693.html Sent from the Camel - Users mailing list archive at Nabble.com.
