Details
-
Type:
Improvement
-
Status: Resolved
-
Priority:
Major
-
Resolution: Fixed
-
Affects Version/s: 2.18.3
-
Fix Version/s: 2.20.0
-
Component/s: camel-core
-
Labels:None
-
Estimated Complexity:Unknown
Description
The aggregated exchange doesn't become complete after a completionTimeout which is lower than 1000ms (e.g. 150ms)
From source code, seems that there is no way to set a value for AggregationTimeoutMap from AggregateProcessor class:
{{ // check for timed out aggregated messages once every second
timeoutMap = new AggregationTimeoutMap(getTimeoutCheckerExecutorService(), 1000L);}}
because it's hardcoded to 1s.
A new option like timeoutCheckerExecutorInterval with default value of 1000ms will solve the problem.