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)».

Если сообщение подтверждено, должно ли оно быть исключено из очереди в пользовательском интерфейсе. я что-то здесь упускаю

0 ответов

Другие вопросы по тегам