[CAMEL-11515] Aggregator is not working correctly when completionTimeout < 1000ms

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.18.3
• Fix Version/s: 2.20.0
• Component/s: camel-core
• Estimated Complexity: Unknown
• Assignee: Claus Ibsen
• Reporter: Denis Chirov
• Created: 05/Jul/17 18:42
• Updated: 05/Jul/17 19:29
• Resolved: 05/Jul/17 19:26

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.