Mule ESB：如何在一个流中处理多个输入队列 (WMQ) - Mule ESB答案

【问题标题】：Mule ESB: How to handle multiple Input Queue (WMQ) in a flow - Mule ESBMule ESB：如何在一个流中处理多个输入队列 (WMQ) - Mule ESB
【发布时间】：2014-05-22 03:45:42
【问题描述】：

请帮助我解决这个问题。最初我有单个 WMQ（入站）连接到 Java Transformer，在完成所有转换之后，最终消息已将其放入文件中。它工作正常。后来客户端更改了要求，多个输入队列必须连接Java Transformer（但转换逻辑相同）。

我正在 WMQ 属性中搜索选项以提及多个队列名称。无法找到解决方案。虽然使用 JMS 不确定是当前的选项。因为我已经使用过 WMQ，所以它工作正常。

请告诉我，我们有什么方法可以处理多个输入队列 (WMQ) 连接到它的下一个消息处理器。请指导我。使用单个队列在下面找到我的工作配置 xml。

           <wmq:connector name="WMQ" hostName="localhost" port="2025"          queueManager="XXX" channel="XXXX" validateConnections="true" doc:name="WMQ"/>
<flow name="Flow1" doc:name="Flow1">
    <wmq:inbound-endpoint queue="INPUT" connector-ref="WMQ" doc:name="WMQ">
        <wmq:transaction action="NONE"/>
    </wmq:inbound-endpoint>
    <custom-transformer class="purchaseOrgin.Controller" doc:name="Java"/>
    <logger message="****Incoming Payload:#[payload]***" level="INFO" doc:name="Logger"/>
    <file:outbound-endpoint path="C:\Users\Star\Desktop\mule\In" responseTimeout="10000" doc:name="File"/>
</flow>

提前致谢。我的部署日期更近了。

【问题讨论】：

标签： mule mule-studio mq mule-el

【解决方案1】：

您需要使用 composite-source 在流中拥有多个入站端点：

<flow ...>
  <composite-source>
     <wmq:inbound-endpoint queue="INPUT" ... />
     <wmq:inbound-endpoint queue="INPUT2" ... />
     ...
  </composite-source>
  ...

【讨论】：

谢谢@David。它确实有效:)。问题解决了。再次感谢您的快速回复。