如何以编程方式将映射添加到 UnicastBusConfig？

Question

我希望能够在运行时向我的应用程序添加对可能位于不同服务器上的其他消息类型的订阅。我想要实现的是一个监控应用程序，我可以在运行时添加/删除订阅。这可能吗？如何获取当前 UnicastBus 映射的引用？

这是我到目前为止正在做的事情，但我相信这将覆盖当前存在的任何映射。

MessageEndpointMappingCollection mappings = new MessageEndpointMappingCollection();
mappings.Add(new MessageEndpointMapping()
{
    Messages = m.MessageType.ToString(),
    Endpoint = m.QueueName
});

IComponentConfig<UnicastBusConfig> busConfig = config.Configurer.ConfigureComponent<UnicastBusConfig>(ComponentCallModelEnum.None);
busConfig.ConfigureProperty(u => u.MessageEndpointMappings, mappings);

Answer 1

Yves 在他的 Azure 示例中使用了此代码（可在 NSB 示例集合中找到）

using NServiceBus.Config;
using NServiceBus.Config.ConfigurationSource;

namespace OrderService
{
    class ConfigOverride : IProvideConfiguration<UnicastBusConfig>
    {
        public UnicastBusConfig GetConfiguration()
        {
            return new UnicastBusConfig
            {
                MessageEndpointMappings = new MessageEndpointMappingCollection
                {
                    new MessageEndpointMapping { Messages="MyMessages", Endpoint="orderserviceinputqueue" }
                }
            };
        }
    }
}

Answer 2

解决此问题的最佳方法是实现 IConfigurationSource 并提供您自己的配置。然后，您可以挑选您想要从配置文件中加载的内容（如果有的话）以及您想要在运行时自己指定的内容。

我会反映 DefaultConfigurationSource 类或参考此要点获取指导。

Answer 3

在我目前参与的一个项目中，我们正在通过在我们自己的路由表中跟踪动态订阅/取消订阅代理来对它们进行一些基于内容的路由。

我们将 IBus 包装在装饰器中（通过使用 Windsor 对装饰器的支持，如 此处），查看消息是否实现了特殊的IRoutableMessage接口，该接口允许装饰器通过<代码>bus.Send(destinationEndpoint)。

要做到这一点有点复杂，我建议尽可能使用 NServiceBus 的内置路由。但是是否可以将消息显式路由到任何端点。

Answer 4

如果您正在研究监控，请查看 NSBManager 存储库。这采用相反的方法，让端点向管理器注册。