Apache Camel onException

Question

我想从路线中捕捉所有异常.

我添加了这个OnExeption:

onException(Exception.class).process(new MyFunctionFailureHandler()).stop();

然后,我创建了类MyFunctionFailureHandler.

public class MyFunctionFailureHandler  implements Processor {

@Override
public void process(Exchange exchange) throws Exception {
    Throwable caused;

    caused = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, Throwable.class);

    exchange.getContext().createProducerTemplate().send("mock:myerror", exchange);
   }

}

不幸的是,它不起作用,我不知道为什么.

如果有异常,程序必须停止.

我怎么知道为什么这段代码不起作用!!

谢谢.

Answer 1

我在我的路线上使用了这个：

public class MyCamelRoute extends RouteBuilder {

   @Override
   public void configure() throws Exception {

        from("jms:start")
           .process(testExcpProcessor)

       // -- Handle Exceptions
       .onException(Exception.class)
         .process(errorProcessor)
         .handled(true)

       .to("jms:start");
   }
}

在我的错误处理器中

public class ErrorProcessor implements Processor {

  @Override
  public void process(Exchange exchange) throws Exception {


    Exception cause = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, Exception.class);

    if(cause != null){
        log.error("Error has occurred: ", cause);

        // Sending Error message to client
        exchange.getOut().setBody("Error");
    }else

        // Sending response message to client
        exchange.getOut().setBody("Good");
  }
}

我希望它有帮助

Answer 2

请记住，如果您在多个 RouteBuilder 类中有路由，则此路由中的 onExcpetion 将仅影响此 RouteBuilder 下的所有路由

查看这个答案

另外，如果异常发生在路由内并在该路由内处理，它不会传播到原始调用者路由，您需要使用 noErrorHandler() 即将from(direct:start).errorHandler(noErrorHandler())异常处理传播回调用者