Совокупность двух сообщений JMS от двух разных потребителей

Question

У меня есть два пользователя jms, каждый в другом потоке. Я хочу использовать другой поток для агрегирования сообщений двух двух сообщений. и также необходимо сохранить идентификаторы корреляции, поскольку мне нужно разделить полезную нагрузку и отправить обратно сообщения.

<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> 

Я пытался использовать разброс собрать с двумя въездными виртуальными машинами, но получает следующее сообщение об ошибке:

Вызванными: org.xml.sax.SAXParseException: CVC-комплексе-type.2.4.a: Invalid контент был найден, начиная с элемента 'vm: inbound-endpoint'. Один из «{» 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 ": abstract-mixed-content-message-processor} '. на org.apache.xerces.util.ErrorHandlerWrapper.createSAXParseException (Unknown Source)

Answer 1

Причиной ошибки интеграционного internetsolutionsFlow1 не имеет въездного конечную точку ..

Что вы можете сделать следующее: -

Использование VM: исходящее-конечная точка же пути как от потока интеграции-потребительского client1 и интеграционного потребителя cLIENT2

Затем в интеграции-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> 

Путь исходящего VM как от потока интеграции-потребителей-client1 и интеграции-потребителей-client2 должна быть такой же ..

Вам здесь не нужна сборка рассеяния .. так как оба потока будут отключать полезную нагрузку на том же пути VM. Он будет приниматься конечной точкой входа VM