如何在重新传递时忽略Camel中的一个异常

Question

我必须实现一个错误处理程序，它在发送SOAP请求并处理其响应的业务流程上使用Camel重新交付策略。在process部分期间，可以抛出一个特殊的异常（RetryException）。这个异常是在错误处理程序级别捕获的（多亏了onException（RetryException.Class））。这是最简单的部分。

现在，我想忽略cxfendpoint可能抛出的异常（在每个示例出现连接错误的情况下），并处理它们。所以我试着：

• （1）一条具有带有重试策略的onException子句的主路由
• (2)一个子路由，它聚合了2条路由（并具有noErrorHandler)，以确保重播这2条路由，而不仅仅是抛出异常的处理路由：
  • (3)发送SOAP请求的路由
  • （4）处理响应并可抛出RetryException的路由。

  为了忽略cxfendpoint抛出的异常，我实现了如下路由（3）：

  public void configure() {
      from(ROUTE_NAME).
      .handleFault() // To handle Soap fault
      .onException(Fault.class)
          .continued(true)
          .end()
      .to("cxf:[...]")
      ;
  }
  

  它的工作方式很好，响应处理器在抛出RetryException之前执行一些检查...但是继续的指令丢弃了我以前所拥有的所有关于重传的信息，Camel认为这个例外是第一个。因此路由进入一种永远重试循环。

  Headers: {breadcrumbId=ID-ITEM-S28636-63117-1469800853403-0-1, CamelRedelivered=true, CamelRedeliveryCounter=1, CamelRedeliveryMaxCounter=2, operationName=[...]}
  

  在onException（Fault）之后交换标头：

  Headers: {breadcrumbId=ID-ITEM-S28636-63117-1469800853403-0-1, operationName=[...]}
  

  您是否有任何解决方案来忽略某些子路由异常而不擦除上路由重试策略？

Answer 1

我猜您是通过directendpoint连接路由的；如果是这种情况，我认为您的主要问题是您将fault标记为continued（表示已处理），这很可能是导致您的重发报头被清除的原因。您可以尝试使用seda或消息队列，但不要使用directendpoint，因为它基本上将您的路由链接到一个endpoint。