[CAMEL-12318] Exception from aggregate() of AggregationStrategy has been hiden since Camel 2.16.x

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Implemented
• Affects Version/s: 2.16.5, 2.17.7, 2.18.5
• Fix Version/s: 2.21.0
• Component/s: camel-core

Environment

Java 8

• Estimated Complexity: Unknown
• Assignee: Claus Ibsen
• Reporter: Xilai Dai
• Created: 05/Mar/18 04:17
• Updated: 12/Mar/18 03:29
• Resolved: 09/Mar/18 17:49

Description

In case of any exception thrown from aggregate() of the custom AggregationStrategy class, the exception is hiden by Camel core and couldn't be catched by any errorhandler.

A simple use case project is created for easy reproduce this issue, https://github.com/xldai/test/tree/master/test-multicast

With setting camel.ver to 2.15.x in the pom.xml, the Exception is thrown as expected:

Caused by: java.lang.RuntimeException: Deliberate Exception
        at beans.FD_MulticastAggregator.aggregate(FD_MulticastAggregator.java:16)
        at org.apache.camel.processor.MulticastProcessor.doAggregateInternal(MulticastProcessor.java:848)
        at org.apache.camel.processor.MulticastProcessor.doAggregate(MulticastProcessor.java:830)
        at org.apache.camel.processor.MulticastProcessor$AggregateOnTheFlyTask.aggregateOnTheFly(MulticastProcessor.java:489)
        at org.apache.camel.processor.MulticastProcessor$AggregateOnTheFlyTask.run(MulticastProcessor.java:394)

With setting camel.ver to higher than 2.16.x in the pom.xml, the Exception is not exposed anymore.

Looking into the commit changes, seems this is happening after the changes of CAMEL-8587.