背景信息
我在RabbitMQ中有一个队列(用于电子邮件),并希望为它构建一个使用者.该队列由另一个.NET应用程序用于向客户发送电子邮件.我希望电子邮件逻辑能够位于.NET应用程序之外,并且还具有RabbitMQ提供的持久性等优点.
问题
.NET应用程序能够将电子邮件发布/推送到队列中,但我很难构建消费者!这是我的消费者代码:
// A console app that would be turned into a service via TopShelf public void Start() { using (_connection = _connectionFactory.CreateConnection()) { using (var model = _connection.CreateModel()) { model.QueueDeclare(_queueName,true,false,null); model.BasicQos(0,1,false); var consumer = new EventingBasicConsumer(model); consumer.Received += (channelModel,ea) => { var message = (Email) ea.Body.DeSerialize(typeof(Email)); Console.WriteLine("----- Email Processed {0} : {1}",message.To,message.Subject); model.BasicAck(ea.DeliveryTag,false); }; var consumerTag = model.BasicConsume(_queueName,consumer); } } }
上面的代码应该能够从队列中获取消息并处理它们(根据这个official guide),但这不会发生.
解决方法
原文地址:https://www.jb51.cc/csharp/91971.html
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。