聚合来自两个不同消费者的两条 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 使用分散聚集，但收到以下错误：

原因：org.xml.sax.SAXParseException：cvc-complex-type.2.4.a：发现以元素“vm:inbound-endpoint”开头的无效内容。 '{"http://www.mulesoft.org/schema/mule/core":annotations, "http://www.mulesoft.org/schema/mule/core":custom-aggregation-strategy, "http://www.mulesoft.org/schema/mule/core":threading-profile, "http://www.mulesoft.org/schema/mule/core":abstract-message-processor, "http://www.mulesoft.org/schema/mule/core 之一":abstract-outbound-endpoint, "http://www.mulesoft.org/schema/mule/core":abstract-mixed-content-message-processor}' 是预期的。 在 org.apache.xerces.util.ErrorHandlerWrapper.createSAXParseException（未知来源）

Answer 1

错误原因是integration-internetsolutionsFlow1没有任何入站端点..

您可以执行以下操作：-

使用 vm:outbound-endpoint 到两个流程的相同路径 integration-consumer-client1 和 integration-consumer-client2

然后在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>

integration-consumer-client1 和 integration-consumer-client2 流的出站虚拟机路径应该相同..

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