如何在骆驼路线中提交MQ事务？

Question

有一条骆驼路线，它被处理，异常由TransactionError Handler处理。代码如下所示：

...
<bean
    id="errorHandler"
    class="org.apache.camel.spring.spi.TransactionErrorHandlerBuilder">
</bean>
...
<camelContext errorHandlerRef="errorHandler">
    ...
    <onException>
        <exception>java.lang.Exception</exception>
        <handled>
            <constant>true</constant>
        </handled>
        <!-- do some exception handling -->
    </onException>

    <route>
        <from uri="mq:queue://QMgr/Q?exchangePattern=InOut" />
        <transacted />
        <!-- some routing that throws an Exception -->
    </route>
</camelContext>

它是有效的，并且在错误被处理后，事务有一个提交：事务提交（0xFab75a3a）重新传递（true）for…，但是然后消息再次被放入输入队列中，事务从头开始（无尽循环）。

我们正在使用IBM MQ，我认为这种回滚是由MQ执行的，而不是从camel路线执行的。所以问题是:我能告诉MQ我处理了异常，并且它不应该再次回滚吗？

Answer 1

IBM MQ 正在通过设计将消息重新发送给消费者。要让代理在 X 次尝试后停止，请为 IBM MQ 配置“撤销阈值”和“中断队列”，以便在传递尝试失败后将消息移开。