Fix time in AtLeastOnceDeliverySemantic.SetDeliverySnapshot to be con…

…sistent with Deliver when RecoveryRunning (#4574)
akkadotnet · Oct 12, 2020 · 80b9cac · 80b9cac
1 parent a706ee6
commit 80b9cac
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/core/Akka.Persistence/AtLeastOnceDeliverySemantic.cs b/src/core/Akka.Persistence/AtLeastOnceDeliverySemantic.cs
@@ -499,7 +499,8 @@ public AtLeastOnceDeliverySnapshot GetDeliverySnapshot()
         public void SetDeliverySnapshot(AtLeastOnceDeliverySnapshot snapshot)
         {
             _deliverySequenceNr = snapshot.CurrentDeliveryId;
-            DateTime now = DateTime.UtcNow;
+            // deliver on next tick
+            var now = DateTime.UtcNow - RedeliverInterval;
             _unconfirmed =
                 snapshot.UnconfirmedDeliveries.Select(
                     u => new KeyValuePair<long, Delivery>(u.DeliveryId, new Delivery(u.Destination, u.Message, now, 0)))