Apache camel-句柄和重试异常

Question

我正在使用JavaDSL来配置路由。我有一个类似于下面给出的路由。

    RouteBuilder builder = new RouteBuilder() {
        public void configure() {
           // onException(Exception.class).bean("bean");

            onException(Exception.class).to("anotherProcessor");

            from("queue:a").bean("someBean").to("processor");
        }
    };

在做了一些活动后，我该如何处理异常？在异常时，我尝试配置处理器和bean来重新引发异常。不管怎样，camel都在将异常设置为exchange，但没有破坏异常。

我在junit测试用例中这样做。我正在使用OneException处理器处理异常。在处理器内部，我正在进行断言。断言错误由camel自动处理，测试不会被标记为通过/失败。

Answer 1

from(CONSUMER)
    .doTry()
    .doCatch(SocketTimeoutException.class,Exception.class)
            .beanRef("ErrorProcessor","processErrorMessage")
            .to("freemarker:ErrorResponseTransformer.ftl")
    .end()
    .to(PRODUCER)

尝试捕捉

onException(Exception.class)
        .handled(true)
        .process(new Processor() {
            public void process(Exchange e) throws Exception {
                helper.processErrorMessage(e);
                log.info("Response error: "
                        + MessageHelper.extractBodyAsString(e.getIn()));
                log.info("Response error: "
                        + MessageHelper.extractBodyAsString(e.getOut()));
            }
        });

on Exception处理异常并将其作为响应错误消息处理以显示。你甚至可以放一个。至（ERRORDESTINATION）或窃听以继续正常流量。

或者使用camel的errorHandler。

希望这有帮助。