Pentaho JMS 消费者 - 多个生产者到一个消费者

Pentaho JMS consumer - multiple producer to a single consumer

我有 2 个 JMS 队列,我的应用程序可以根据接收请求的节点将消息发布到队列中的任何一个。 Pentaho 应该积极地查看两个队列,并且应该能够在消息到达两个队列中的任何一个时立即进行处理。

目前,我已经实施了一项工作来主动侦听一个队列并处理消息,并 post 对此作出响应。

我们如何配置 pentaho 同时主动监听两个队列,并在任一队列 post 收到消息时执行相同的操作?

编辑 我不知道 Pentaho 中有任何此类直接功能可用于此类服务内通信。

聚类是否有助于解决这个问题?

终于破解了

Job1 
Start (Run next entries in Parallel) -> Transformation1 (JMS Consumer1)
                                    |-> Transformation2 (JMS Consumer2)

将任务和消息优先级逻辑放在应用程序端。