将exchange标记为基于表达式的已处理的事务Camel路由不起作用

Question

package com.my.comp.playground;

import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.builder.RouteBuilder;
import org.springframework.stereotype.Component;

@Component
public class MyRouteBuilder extends RouteBuilder {
    @Override
    public void configure() {
        onException(Exception.class)
                .process(new Processor() {
                    private int failureCounter = 0;
                    @Override
                    public void process(Exchange exchange) {
                        exchange.getIn().setHeader("failureCounter", ++failureCounter);
                    }
                })
                .log("failureCounter = ${header.failureCounter}")
                //.handled(true);
                .handled(header("failureCounter").isGreaterThan(3));

        from("jms:test.queue")
                .routeId("test-route")
                .transacted()
                .process(exchange -> {
                    throw new RuntimeException("No good Pal!");
                })
                .to("mock:discard");
    }
}

因此，我试图做的是保留一个失败的计数器，如果该计数器大于某个数字，则将异常标记为已处理并提交事务。

注意异常处理结尾的两行代码：

 //.handled(true);
 .handled(header("failureCounter").isGreaterThan(3));

当我使用标头（“failureCounter”）.isgreaterthan(3)处理的条件运行路由时，消息会一次又一次地永远回滚，我可以在日志中看到failureCounter正确地增加：

...
[mer[test.queue]] test-route                               : failureCounter = 402
[mer[test.queue]] o.a.c.p.e.DefaultErrorHandler            : Failed delivery for (MessageId: ...
...
[mer[test.queue]] test-route                               : failureCounter = 403
...
[mer[test.queue]] test-route                               : failureCounter = 404
...

[mer[test.queue]] test-route                               : failureCounter = 1
[mer[test.queue]] o.a.c.s.spi.TransactionErrorHandler      : Transaction commit (0x52b2f795) redelivered(true)

所以我的问题是：是我做错了什么，还是我对如何使用handled异常的理解不正确？如果是这样，正确的方法是什么？

Answer 1

我不知道这是设计还是一个bug。

当我调试您的案例时，我看到handled()中的谓词是根据Camel Exchange计算的。

但是，FailureCounter标头不在Exchange中。因此，表达式标头（“failurecounter”）的计算结果为null，谓词始终为false。