Apache Camel聚合路由异常

Question

我想对3条路由使用Apache Camel并行组播，聚合（并等待）其中的2条路由，而让第3条路由自行进行（第3条路由不应阻塞前两条路由）。我还需要在“所有”情况下处理这两个，这意味着如果其中一个失败（例如在处理过程中抛出异常），也应该对其进行聚合。

根据我从Camel文档中了解到的情况，只要不指定StoponException，该行为就应该是“默认的”。但发生的情况是exchange异常永远不会到达我的AggregationStrategy。奇怪的是，即使存在completionSize(2)时，聚合后面的处理器也会被执行。

CamelContext context = new DefaultCamelContext();
RouteBuilder builder = new RouteBuilder() {
    @Override
    public void configure() throws Exception {
    }
};

builder.onException(MyException.class)
        .process(new PropertySetterProcessor("a", "onException"))
        .handled(true);

builder.from("direct:input")
        .process(new PropertySetterProcessor("a", "before-multicast"))
        .multicast()
        .parallelProcessing()
        .shareUnitOfWork()
        .to("direct:part1", "direct:part2", "direct:part3")

builder.from("direct:part1")
        .process(new PropertySetterProcessor("a", "part1"))
        .to("direct:sync");

builder.from("direct:part2")
        .process(new PropertySetterProcessor("a", "part2"))
        .process(new ExceptionThrowingProcessor("oops")) // throws MyException
        .to("direct:sync");

builder.from("direct:part3")
        .process(new PropertySetterProcessor("a", "part3"));
// don't want this to be aggregated within direct:sync

builder.from("direct:sync")
        .aggregate(new TestAggregationStrategy())
        // strategy.aggregate is called only once (from part1) but not from part2 :(
        .constant(true)
        .completionSize(2)
        .process(new PropertySetterProcessor("a", "after-aggregation"));

context.addRoutes(builder);
context.start();

ProducerTemplate template = context.createProducerTemplate();
template.send("direct:input", new DefaultExchange(context, ExchangePattern.InOut));

Answer 1

在onException块上将handled（true）替换为continue（true）。有关更多信息，请参见http://camel.apache.org/exception-clause.html