是否可以对NServiceBus中的事件发布者进行范围/分组?

塞尔吉·谢梅诺夫(Serge Semenov)

我有:
-一个订阅者SUB与QUEUE0-
发布者PUB1与QUEUE1-
发布者PUB2与QUEUE2-
事件MyEvent由两个发布者发布

在以下情况下:
-SUB仅使用队列名称QUEUE1明确订阅PUB1

subscriberEndpointConfiguration.UnicastRouting().AddPublisher("PUB1", typeof(MyEvent));

结果:-SUB
MyEvent从PUB2接收(队列名称为QUEUE2)

预期:
-SUB不应MyEvent从PUB2接收,因为它未订阅该发布者队列名称

从NSB Wiki:

订阅者对一个或多个类表示兴趣,并且仅接收感兴趣的消息,而不知道那里有什么发布者

问题

  1. AddPublisher上面显示方法中指定发布者终结点有什么意义Azure表存储中的订阅表具有事件类型和仅订阅者列,未存储发布者终结点。

  2. 如果AddPublisher是某种过时的方法,则endpointInstance.Subscribe<MyEvent>()简单地失败-它说“找不到发布者”。

  3. 是否可以对发布者进行范围/分组,以便只有一种事件类型MyEvent,订阅者才能从仅使用相同队列名创建的发布者那里收到该事件?
    例如,您创建带有QUEUE-A的PUB1,带有队列QUEUE-A的PUB2,带有QUEUE-B的PUB3和带有AddPublisherQUEUE-A的SUB,因此SUB不会MyEvent从PUB3接收(QUEUE-B)。

我正在使用:
NServiceBus 6.0.0-beta0004
NServiceBus.Persistence.AzureStorage 1.0.0-beta0004
NServiceBus.Azure.Transports.WindowsAzureStorageQueues 7.0.0-beta0004

肖恩·费尔德曼(Sean Feldman)
  1. Azure存储队列传输使用持久性支持pub / sub在那里需要指定发布者终结点,以允许订阅者在启动时发送订阅消息。默认情况下,所有端点都使用相同的共享存储表,这就是为什么您要体验自己描述的原因。如果按每个端点(每个端点都有自己的存储表)拆分订阅,则您将看到SUB仅从PUB1接收到一个事件,前提是它是唯一订阅的发布者。

  2. AddPublisher()这不是一种过时的方法。已过时的消息将被标记为原样。话虽如此,路由功能仍然可以在我们目前处于测试阶段的阶段进行修改。

  3. 可以按照Philip概述的方式进行作用域确定。同时,我鼓励研究一下为什么您有两个不同的端点生成同一事件。通常,您希望事件是唯一的,并由单个端点(或所有实例)引发,但不要由两个或多个不同的端点引发。

本文收集自互联网,转载请注明来源。

如有侵权,请联系[email protected] 删除。

编辑于
0

我来说两句

0条评论
登录后参与评论

相关文章

来自分类Dev

可以在IIS中托管NServiceBus发布者吗?

来自分类Dev

可以在IIS中托管NServiceBus发布者吗?

来自分类Dev

Jenkins中的ZMQ事件发布者未发送通知

来自分类Dev

如何在发布者中获得事件的响应?

来自分类Dev

NServiceBus可以将同一应用程序同时作为发布者/订阅者吗?

来自分类Dev

mongodb:是否可以对数组数组中的第一项进行范围搜索

来自分类Dev

节点是否可以对事件进行声明?

来自分类Dev

迅速。结合。重试时是否可以多次调用发布者块?

来自分类Dev

使用发布者确认时,是否可以恢复已被删除的邮件

来自分类Dev

是否可以使用 Reactor 3.0 以编程方式查找上游发布者?

来自分类Dev

SQL查询以对月度范围进行分组

来自分类Dev

ASP.NET Web Api的事件发布者

来自分类Dev

我如何默认将发布者证书安装到“受信任的发布者”中?

来自分类Dev

在Elasticsearch中,是否可以对索引进行临时POST?

来自分类Dev

ReactJS中的发布者/订阅者模型

来自分类Dev

nanomsg (nng) 中的多个发布者和订阅者

来自分类Dev

订户可以根据发布者选择消息吗?

来自分类Dev

是否可以根据特定参数对事件进行分组并在每组中运行 Flink CEP 模式?

来自分类Dev

是否可以对与std :: variant一起使用的结构进行分组

来自分类Dev

在 NServiceBus 6 中,端点可以在不知道发布端点的情况下订阅事件吗?

来自分类Dev

使用qos 2进行发布的发布者得到经纪人或订阅者的确认

来自分类Dev

是否可以对文本区域的内容进行onClick事件?

来自分类Dev

O(n)算法在社交网络中查找“发布者”

来自分类Dev

Spring AMQP中的“发布者退货”如何发生/工作?

来自分类Dev

在发布者端在SimpleInjector中为MassTransit建立队列

来自分类Dev

发布者完成后,从AnyCancellable数组中删除

来自分类Dev

在SwiftUI中异步更新后如何触发发布者?

来自分类Dev

为什么发布者在Pika RabbitMQ中声明队列a?

来自分类Dev

O(n)算法在社交网络中查找“发布者”

Related 相关文章

  1. 1

    可以在IIS中托管NServiceBus发布者吗?

  2. 2

    可以在IIS中托管NServiceBus发布者吗?

  3. 3

    Jenkins中的ZMQ事件发布者未发送通知

  4. 4

    如何在发布者中获得事件的响应?

  5. 5

    NServiceBus可以将同一应用程序同时作为发布者/订阅者吗?

  6. 6

    mongodb:是否可以对数组数组中的第一项进行范围搜索

  7. 7

    节点是否可以对事件进行声明?

  8. 8

    迅速。结合。重试时是否可以多次调用发布者块?

  9. 9

    使用发布者确认时,是否可以恢复已被删除的邮件

  10. 10

    是否可以使用 Reactor 3.0 以编程方式查找上游发布者?

  11. 11

    SQL查询以对月度范围进行分组

  12. 12

    ASP.NET Web Api的事件发布者

  13. 13

    我如何默认将发布者证书安装到“受信任的发布者”中?

  14. 14

    在Elasticsearch中,是否可以对索引进行临时POST?

  15. 15

    ReactJS中的发布者/订阅者模型

  16. 16

    nanomsg (nng) 中的多个发布者和订阅者

  17. 17

    订户可以根据发布者选择消息吗?

  18. 18

    是否可以根据特定参数对事件进行分组并在每组中运行 Flink CEP 模式?

  19. 19

    是否可以对与std :: variant一起使用的结构进行分组

  20. 20

    在 NServiceBus 6 中,端点可以在不知道发布端点的情况下订阅事件吗?

  21. 21

    使用qos 2进行发布的发布者得到经纪人或订阅者的确认

  22. 22

    是否可以对文本区域的内容进行onClick事件?

  23. 23

    O(n)算法在社交网络中查找“发布者”

  24. 24

    Spring AMQP中的“发布者退货”如何发生/工作?

  25. 25

    在发布者端在SimpleInjector中为MassTransit建立队列

  26. 26

    发布者完成后,从AnyCancellable数组中删除

  27. 27

    在SwiftUI中异步更新后如何触发发布者?

  28. 28

    为什么发布者在Pika RabbitMQ中声明队列a?

  29. 29

    O(n)算法在社交网络中查找“发布者”

热门标签

归档