1. 添加onException处理程序

首先，需要在Camel路由的起点添加onException处理程序，以处理从该路由中传递的异常。例如：

from("direct:start")
    .onException(Exception.class)
      .handled(true)
      .to("direct:errorHandler")
    .end()
    .to("mock:result");

在这个示例中，我们使用onException处理程序来处理所有类型的异常，并将它们重定向到名为“errorHandler”的直接路由。

2.定义errorHandler处理程序

接下来，我们需要定义一个名为“errorHandler”的处理程序，用于根据需要自定义处理异常。在这个示例中，我们只是输出异常的消息，但您可以根据需要执行其他操作。例如：

from("direct:errorHandler")
    .log(LoggingLevel.ERROR, "Exception Occurred: ${exception.message}")
    .to("mock:errorResult");

在这个示例中，我们使用Camel log记录器记录异常消息，并将异常消息转发到名为“errorResult”的模拟路由。请注意，使用onException处理程序捕获的异常不会流向最终的消费者端点，在这种情况下，它会流向自定义的错误处理程序。

3. 测试代码

接下来，我们可以编写一些测试代码来测试我们的自定义异常处理程序是否工作。例如：

@Test
public void testCustomErrorHandler() throws Exception {
    String message = "Test message";
    Exchange exchange = createExchangeWithException(message, new IllegalArgumentException("Invalid argument"));
    template.send("direct:start", exchange);
    assertMockEndpointsSatisfied();
    Assert.assertEquals("Exception Occurred: Invalid argument", getMockEndpoint("mock:errorResult").getExchanges().get(0).getIn().getBody());
}

private Exchange createExchangeWithException(String message, Exception e) {
    Exchange exchange = new DefaultExchange(context);
    Message in = exchange.getIn();
    in.setBody(message);
    exchange.setException(e);
    return exchange;
}

在这个示