RabbitMQ: подтвердите, что сообщение достигло очереди

Я новичок в RabbitMQ и пытаюсь создать надежного производителя, который продолжает пытаться донести сообщение.

Поэтому мне нужно убедиться, что сообщение отправлено моим производителем и помещено в очередь. Мне просто нужно подтвердить, что он находится в очереди, «возможно, еще не получен потребителем из-за размера очереди».

Мой простой издатель приложений

    var factory = new ConnectionFactory
    {
         Uri = new Uri($"amqp://{_config.MassTransit.Username}:{_config.MassTransit.Password}@{_config.MassTransit.Host}:{_config.MassTransit.Port}")
    };

    using IConnection connection = factory.CreateConnection();
    using IModel channel = connection.CreateModel();


    channel.BasicPublish(message.ExchangeName, message.RoutingKey, null, 
    Encoding.UTF8.GetBytes(JsonSerializer.Serialize(message)));

Итак, как я могу подтвердить сообщение в очереди, чтобы избежать повторной доставки сообщения?

Заранее спасибо.


person karim alaa    schedule 28.04.2021    source источник


Ответы (1)


Вы ищете подтверждение издателя.

person jrhodin    schedule 28.04.2021
comment
Спасибо, кажется, то, что я ищу. - person karim alaa; 01.05.2021