Details
-
Type:
New Feature
-
Status: Resolved
-
Priority:
Major
-
Resolution: Fixed
-
Affects Version/s: 2.13.0
-
Fix Version/s: 2.16.0
-
Component/s: camel-core, eip
-
Labels:None
-
Estimated Complexity:Unknown
Description
There is a way to do this by creating a "trigger" exchange that is handled in a special way by the aggregation strategy and a completion predicate. But this solution is quite intrusive and painful to write.
It would actually be much easier if the AggregateProcessor would implement and expose the following methods:
public void forceCompletionOfGroup(String key)
public Expression getCorrelationExpression()
This way, it becomes possible to control "externally" an aggregator without having to implement some intrusive logic.