如何使用 Steeltoe 和 RabbitMQ 注册多个消费者?

问题描述 投票:0回答:0

我正在尝试使用 Steeltoe 注册多个 RabbitMQ 的消费者,但只有一个正在“处理”消息。对于其他消费者,我得到:

“Dispatcher 没有频道‘myConsumer’的订阅者”

下面是我的两个消费者:

消费者#1

[EnableBinding(typeof(ISink))]
    public class LoggingConsumer
    {
        [StreamListener(ISink.INPUT)]
        public void Handle(Person person)
        {
            Console.WriteLine("Received: " + person);
        }


    }

消费者#2

[EnableBinding(typeof(IEnrollment))]
    public class EnrollmentConsumer
    {
        [StreamListener(IEnrollment.INPUT)]
        public void Handle(Enroll message)
        {
            Console.WriteLine("Received: " + message);
        }


    }

Program.cs 中只允许一个

.AddStreamServices<LoggingConsumer>();
,我如何注册多个消费者?

谢谢!

我已按照 Steeltoe 提供的示例注册消费者。 (https://docs.steeltoe.io/guides/stream/quick-start.html

此外,如果我将第二个消费者添加为 service.AddStreamBinding(); 它只会在 RabbitMQ 的队列中创建消费者。

c# .net asp.net-core rabbitmq steeltoe
© www.soinside.com 2019 - 2024. All rights reserved.