NServiceBus 未在测试系统上发布

Question

我有以下设置：

• 一个名为 CoreHost 的服务应该接收一个 ExecuteWorkflowByAttributeCommand ，它是 Bus.Send 并发布 之后 WorkflowByAttributeExecuted。

• 一个“客户端”使用 Bus.Send 执行命令并订阅 WorkflowByAttributeExecuted 消息。

处理程序如下所示：

    public void Handle(WorkflowByAttributeCommand message)
    {
        MessageLifetimeLogger.Info("Received WorkflowByAttribute Command", ...);

        var log = _executor.ExecuteWithLog(message.Attribute, 
                                           message.SerializedWorkItem,
                                           message.Id);
        Bus.Publish(new WorkflowByAttributeExecuted(message.Id, log));

        MessageLifetimeLogger.Info("Completed WorkflowByAttribute Command", ...);
    }

在我的开发机器上它运行良好，但在我们的测试系统上却运行不佳。

命令被接收并且处理程序显然被执行（日志包含适当的条目），但没有发布消息。

令我惊讶的是日志在两台机器上看起来完全不同。

工作机器日志包含

Received message MHP.Domain.Common.Core.Messaging.WorkflowByAttribute.WorkflowByAttributeCommand, MHP.Domain.Common.Core, Version=0.0.0.1, Culture=neutral, PublicKeyToken=null with ID 6e15d4f7-7aa7-4be3-bd80-e70497bc5051\66585 from sender TestServerQueue@PC-SB-11
Activating: WorkflowByAttributeHandler 
// some log entries generated by the Handle method
Sending message MHP.Domain.Common.Core.Messaging.WorkflowByAttribute.WorkflowByAttributeExecuted, MHP.Domain.Common.Core, Version=0.0.0.1, Culture=neutral, PublicKeyToken=null with ID 6e15d4f7-7aa7-4be3-bd80-e70497bc5051\66587 to destination TestServerQueue@PC-SB-11.
WorkflowByAttributeHandler Done. 

其中不工作机器日志仅包含

Received message MHP.Domain.Common.Core.Messaging.WorkflowByAttribute.WorkflowByAttributeCommand, MHP.Domain.Common.Core, Version=0.0.0.1, Culture=neutral, PublicKeyToken=null with ID 6e15d4f7-7aa7-4be3-bd80-e70497bc5051\66585 from sender TestServerQueue@PC-SB-11
// some log entries generated by the Handle method

但是所有消息类型似乎都已成功注册：

Subscribing TestServerQueue@VM-SCRUM-VLOG to message type MHP.Domain.Common.Core.Messaging.WorkflowByAttribute.WorkflowByAttributeExecuted, MHP.Domain.Common.Core, Version=0.0.0.1, Culture=neutral, PublicKeyToken=null |  
Subscribing TestServerQueue@VM-SCRUM-VLOG to message type MHP.Domain.Common.Core.Messaging.WorkflowByAttribute.WorkflowByAttributeCommand, MHP.Domain.Common.Core, Version=0.0.0.1, Culture=neutral, PublicKeyToken=null |  

服务器的 app.config 看起来像

<MsmqTransportConfig
    InputQueue="CoreHostQueue"
    ErrorQueue="ErrorQueue"
    NumberOfWorkerThreads="1"
    MaxRetries="5" />

<UnicastBusConfig>
    <MessageEndpointMappings>
    </MessageEndpointMappings>
</UnicastBusConfig>

另一个包含消息映射

<MsmqTransportConfig
  InputQueue="TestServerQueue"
  ErrorQueue="ErrorQueue"
  NumberOfWorkerThreads="2"
  MaxRetries="5" />

<UnicastBusConfig>
  <MessageEndpointMappings>
    <add Messages="MHP.Domain.Common.Core.Messaging.WorkflowByAttribute.WorkflowByAttributeCommand, MHP.Domain.Common.Core" Endpoint="CoreHostQueue"/>
    <add Messages="MHP.Domain.Common.Core.Messaging.WorkflowByAttribute.WorkflowByAttributeExecuted, MHP.Domain.Common.Core" Endpoint="CoreHostQueue"/>
  </MessageEndpointMappings>
</UnicastBusConfig>

Answer 1

订阅未持久存储。感谢 Andreas Öhlund 的帮助！

Answer 2

请注意，只有在发布者和订阅者上保存您要发布的消息的程序集的版本和公钥标记相同时，发布者才会成功评估订阅。

原因是订阅者在启动时向发布者发送的订阅消息包含此信息。

检查发布者订阅存储中存储的订阅消息，并确保版本/PKT 与订阅者匹配。