NServiceBus：如何让订阅者在不使用通用主机的情况下开始处理混乱？

Question

我正在修改 PubSub 示例，并一直在尝试 NServiceBus 的配置。目前，我的 EndpointConfig.cs 文件具有如下配置：

Configure.With(new[] { typeof(IEvent), typeof(NServiceBus.Unicast.Transport.CompletionMessage) })
            .CustomConfigurationSource(new UserConfigurationSource()
               .Register(() => new MsmqTransportConfig { InputQueue = "Subscriber2InputQueue", ErrorQueue = "error", NumberOfWorkerThreads = 1, MaxRetries = 5 }))
            .DefaultBuilder()
            .XmlSerializer()
            .MsmqTransport()
            .IsTransactional(true);

现在我想将其更改为没有通用主机的控制台应用程序。以下是我所做的更改：

1. 将项目输出更改为控制台应用程序
2. 将启动设置更改为不调用通用主机

3. 将上面的配置移至 Main 方法，如下所示：

   Configure.With(new[] { typeof(IEvent), typeof(NServiceBus.Unicast.Transport.CompletionMessage) })
               .CustomConfigurationSource(new UserConfigurationSource()
                  .Register(() => new MsmqTransportConfig { InputQueue = "Subscriber2InputQueue", ErrorQueue = "error", NumberOfWorkerThreads = 1, MaxRetries = 5 }))
               .DefaultBuilder()
               .XmlSerializer()
               .MsmqTransport()
               .IsTransactional(true);
   
   
    Console.ReadLine();
   
   
   

我还应该做其他事情来“启动”订阅者来读取消息吗？

Answer 1

查看异步页面示例，了解如何自行托管 NServiceBus（就像在 IIS 中一样）。您缺少 .UnicastBus().LoadMessageHandlers().Start()。

Answer 2

仅供参考，我的配置看起来像这样，

_Bus = NServiceBus.Configure.With()
              .DefaultBuilder()
              .Log4Net(new MyLogAppender())
              .XmlSerializer()
              .MsmqTransport()
                  .IsTransactional(false)
                  .PurgeOnStartup(true)
              .UnicastBus()
                  .ImpersonateSender(false)
                  .DoNotAutoSubscribe()
                  .LoadMessageHandlers()
              .CreateBus()
              .Start();