我正在尝试使用 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 的队列中创建消费者。