diff --git a/src/DotNetCore.CAP.RabbitMQ/RabbitMQConsumerClient.cs b/src/DotNetCore.CAP.RabbitMQ/RabbitMQConsumerClient.cs index 42f4665aa..c8d6cf79e 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()