Aggregator recover checker producing duplicate messages

[archis <ar...@nomura.com>]

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.