发布到具有不同存储的多个Rebus队列

我们有一个发布消息的应用程序-PublishApp。

消息（MessageA和MessageB）由两个不同的消费者应用程序（ConsumerA和ConsumerB）拾取。

所有应用程序都使用SQL Server作为传输和Windsor配置，但这两个Consumer在SQL Server中有不同的数据库。

我们如何配置PublishApp来为ConsumerA发布MessageA，为ConsumerB发布MessageB

我已经尝试过使用这里描述的DetermineMessageOwnership，但实际上似乎并没有调用它（没有命中断点）。对于返回的字符串端点应该是什么，我有点困惑

我希望我可以在Windsor中设置一个具有特定名称的IBus组件，然后在设置MessageB发布类时按名称引用该组件。然而，目前还不清楚如何在温莎的魔盒之外建立一个IBus，为我做这一切。

如果我尝试调用Configure.With(new WindsorContainerAdapter(container))两次，那么使用Windsor配置会导致Windsor错误，因为它被解释为注册IBus接口两次。我在这里看不到为其中一个IBus实例命名的扩展点，因此无法在Windsor中区分它们。

或者，尝试重用Configure.With...调用会抛出一个错误，告诉我已经在配置程序上调用了.Transport()两次，这也是不允许的（但这会让我使用不同的连接字符串…）

添加XML配置可以让我为不同的消息指定不同的端点，但不能指定不同的SQL连接字符串。

我真正想得到的是这样的东西：

// Set up Bus A
var busA = Configure.With(new WindsorContainerAdapter(container))
    .Transport(tc => tc.UseSqlServerInOneWayClientMode("ConnectionStringA"))
    .Subscriptions(sc => sc.StoreInSqlServer("ConnectionStringA", "RebusSubscriptions"))
    .CreateBus()
    .Start();
// Set up Bus B
var busB = Configure.With(new WindsorContainerAdapter(container))
    .Transport(tc => tc.UseSqlServerInOneWayClientMode("ConnectionStringB"))
    .Subscriptions(sc => sc.StoreInSqlServer("ConnectionStringB", "RebusSubscriptions"))
    .CreateBus()
    .Start();
// Register Bus A in Windsor
container.Register(Component.For<IBus>()
    .Named("BusA")
    .Instance(busA));
// Register a class that depends on IBus, and set it to use Bus A
container.Register(Component.For<IPublishA>()
    .ImplementedBy<PublishA>()
    .DependsOn(Dependency.OnComponent(typeof(IBus), "BusA"));
// And a registration also for IBus B, and for IPublishB to reference named "BusB"

注意：我不想监听多个总线，只想向它们发布事件。其他应用程序正在监视队列，每个应用程序只侦听一个队列上的一个事件。

    public static void ConfigureAndStartBus(IWindsorContainer container)
    {
        _RegisterBus(container, "ConnectionStringA" "BusA");
        _RegisterBus(container, "ConnectionStringB" "BusB");
    }
    private static void _RegisterBus(IWindsorContainer container, string connectionString, string busName)
    {
        var bus = Configure.With(new BuiltinContainerAdapter())
            .Transport(tc => tc.UseSqlServerInOneWayClientMode(connectionString))
            .Subscriptions(sc => sc.StoreInSqlServer(connectionString, "RebusSubscriptions"))
            .CreateBus()
            .Start();
        container.Register(
            Component.For<IBus>()
                .Named(busName)
                .LifestyleSingleton()
                .Instance(bus));
    }