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

Reply via email to