RabbitMQ Transport Reject Function Call Error

[LuckyZhangWeiwei]

public void Reject(object? sender)
{
_consumer!.BasicAck((ulong)sender!);
}

should be

public void Reject(object? sender)
{
_consumer!.BasicReject((ulong)sender!);
}

[yang-xiaodong]

上引用或截图我看看

[LuckyZhangWeiwei]

[LuckyZhangWeiwei]

\CAP\src\DotNetCore.CAP.RabbitMQ\RabbitMQConsumerClient.cs

[yang-xiaodong]

你这是最新代码么

[LuckyZhangWeiwei]

是 我刚有查了一下您现在的main 分支 也是这种代码
public void Commit(object? sender)
{
_consumer!.BasicAck((ulong)sender!);
}

public void Reject(object? sender)
{
    _consumer!.BasicAck((ulong)sender!);
}

[yang-xiaodong]

确认Bug，由8.2.0版本引入，感谢你的报告！

[yang-xiaodong]

Fixed in version 8.3.1