如何解决如何将 à 大众运输消费者连接到由不同应用程序创建的交换
我使用 Masstransit 和 RabbitMq 在两个 Web 应用程序 .net core 之间进行通信。 在发布者应用程序中,我向交换“生产者”发布一条消息。
rabbitConfigurator.Message<TMessage>(x => x.SetEntityName("producer"));
在同一个应用程序中,我有一个上述消息的消费者 A 并且工作正常(消费者有一个交换和一个队列,如连接到生产者交换的兔子/大众运输所推荐的那样)
rabbitConfigurator.ReceiveEndpoint("consumer-A",x =>
{
x.Consumer<TConsumer>(context);
x.Bind("producer");
});
在第二个应用程序中,我试图设置另一个连接到交换“生产者”的相同消息类型的消费者 B。
rabbitConfigurator.ReceiveEndpoint("consumer-B",x =>
{
x.Consumer<TConsumer>(context);
x.Bind("producer");
});
然而,发往第二个应用程序的消息被发送到一个跳过的队列。不过从我所见,第二个使用者在 RabbitMq 中已正确配置。
我看不到我错过了什么。
编辑:在生产应用程序中,我也可以在第二个消费者中成功接收消息。但是从另一个 Web 应用程序它不起作用 - 也许与存在不同连接/通道的事实有关?
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。