NServiceBus - 发布后回复消息

Question

我有一个成功处理消息的订阅者，然后订阅者继续成功发布另一条消息以表明某个事件已经发生，我的问题是我在发布后尝试将消息返回给初始消息的发送者，并且系统失败并显示以下消息

没有为消息 NServiceBus.Unicast.Transport.CompletionMessage 指定目的地。无法发送消息。检查配置文件中的 UnicastBusConfig 部分，并确保该消息类型存在 MessageEndpointMapping。

返回代码如下所示：

 Bus.Publish(orderMessage);

 Bus.Return((int)MySendBus.Core.ErrorCode.Ok);

app.config 如下：

<configuration>
  <configSections>
    <section name="MsmqTransportConfig" type="NServiceBus.Config.MsmqTransportConfig, NServiceBus.Core"/>
  </configSections>

  <MsmqTransportConfig InputQueue="MyServerInputQueue" ErrorQueue="error" NumberOfWorkerThreads="1" MaxRetries="5"/>
</configuration>

我添加了单播部分，但仍然收到相同的错误。我的理解是，NServicebus 知道如何回复消息，除了 app.config 中找到的 MsmqTransportConfig 输入队列之外，我不必指定一个队列来继续回复。

是否可以让订阅者发布消息然后响应消息发送的位置？

Answer 1

如果您使用 Bus.Return()，则必须在客户端端点上注册回调，如下所示：

Bus.Send<IRequestDataMessage>(m =>
            {
                m.DataId = g;
                m.String = "<node>it's my \"node\" & i like it<node>";
            })
                .Register(i => Console.Out.WriteLine(
                                   "Response with header 'Test' = {0}, 1 = {1}, 2 = {2}.",
                                   Bus.CurrentMessageContext.Headers["Test"],
                                   Bus.CurrentMessageContext.Headers["1"],
                                   Bus.CurrentMessageContext.Headers["2"]));

如果您想返回您选择的完整消息，则使用 Bus.Reply() 并在客户端端点中编写处理程序。我的完整示例可以在此处找到。