AMQP ReceiverLink после принятия сообщения не удаляет сообщение из очереди в пользовательском интерфейсе
Публикую сообщения в виртуальную тему и оттуда в две очереди. Я использую сообщения из одной очереди, используя ReceiverLink асинхронно.
receiverLink.Start(20, (receiverLink, msg) => {
var t = ProcessMessageAsync(receiverLink, msg);
} );
receiverLink.SetCredit(10, CreditMode.Auto, 10);
public async Task ProcessMessageAsync(IReceiverLink receiver, Message message)
{
try
{
receiver.Accept(message);
_logger.LogDebug("Accepted Message : {message}", message.Body.ToString());
}
catch (Exception ex)
{
}
await Task.Delay(1000);
}
Я принимаю сообщения, но счетчик удаленных из очереди остается равным 0 в пользовательском интерфейсе.
Из документации API Receiverlink: «Приложение подтверждает сообщение, вызывая метод Accept(Message), Reject(Message, Error), Release(Message) или Modify(Message, Boolean, Boolean, Fields)».
Если сообщение подтверждено, должно ли оно быть исключено из очереди в пользовательском интерфейсе. я что-то здесь упускаю