java - Camel 没有捕捉到异常

Question

.from("seda:rest_upload")
                .process(new Processor() {
                    @Override
                    public void process(Exchange exchange) {
                        if(true){
                            throw new RuntimeException();
                        }})
                .to("seda:parsed_csv")
                .onException(Exception.class).process(new Processor() {
            @Override
            public void process(Exchange exchange) throws Exception {
                logger.warn("Error");
            }
        });

但是 logger.warn("Error"); 没有被调用。

我做错了什么？

如何为 Camel 路线注册全局异常处理程序？

Answer 1

在路由顶部移动 onException block ，不要忘记 end() 终止符。

end() 告诉 Camel onException block 在哪里结束。如果你忽略它，Camel 会将其视为一个 onException block 。只是会有路由从 seda 消耗并且没有输出处理器，因为 onException() 之后的所有内容都会成为 onException block 的一部分。

---

特定于路由的异常处理:处理路由 seda:rest_upload

中发生的异常

from("seda:rest_upload")
    .onException(Exception.class).process(exchange -> logger.warn("Error")).end()
    .process(e -> {throw new RuntimeException();})
    .to("seda:parsed_csv");

from("seda:parsed_csv").to("log:parsed_csv");

from("timer:tmr?period=1000")
    .setBody(constant("mock"))
    .to("seda:rest_upload");

---

全局异常处理:处理当前RouteBuilder中所有路由的异常

onException(Exception.class).process(exchange -> logger.warn("Error")); //There is no need for end(), whole block is part of onException block

from("seda:rest_upload")
    .process(e -> {throw new RuntimeException();})
    .to("seda:parsed_csv");

from("seda:parsed_csv").to("log:parsed_csv");

from("timer:tmr?period=1000")
    .setBody(constant("mock"))
    .to("seda:rest_upload");