[CAMEL-1679] InProgress repository

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.1.0
• Component/s: camel-core
• Assignee: Claus Ibsen
• Reporter: Claus Ibsen
• Created: 07/Jun/09 09:10
• Updated: 07/Feb/10 09:55
• Resolved: 11/Sep/09 10:59

Description

Adding a repository for registering in progress exchanges.

The repository should be per camel context specific. It should contain a default memory only repository, but support pluggable so end user can impl some other store if they like.
It should support some notion of a key to identify whether a given message is already in progress or not.

The UnitOfWork can be used to register and de register in progress, so we ensure its always done.

We could by default just register the exchange id, and thus have a sort of current snapshot of how many exchanges is currently in progress.
Then we can let components override this behavior to use a key that is component specific and has a meaning.
For instance the file component can use the absolute file name as key to ensure that it does not consume the same file while its already in progress.
And the idempotent consumer EIP can use the correlation message id to ensure that it also detects in progress messages.

Issue Links

• depends upon: CAMEL-1650 Race condition in IdempotentConsumer