Fixes RabbitMQ transport reject function call error. (#1608)

dotnetcore · Nov 5, 2024 · 2f8080e · 2f8080e
1 parent 6f6f057
commit 2f8080e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/DotNetCore.CAP.RabbitMQ/RabbitMQConsumerClient.cs b/src/DotNetCore.CAP.RabbitMQ/RabbitMQConsumerClient.cs
@@ -97,7 +97,7 @@ public void Commit(object? sender)
 
     public void Reject(object? sender)
     {
-        _consumer!.BasicAck((ulong)sender!);
+        _consumer!.BasicReject((ulong)sender!);
     }
 
     public void Dispose()