Apache Camel拆分和聚合异常处理

Question

我们在Camel中定义了一个具有拆分和聚合功能的路由，但无法在聚合器之后将异常传播回拆分。这导致即使我们遇到异常，拆分也会运行

下面是不工作的代码

from("direct:MyRoute")
     .routeId("MyRouteID")
        .split().tokenize("\n", 1)
        .streaming().stopOnException()
        .choice()
        .when(simple("${property.CamelSplitIndex} > 0"))
           .unmarshal(domainDataFormat)
           .choice()
           .when(simple("${property.CamelSplitComplete}"))
           .process(
              new Processor()
              {
                 @Override
                 public void process(Exchange exchange) throws Exception
                 {
                    exchange.getIn().getHeaders().put(Exchange.AGGREGATION_COMPLETE_ALL_GROUPS_INCLUSIVE, true);
                 }
              }
           )
           .end()
           .aggregate(myAggregationStrategy).constant(true) //if i comment this line split will be stop on exception
           .threads().executorService(executorService)
           .process(myProcessor).end()
     .end();

上述代码中的处理器（myProcessor）如下：

counter.incrementAndGet(); //atomic counter 
if(counter.get()==3)
  {
     exchange.setException(new RuntimeException());
     throw new RuntimeCamelException();
  }

但是，当我从路由中移除聚合时，Split能够在异常情况下停止路由。

Answer 1

使用复合消息处理器EIP，它是在同一工作单元中拆分聚合（分叉/连接）。

参见文档：http://camel.apache.org/composed-message-processor.html

请参阅“仅拆分器”部分，在该部分中，您可以为拆分器指定聚合策略，使其协同工作。