Я новичок в 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)));
Итак, как я могу подтвердить сообщение в очереди, чтобы избежать повторной доставки сообщения?
Заранее спасибо.