问题描述
我是 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)));
那么,如何确认队列中的消息以避免重新发送消息?
提前致谢。
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)