聚合来自两个不同使用者的两条 JMS 消息

Question

我有两个jms消费者，每个都在不同的流中。我想使用另一个流来聚合这两条消息的消息。并且还需要保留相关ID，因为我需要分割有效负载并发送回消息。

    <flow name="integration-consumer-client1" doc:name="integration-consumer-client1">
    <jms:inbound-endpoint doc:name="JMS" connector-ref="Active_MQ" queue="client1.publish"/>
    <logger message="Consumes Client One = #[payload]" level="INFO" doc:name="Logger"/>
    <logger message="Client One Correlation = #[message.correlationId]" level="INFO" doc:name="Logger"/>
    <vm:outbound-endpoint exchange-pattern="one-way" path="client1" doc:name="VM"/>
</flow>
<flow name="integration-consumer-client2" doc:name="integration-consumer-client2">
    <jms:inbound-endpoint doc:name="JMS" connector-ref="Active_MQ" queue="client2.publish"/>
    <logger message="Consumes Client Two = #[payload]" level="INFO" doc:name="Logger"/>
    <logger message="Client Two Correlation = #[message.correlationId]" level="INFO" doc:name="Logger"/>
    <vm:outbound-endpoint exchange-pattern="one-way" path="client2" doc:name="VM"/>
</flow>
<flow name="integration-internetsolutionsFlow1" doc:name="integration-internetsolutionsFlow1">
    <scatter-gather doc:name="Scatter-Gather">
        <vm:inbound-endpoint exchange-pattern="one-way" path="client1" doc:name="VM"/>
        <vm:inbound-endpoint exchange-pattern="one-way" path="client2" doc:name="VM"/>
    </scatter-gather>
</flow>

我尝试将分散收集与两个入站 VM 一起使用，但收到以下错误：

由以下原因导致：组织.xml.sax.SAXParse 异常：cvc-complex-type.2.4.a：发现以元素“vm：入站终结点”开头的无效内容。“{”http://www.mulesoft.org/schema/mule/core“：注释、”http://www.mulesoft.org/schema/mule/core“：自定义聚合策略、”http://www.mulesoft.org/schema/mule/core“：线程配置文件、”http://www.mulesoft.org/schema/mule/core“：抽象消息处理器、”http://www.mulesoft.org/schema/mule/core“：抽象出站终结点、”http://www.mulesoft.org/schema/mule/core“：抽象混合内容消息处理器}”之一是预期的。at org.apache.xerces.util.ErrorHandlerWrapper.createSAXParseException（未知来源）

Answer 1

错误的原因是集成 - 互联网解决方案Flow1没有任何入站endpoint。

你可以做的是以下：-

使用 vm：出站endpoint从流集成-使用者-客户端1 和集成-使用者-客户端2 转到同一路径

然后在integration-internetsolutionsFlow1中

     <flow name="integration-internetsolutionsFlow1" doc:name="integration-internetsolutionsFlow1">
      <vm:inbound-endpoint exchange-pattern="request-response" path="Your Path" doc:name="VM" connector-ref="vmConnector" />
    <logger level="INFO" message="#[message.payload]" doc:name="Logger"/>
<!-- you don't require a setter-getter here -->
    </flow>

流式集成-消费者-客户端1和集成-消费者-客户端2的出站VM路径应该相同。

你不需要在这里分散收集..因为两个流都会将有效负载分配到相同的 VM 路径 .它将由 VM 入站终结点接收