Removed unneeded idempotency keys set from EventSource

stidsborg · Nov 15, 2023 · 1d34ff9 · 1d34ff9
1 parent 129b6b2
commit 1d34ff9
Showing 1 changed file with 0 additions and 7 deletions.
diff --git a/Core/Cleipnir.ResilientFunctions/Messaging/EventSource.cs b/Core/Cleipnir.ResilientFunctions/Messaging/EventSource.cs
@@ -18,7 +18,6 @@ public class EventSource : IReactiveChain<object>, IDisposable
     private readonly TimeSpan _pullFrequency;
     private readonly ISerializer _eventSerializer;
 
-    private readonly HashSet<string> _idempotencyKeys = new();
     private int _deliverOutstandingEventsIteration;
     private EventProcessingException? _thrownException;
 
@@ -101,12 +100,6 @@ private async Task DeliverOutstandingEvents(bool deliverDespiteNoActiveSubscript
             var storedEvents = await _eventsSubscription!.PullNewEvents();
             foreach (var storedEvent in storedEvents)
             {
-                if (storedEvent.IdempotencyKey != null)
-                    if (_idempotencyKeys.Contains(storedEvent.IdempotencyKey))
-                        continue;
-                    else
-                        _idempotencyKeys.Add(storedEvent.IdempotencyKey);
-
                 var deserialized = _eventSerializer
                     .DeserializeEvent(storedEvent.EventJson, storedEvent.EventType);