MassTransit，在不同的虚拟主机上使用 UseMessageScheduler

debugcn 发表于 Dev

穆罕默德·礼萨·萨雷迪尼

是否可以配置 UseMessageScheduler 以使用与其总线不同的虚拟主机？

在尝试实现此目标时，我遇到了“找不到指定地址的主机”。

这是我的总线配置：

_myBus = Bus.Factory.CreateUsingRabbitMq(sbc =>
{
    var host = sbc.Host(new Uri("rabbitmq://localhost/MyVirtualHostName"), h =>
    {
        h.Username("guest");
        h.Password("guest");
    });

    sbc.ReceiveEndpoint(host, "MySaga", ep =>
    {
        var machine = new MyStateMachine();
        ep.StateMachineSaga(machine, _sagaRepository);

        sbc.UseMessageScheduler(new Uri("rabbitmq://localhost/Quartz"));
    });
});

我还检查了 MassTransit.QuartzService 正在运行并使用“rabbitmq://localhost/Quartz”。

当我在同一个虚拟主机上使用调度时，它工作正常。更清楚地说，我的意图是使用相同的 QuartzService 使用具有不同虚拟主机的不同应用程序。

我使用：
MT 5.1.4
Automatonymous 5.1.3
MassTransit.Quartz 5.1.4

任何帮助真的很感激:)

穆罕默德·礼萨·萨雷迪尼

感谢@chris-patterson 的评论，我通过在总线中添加另一个主机解决了这个问题。这是我的配置：

_myBus = Bus.Factory.CreateUsingRabbitMq(sbc =>
 {
     var quartzHost = sbc.Host(new Uri("rabbitmq://localhost"), h =>
     {
        h.Username("guest");
        h.Password("guest");
     });

     var host = sbc.Host(new Uri("rabbitmq://localhost/MyVirtualHostName"), h =>
     {
        h.Username("guest");
        h.Password("guest");
     });

     sbc.ReceiveEndpoint(host, "MySaga", ep =>
     {
         var machine = new MyStateMachine();
         ep.StateMachineSaga(machine, _sagaRepository);

         sbc.UseMessageScheduler(new Uri("rabbitmq://localhost/Quartz"));
     });
});

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。