Fixes FailChunkExecution does not handle DbExceptions wrapped in an…

… `AggregateException` (akkadotnet#6361)
F0b0s · Jan 25, 2023 · fb4fe01 · fb4fe01
1 parent a7f4d3f
commit fb4fe01
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/contrib/persistence/Akka.Persistence.Sql.Common/Journal/BatchingSqlJournal.cs b/src/contrib/persistence/Akka.Persistence.Sql.Common/Journal/BatchingSqlJournal.cs
@@ -762,7 +762,12 @@ protected sealed override bool Receive(object message)
         private void FailChunkExecution(ChunkExecutionFailure message)
         {
             _remainingOperations++;
-            var cause = message.Cause;
+
+            var cause = message.Cause is AggregateException aggregateException
+                ? aggregateException.Flatten().InnerExceptions.OfType<DbException>().FirstOrDefault()
+                    ?? aggregateException.Flatten().InnerExceptions[0]
+                : message.Cause;
+
             Log.Error(cause, "An error occurred during event batch processing. ChunkId: [{0}], batched requests: [{1}]", message.ChunkId, message.Requests.Length);
 
             foreach (var request in message.Requests)