[CAMEL-8947] LevelDBAggregatorRepository redelivers incorrectly

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Won't Fix
• Affects Version/s: 2.14.1
• Fix Version/s: 2.19.0
• Component/s: camel-leveldb
• Estimated Complexity: Unknown
• Assignee: Unassigned
• Reporter: Benjamin P. O'Day
• Created: 09/Jul/15 23:24
• Updated: 03/Mar/17 13:19
• Resolved: 03/Mar/17 13:19

Description

I'm using an the aggregator with the LevelDBAggregationRepository and seeing an incorrect redelivery of a message when using the UseLatestAggregationStrategy...

this very basic route (see attached)...

from("direct:start")
.aggregate(constant(true), new UseLatestAggregationStrategy())
.completionSize(2)
.aggregationRepository(repo)
.to("mock:mock");

shows the following behavior...

WARN LevelDBAggregationRepository - Unable to confirm exchangeId [ID-localhost-63819-1436483565832-0-6 from repository repo1: Not Found]

DEBUG LevelDBAggregationRepository - Scanned and found 1 exchange(s) to recover (note some of them may already be in progress).

DEBUG LevelDBAggregationRepository - Recovering exchangeId [ID-localhost-63819-1436483565832-0-3] -> Exchange[Message: test1]

resulting in a duplicate message being processed through the aggregator route...

if the default in-memory repo is used, the test behaves as expected...no unnecessary redelivery, etc.

Issue Links

• is related to: CAMEL-8971 HazelcastAggregatorRepository redelivers incorrectly