是否使用Solace设置了“消息分组”(re ActiveMQ)场景。
例如,考虑大量的消息(例如订单),每个订单都有一个唯一的订单id。对命令的修改/更改具有相同的订单id。我希望对不同的订单id使用循环调度,但需要确保处理相同订单id的消息是“按顺序”处理的。
消息组专门解决了这个问题,但我不知道如何在Solace中实现同样的问题。
-补充情况
我正在使用一个主题结构,如: TOPIC/orders/,这给了我组。然后通过主题/订单/*订阅。
从文档中看,似乎所有组件都可用:通过主题名称分组、保证消息、应用程序确认、通过非排它队列进行循环调度.但是,我没有看到一个具体的例子,说明如何将这些集合在一起来解决“消息组”问题。
谢谢。
发布于 2016-06-15 07:40:20
在Solace设备/VMR上,应用程序可以写入/读取JMSXGroupID,但它对消息传递没有影响。
下面是两个常用的选项来模拟ActiveMQ的JMSXGroupID的行为。
TOPIC/INITIAL
( b)创建一个非排他性队列- INITIAL_QUEUE,该队列被配置为接收发送到TOPIC/INITIAL的所有消息。
( c)没有新通信目的地的发布服务器将向TOPIC/INITIAL发送第一条消息。这个负载平衡了对多个使用者的初始消息。
( d)当消息由使用者处理时,使用者用另一个已知的主题/队列向发布者发送答复,以便由同一使用者处理进一步的订单更新。然后,发布者将向该目的地发送进一步的更新,以确保将所有消息发送给同一个使用者。通过诸如回复目的地和点对点收件箱主题等特性,Solace API可以轻松地处理这一问题。https://stackoverflow.com/questions/37642956
复制相似问题