Merge branch 'master' of https://github.com/dotnetcore/CAP

dotnetcore · Sep 20, 2024 · f304b1b · f304b1b
2 parents 47c071e + 7e9d668
commit f304b1b
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 1 deletion.
diff --git a/src/DotNetCore.CAP.AzureServiceBus/AzureServiceBusConsumerClient.cs b/src/DotNetCore.CAP.AzureServiceBus/AzureServiceBusConsumerClient.cs
@@ -134,7 +134,8 @@ public void Commit(object? sender)
 
     public void Reject(object? sender)
     {
-        // ignore
+        var commitInput = (AzureServiceBusConsumerCommitInput)sender!;
+        commitInput.AbandonMessageAsync().GetAwaiter().GetResult();
     }
 
     public void Dispose()

diff --git a/src/DotNetCore.CAP.AzureServiceBus/AzureServiceBusConsumerCommitInput.cs b/src/DotNetCore.CAP.AzureServiceBus/AzureServiceBusConsumerCommitInput.cs
@@ -29,4 +29,11 @@ public Task CompleteMessageAsync()
             ? ProcessMessageArgs.CompleteMessageAsync(Message)
             : ProcessSessionMessageArgs!.CompleteMessageAsync(Message);
     }
+
+    public Task AbandonMessageAsync()
+    {
+        return ProcessMessageArgs != null
+            ? ProcessMessageArgs.AbandonMessageAsync(Message)
+            : ProcessSessionMessageArgs!.AbandonMessageAsync(Message);
+    }
 }