当前位置：文江博客话题详情

是否有适用于 WCF 的 Pub/Sub 的 nServiceBus 示例？

发布于 2024-10-12 14:33:10 字数 272 浏览 2 评论 0原文

这是一个非常常见的模式，我发现它的实现是一场噩梦！

WcfIntegration 示例几乎就是我正在寻找的示例，因为它通过 WCF 端点接收消息。然而，它会自行接收消息。我想要一个单独的订户。

所以我想做的是合并 WcfIntegration 和 pub/sub 示例。

真正的需要是网站调用类库，然后类库调用发布者的 WCF 端点。

然后，订阅者选择接收发布者发布的消息，并对其执行任何操作。

——

罗布

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

隔岸观火 2024-10-19 14:33:10

您不需要 IEventMessageService 接口； NSB 会为您处理。
在我的本地示例中，我将消息映射到我自己。对于您来说，这将是：
```
<添加消息=“MyMessages”端点=“MyPublisherInputQueue”/>
```

您还需要将您的发布移动到实际的处理程序。目前，它只发生一次（在启动时）：

public void Handle(EventMessage 消息)    
{
    总线.发布(消息);
    总线.Return((int)ErrorCodes.None);
}

确保您的基础设施已准备就绪，即队列是事务性的，并且 MSDTC 正在运行。

我敢打赌，由于没有映射，一旦调用服务，它就不知道将消息放在哪里（它在内部调用 Bus.Send() ）。我没有查看订阅者，因为这似乎不是问题。

You shouldn't need the interface IEventMessageService; NSB handles that for you.

In my local example, I mapped the messages to myself. For you this would be:

<UnicastBusConfig><MessageEndpointMappings>
<add Messages="MyMessages" Endpoint="MyPublisherInputQueue"/>
</MessageEndpointMappings></UnicastBusConfig>

You also need to move your Publish to the actual handler. Right now, it is only happening once (at startup):

public void Handle(EventMessage message)    
{
    bus.Publish(message);
    bus.Return((int)ErrorCodes.None);
}

Make sure your infrastructure is primed, i.e. the queue is transactional, and MSDTC is running.

I'm willing to bet that since there is no mapping, once the service is called, it doesn't know where to put the messages (it calls Bus.Send() internally). I didn't look at the subscribers since that didn't seem to be the issue.

回复收藏 0 原文