When a queue restarts or multiple concurrent listeners receive the same message, we need to ensure that we don't have any duplicate messages provided to the consumer.
Have an implementation that does that in memory and can be overwritten in another module with a central key value store
When a queue restarts or multiple concurrent listeners receive the same message, we need to ensure that we don't have any duplicate messages provided to the consumer.
Have an implementation that does that in memory and can be overwritten in another module with a central key value store