小编cpr*_*ler的帖子

RabbitMQ 消费者总是直接关闭(C#)

目前我正在学习如何使用 RabbitMQ。发送作品。但是接收不起作用。这是我的代码:

    var factory = new ConnectionFactory() { HostName = hostName };
        using (var connection = factory.CreateConnection())
        using (var channel = connection.CreateModel())
        {
            channel.QueueDeclare(queue: queueName,
                             durable: false,
                             exclusive: false,
                             autoDelete: false,
                             arguments: null);
            var consumer = new EventingBasicConsumer(channel);
            consumer.Received += (model, ea) =>
            {
                var body = ea.Body;
                var message = Encoding.UTF8.GetString(body);
                Console.WriteLine("Recieved: {0}", message);
            };
            consumer.Shutdown += (o, e) =>
            {
                Console.WriteLine("Error with RabbitMQ: {0}", e.Cause);
                createConnection(hostName, queueName);
            };
            channel.BasicConsume(queueName, true, consumer);
        }
Run Code Online (Sandbox Code Playgroud)

这是从教程中复制的。如果我启动应用程序,则直接调用 consumer.Shutdown 并得到:

    {AMQP close-reason, initiated …
Run Code Online (Sandbox Code Playgroud)

c# rabbitmq

4
推荐指数
1
解决办法
2613
查看次数

标签 统计

c# ×1

rabbitmq ×1