如何使用OnException在Apache Camel中正确处理异常

Question

我将我的jms队列更改为JMS1。然而，当我执行代码时，我得到一个异常。

我的期望是，每当我得到异常时，我的bean类都应该被调用，但事实并非如此。

runtimeCamelException：org.apache.camel.FailedToCreateRouteException：在以下位置创建路由route1失败：>>>到[jms1:queue:finalqSource]<<<在route:route[[from[jms:queue:testqSource]]->[onException[[class J...因为解析终结点:jms1://queue:finalqSource失败，原因是：找不到Scheme:jms1的组件

<camelContext id="jmsContext" html" target="_blank">xmlns="http://camel.apache.org/schema/spring">   
  <onException>
  <exception>org.apache.camel.RuntimeCamelException</exception>
  <exception>org.apache.camel.ResolveEndpointFailedException</exception>
    <!-- <handled><constant>true</constant></handled> -->           
      <bean ref="exceptionListener" method="orderFailed" />
  </onException>
  <route>
    <from uri="jms:queue:testQSource" />
    <to uri="jms1:queue:FinalQSource" /><!--
  </route>
</camelContext>

Answer 1

这将不起作用，因为当camel试图解析您的路由时，它会抛出异常。onException块将只捕获在路由执行期间引发的异常。

要测试异常处理，请使用适当的camel测试指南-http://camel.apache.org/testing.html

我建议模拟您的一个endpoint以返回异常，这里的示例是https://github.com/christian-posta/camel-sandbox/blob/master/one-off/src/test/java/posta/testmockexceptions.java

MockEndpoint mockException = MockEndpoint.resolve(context, "mock:exception");
    mockException.whenAnyExchangeReceived(new Processor() {
        @Override
        public void process(Exchange exchange) throws Exception {
            System.out.println("i got here...");
            throw new RuntimeException("fail!");
        }
});