当camel拆分中发生异常时，如何获取groupedExchange？

Question

我在我的骆驼分裂（）路线中有一个聚合策略。

from("direct:split")
    .split()
        .method(new SplitBean(), "splitMessage")
        .aggregationStrategy(AggregationStrategies.groupedExchange())
        .stopOnException()
    .to("direct:destination")
    .end();

splitMessage方法已将数据拆分为3个请求数据。因此，我将点击http目标endpoint3次。

使用聚合策略，我的http响应在前2次被聚合。

第三次http调用因异常而失败。返回给调用者的交换不包含前两个分组交换。

在这种情况下，我如何获得分组交换（成功，异常）。

如果问题不清楚，请告诉我。

Answer 1

>

从. ostOnException（）更改为. ostOnAggregate Exception（）

创建一个AggregationStrategy策略类，并从那里处理异常

public void configure（）引发异常{

     from("direct:split")             
             .split()
             .method(new SplitBean(), "splitMessage")
             .aggregationStrategy(new ErrorStrategy())
             .stopOnAggregateException()
             .to("direct:destination")
             .end();

 }

 public class ErrorStrategy  implements CompletionAwareAggregationStrategy {
         @Override
     public void onCompletion(Exchange exchange) {

     }

     @Override
     public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
         if (newExchange.getException() != null) {
             return oldExchange;
         }

         if (oldExchange == null) {
         ....
         return newExchange;
         }
   .....
     return oldExchange;
     }
     }