Details
-
New Feature
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
2.13.0
-
None
-
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.