0

我有使用所有默认设置（确认模式AUTO）的 IBM MQ 连接器的基本流程。如果流程在两者之间抛出错误，则消息开始循环运行，而不会结束线程。

我希望因为它AUTO应该通过看到错误来结束线程。

据我记得在旧版本 3.6 中它可以完美运行ACK mode AUTO

在 Mule4 中 - 设置 ACKManual或者Immediate它工作正常。

我尝试将 IBM MQ 连接器v1.6.0以及所有客户端 jar 更新为最新的“9.1.2.0”。所有行为都相同。

谁能解释一下这是 IBM Queue 连接器在 Mule4 中的默认行为ACK mode AUTO。谁能指出我错过了什么？

我使用 Mule 版本：4.2.2

   <ibm-mq:config name="IBM_MQ_Config" doc:name="IBM MQ Config" doc:id="a217b071-0d6b-4674-8696-0a74c8e8b4ee" sendCorrelationId="ALWAYS">
<ibm-mq:connection username="admin" password="passw0rd">
    <ibm-mq:connection-mode >
        <ibm-mq:client host="${mq.inbound.host}" queueManager="${mq.inbound.queueManager}" channel="${mq.inbound.channelName}" port="${mq.inbound.port}"/>
    </ibm-mq:connection-mode>
</ibm-mq:connection>


   <flow name="NotificationFlow" doc:id="a275ef91-8608-49a5-adcc-624c2dc6aacd" >
        <ibm-mq:listener doc:name="On New Message" doc:id="5de4cf1b-bd66-4519-b170-69f2159bd8b4" config-ref="IBM_MQ_Config" destination="testQ" ackMode="AUTO"/>
        <logger level="INFO" doc:name="Logger" doc:id="9c4c241b-d564-44ff-a2a3-6433e48ddf0a" />
        <ee:transform doc:name="Transform Message" doc:id="46c10c0c-3f0a-4184-a722-7caab39ca97d" >
            <ee:message >
                <ee:set-payload ><![CDATA[%dw 2.0
import * from dw::Runtime
var result = []
output application/java
---
if(sizeOf(result) <= 0) fail('Data was empty') else result]]></ee:set-payload>
            </ee:message>
        </ee:transform>
    </flow>
4

1 回答 1

1

这似乎是预期的结果。当流程中出现错误时，消息不会被确认，因此会返回到队列中。下一次读取将收到相同的未确认消息。这就是所谓的有毒信息。

从应用程序端，您可以使用 on continue 错误处理程序处理错误，使其不会冒泡到流程中。这样，错误就会被消耗，并且在流程完成时将确认消息。

如果要管理重新传递，则必须配置代理（在本例中为 IBM MQ）以以不同的方式处理重新传递，例如将其发送到 DLQ。有关更多详细信息，请参阅其他问题中的评论。

于 2020-06-17T17:38:58.383 回答