introduced AK1001 bug

petabridge · Jan 10, 2024 · ce834b6 · ce834b6
1 parent 4cb76c7
commit ce834b6
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/src/clustering/sharding-sqlserver/SqlSharding.Host/Actors/ProductTotalsActor.cs b/src/clustering/sharding-sqlserver/SqlSharding.Host/Actors/ProductTotalsActor.cs
@@ -49,8 +49,6 @@ public ProductTotalsActor(string persistenceId)
             var response = State.ProcessCommand(cmd);
             var sentResponse = false;
 
-            var sender = Sender;
-
             if (response.ResponseEvents.Any())
             {
                 PersistAll(response.ResponseEvents, productEvent =>
@@ -66,7 +64,15 @@ public ProductTotalsActor(string persistenceId)
                     if (!sentResponse) // otherwise we'll generate a response-per-event
                     {
                         sentResponse = true;
-                        sender.Tell(response);
+
+                        async Task<ProductCommandResponse> ReplyToSender()
+                        {
+                            await Task.Delay(1);
+                            return response;
+                        }
+
+                        ReplyToSender().PipeTo(Sender, failure: ex => new Status.Failure(ex));
+
                     }
 
                     if(LastSequenceNr % 10 == 0)