Spring Integration DSL :根据消息负载向多个订阅者(不是所有订阅者)发送消息

Question

我必须创建一个向多个订阅者发送消息的管道，我可以使用publishSubscribeChannel来实现这一点。

但是在我的例子中，当我收到消息时--我有一个类似的eventSubType

<ns1:eventSubType>0:INIT-SHIP-ASSIGN,BKD,</ns1:eventSubType>

我必须检查eventSubType是否包含INIT-SHIP-ASSIGN，然后我会将它路由到"INIT-SHIP-ASSIGN“通道，如果它是"BKD”，那么我必须将它路由到"Booked“通道。类似地，我们有其他的eventSubTypes。

我的挑战是-我有5个不同的子类型，在每条消息中我们可以有多个子类型。因此，根据消息中可用的事件子类型(可以大于1)，我们必须将消息发送给多个订阅者，而不是所有订阅者。

请给出建议

Answer 1

请改用recipient list router。

.routeToRecipients(r -> r
        .recipient("thing1-channel", "'thing1' == payload")
        .recipientMessageSelector("thing2-channel", m ->
                m.getHeaders().containsKey("recipient")
                        && (boolean) m.getHeaders().get("recipient"))
        ...