Hi, I want to extend the IdempotentConsumer to only deny duplicated while the duplicate message is being processed.
My plan was to add an additional Synchronization that removed the messageId from the repository when the message has finished processing. However I can't find a simple example of how to add my version of the IdempotentConsumer to my route. I believe I could add it as a standard processor but I don't really know how to do this as doesn't have a no-args constructor. My other idea would be to add the additional Synchronization in the route directly, outside the IdempotentConsumer but I couldn't see a clean way of finding the messageId or the repository. Any help would be greatly appreciated. Thanks, Sam