NServiceBus 订阅不起作用

Question

我正在尝试设置一个 NServiceBus PubSub 示例，该示例托管在一组 Windows 服务中。

我已经配置了我的发布者，并且可以看到它调用我的总线发布方法。我还配置了一个订阅者来监听我发送的消息。然而，实际的订阅过程似乎没有正常工作，因为我看不到一条日志消息，表明订阅者已被订阅（就像我在 PubSub 示例中所做的那样）。

我只是想知道您自己托管服务时是否需要某种魔法才能使这项工作正常进行。

下面是我的配置

发布者

App.Config

 <configSections>
    <section name="MsmqTransportConfig" type="NServiceBus.Config.MsmqTransportConfig, NServiceBus.Core" />
    <section name="UnicastBusConfig" type="NServiceBus.Config.UnicastBusConfig, NServiceBus.Core" />
  </configSections>
  <!-- 1. In order to configure remote endpoints use the format: "queue@machine" 
       2. Input queue must be on the same machine as the process feeding off of it.
       3. Error queue can (and often should) be on a different machine.
       4. The community edition doesn't support more than one worker thread.
  -->

  <MsmqTransportConfig InputQueue="publisher.input" ErrorQueue="error" NumberOfWorkerThreads="1" MaxRetries="5" />
  <UnicastBusConfig>
    <MessageEndpointMappings></MessageEndpointMappings>
  </UnicastBusConfig>

总线设置：

var bus = Configure.With()
            .Log4Net()
            .NinjectBuilder()
            .XmlSerializer()
            .MsmqSubscriptionStorage()
            .MsmqTransport()
                .IsTransactional(false)
                .PurgeOnStartup(false)
            .UnicastBus()
                .ImpersonateSender(false)
            .CreateBus()
            .Start();

订阅者

App.Config

<configSections>
    <section name="MsmqTransportConfig" type="NServiceBus.Config.MsmqTransportConfig, NServiceBus.Core" />
    <section name="UnicastBusConfig" type="NServiceBus.Config.UnicastBusConfig, NServiceBus.Core" />
  </configSections>
  <!-- 1. In order to configure remote endpoints use the format: "queue@machine" 
       2. Input queue must be on the same machine as the process feeding off of it.
       3. Error queue can (and often should) be on a different machine.
       4. The community edition doesn't support more than one worker thread.
  -->

  <MsmqTransportConfig
    InputQueue="subscriber.input"
    ErrorQueue="error"
    NumberOfWorkerThreads="1"
    MaxRetries="5"
  />

  <UnicastBusConfig>
    <MessageEndpointMappings>
      <add Messages="MyEventNamespace" Endpoint="publisher.input" />
    </MessageEndpointMappings>
  </UnicastBusConfig>

总线设置：

        var bus = Configure.With()
            .Log4Net()
            .NinjectBuilder()
            .XmlSerializer()
            .MsmqSubscriptionStorage()
            .MsmqTransport()
                .IsTransactional(false)
                .PurgeOnStartup(false)
            .UnicastBus()
                .ImpersonateSender(false)
            .CreateBus()
            .Start();

有什么我遗漏或做的很愚蠢的事情吗？

干杯

Answer 1

主要问题是您在订阅者中的 .UnicastBus() 之后没有调用 .LoadMessageHandlers() 。因此，它不知道您有一个配置为来自publisher.input 的事件处理程序，因此不会订阅。

另一件事是，您不需要包含订阅者的 .MsmqSubscriptionStorage() 。

Answer 2

在订阅者中，您可以调用 Bus.Subscribe() 并显式设置它。

Answer 3

对于使用“不显眼模式”的任何人，您还应该确保定义了消息约定。

我在某个地方看到了一个示例，该示例已将其添加到消息处理程序的项目中：

class MessageConventions : IWantToRunBeforeConfiguration { 
   public void Init() {
      Configure.Instance.DefiningMessagesAs(t => t.Namespace != null &&  
            t.Namespace.StartsWith("Your.Messages.Namespace.Here"));
   }
}

这对我有用。

示例代码此处 包含类似的内容。