From 2f8080e8213a68d5d37a6616dcf7d30eae1c4c07 Mon Sep 17 00:00:00 2001 From: Savorboard Date: Tue, 5 Nov 2024 11:56:47 +0800 Subject: [PATCH] Fixes RabbitMQ transport reject function call error. (#1608) --- src/DotNetCore.CAP.RabbitMQ/RabbitMQConsumerClient.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/DotNetCore.CAP.RabbitMQ/RabbitMQConsumerClient.cs b/src/DotNetCore.CAP.RabbitMQ/RabbitMQConsumerClient.cs index 42f4665a..c8d6cf79 100644 --- 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()