Apache camel onException向原始消息添加错误详细信息

Question

我已将此异常处理添加到camel路由。

 .onException(BeanCreationException.class, ValidationException.class)
     .handled(true)
     .process(new OnExceptionProcessor())
     .to("errorQueue0").id("errorQueue")
     .end()

public class OnExceptionProcessor implements Processor {
    @Override
    public void process(Exchange exchange) throws Exception {
        Exception cause = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, Exception.class);
        exchange.getIn().setHeader("FailedBecause", cause.getMessage());
    }
}

当我从错误队列中读回此消息时，找不到此标头。您知道如何将错误详细信息与原始消息一起添加到错误队列吗

Answer 1

这可能是上下文问题，因为您所在的处理器由错误处理程序调用。

或者，可以从处理器方法返回要在标头中设置的字符串值。顺便说一下，这也提高了处理器的可测试性。

然后可以使用此返回值直接在错误处理程序路由中设置标头。

.setHeader("FailedBecause", method(new OnExceptionProcessor()))