0

请在这个问题上帮助我。最初我有单个 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>

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

4

1 回答 1

1

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

<flow ...>
  <composite-source>
     <wmq:inbound-endpoint queue="INPUT" ... />
     <wmq:inbound-endpoint queue="INPUT2" ... />
     ...
  </composite-source>
  ...
于 2014-05-21T19:45:42.267 回答