当前位置:  开发笔记 > 编程语言 > 正文

RabbitMQ只侦听队列中的第一条消息

如何解决《RabbitMQ只侦听队列中的第一条消息》经验,为你挑选了0个好方法。

我的Rabbit队列问题当前只对队列中的第一条消息做出反应,之后被忽略的任何其他消息都被忽略了.

我首先实例化连接并在IQueueConnectionProvider中声明队列:

var connectionFactory = new ConnectionFactory() { HostName = hostName };
var connection = _connectionFactory.CreateConnection();
var channel = connection.CreateModel();

然后IQueueConnectionProvider在我的IQueueListener中用作只有一个方法的依赖项:

public void ListenToQueue(string queue)
{
    var channel = _queueConnectionProvider.GetQueue();

    var consumer = new EventingBasicConsumer(channel);
    consumer.Received += (model, ea) =>
    {
        string path = @"d:\debug.log.txt";
        File.AppendAllLines(path, new List() {"MESSAGE RECEIVED", Environment.NewLine });

        var body = ea.Body;
        var message = Encoding.UTF8.GetString(body);

        channel.BasicAck(ea.DeliveryTag, false);
    };

    channel.BasicConsume(queue, true, consumer);

}

我的日志文件最终只是一行"MESSAGE RECEIVED",但我可以在Rabbit ui界面看到我的其他服务正在将消息推送到该队列就好了.

这里有什么我想念的吗?

推荐阅读
谢谢巷议
这个屌丝很懒,什么也没留下!
DevBox开发工具箱 | 专业的在线开发工具网站    京公网安备 11010802040832号  |  京ICP备19059560号-6
Copyright © 1998 - 2020 DevBox.CN. All Rights Reserved devBox.cn 开发工具箱 版权所有