Hi, We are using camel 2.12.3 Aggregator pattern with JDBC backend repository. We are seeing an issue with duplicate messages being generated by the recovery checker thread. Looking at the debug level logs, it seems like the timeout checker processes messages and moves the aggregated message to the aggregation_completed table. At the same time, the recover checker seems to pick it up even though it's still being processed by the timeout checker thread. Then the recover checker also processes it and tries to send it out. Has anyone seen any issues like this before? I searched through the JIRA and found some bugs related to this posted before. e.g. - https://issues.apache.org/jira/browse/CAMEL-6097 However that doesn't seem to have resolved the isses I'm seeing. Any ideas? Please let me know if there's anything else I can try out. Some relevant excerpts of the log shown belog ---- 20141021 00:00:04,600 [Camel (camelContext) thread #1 - AggregateTimeoutChecker] TRACE org.apache.camel.processor.aggregate.AggregateProcessor.run() - Star ting completion interval task 20141021 00:00:04,627 [Camel (camelContext) thread #1 - AggregateTimeoutChecker] TRACE org.apache.camel.processor.aggregate.AggregateProcessor.run() - Comp letion interval task complete 20141021 00:00:04,901 [Camel (camelContext) thread #1 - AggregateTimeoutChecker] TRACE org.apache.camel.processor.aggregate.AggregateProcessor.run() - Star ting completion interval task 20141021 00:00:04,932 [Camel (camelContext) thread #0 - AggregateRecoverChecker] TRACE org.apache.camel.processor.aggregate.AggregateProcessor.run() - Star ting recover check 20141021 00:00:04,940 [Camel (camelContext) thread #0 - AggregateRecoverChecker] TRACE org.apache.camel.processor.aggregate.jdbc.JdbcAggregationRepository. mapRow() - getKey [ID-host---com-57698-1413498606147-0-161] 20141021 00:00:04,940 [Camel (camelContext) thread #0 - AggregateRecoverChecker] TRACE org.apache.camel.processor.aggregate.jdbc.JdbcAggregationRepository. mapRow() - getKey [ID-host---com-57698-1413498606147-0-174] 20141021 00:00:04,940 [Camel (camelContext) thread #0 - AggregateRecoverChecker] TRACE org.apache.camel.processor.aggregate.jdbc.JdbcAggregationRepository. mapRow() - getKey [ID-host---com-57698-1413498606147-0-197] 20141021 00:00:04,940 [Camel (camelContext) thread #0 - AggregateRecoverChecker] TRACE org.apache.camel.processor.aggregate.jdbc.JdbcAggregationRepository. mapRow() - getKey [ID-host---com-57698-1413498606147-0-207] 20141021 00:00:04,940 [Camel (camelContext) thread #0 - AggregateRecoverChecker] TRACE org.apache.camel.processor.aggregate.jdbc.JdbcAggregationRepository. mapRow() - getKey [ID-host---com-57698-1413498606147-0-230] 20141021 00:00:04,940 [Camel (camelContext) thread #0 - AggregateRecoverChecker] TRACE org.apache.camel.processor.aggregate.jdbc.JdbcAggregationRepository. mapRow() - getKey [ID-host---com-57698-1413498606147-0-237] 20141021 00:00:04,940 [Camel (camelContext) thread #0 - AggregateRecoverChecker] TRACE org.apache.camel.processor.aggregate.jdbc.JdbcAggregationRepository. mapRow() - getKey [ID-host---com-57698-1413498606147-0-244] 20141021 00:00:05,017 [Camel (camelContext) thread #1 - AggregateTimeoutChecker] TRACE org.apache.camel.processor.aggregate.AggregateProcessor.run() - Comp letion interval task complete 20141021 00:00:05,017 [Camel (camelContext) thread #0 - AggregateRecoverChecker] DEBUG org.apache.camel.processor.aggregate.AggregateProcessor.run() - Load ing aggregated exchange with id: ID-host---com-57698-1413498606147-0-161 to be recovered.
-- View this message in context: http://camel.465427.n5.nabble.com/Aggregator-recover-checker-producing-duplicate-messages-tp5758151.html Sent from the Camel - Users mailing list archive at Nabble.com.
