Mule ESB:如何处理流中的多个输入队列(WMQ)——Mule ESB

Question

请帮帮我。最初，我有一个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:UsersStarDesktopmuleIn" responseTimeout="10000" doc:name="File"/>
</flow>

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

Answer 1

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

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