gnodet opened a new pull request, #23235:
URL: https://github.com/apache/camel/pull/23235

   [CAMEL-23513](https://issues.apache.org/jira/browse/CAMEL-23513)
   
   ## Summary
   
   - Fix `completeAllOnStop()` not reliably completing in-flight aggregations 
when used with `completionInterval()`
   - `AggregateProcessor.prepareShutdown()` now also force-completes all groups 
when `completeAllOnStop` is set, not just when `forceCompletionOnStop` is set
   - Update the test to use a 60-second interval (instead of 1 second) so it 
deterministically validates force completion rather than relying on the 
interval timer to race against shutdown
   
   ## Root Cause
   
   `prepareShutdown()` only checked `forceCompletionOnStop` to trigger 
`doForceCompletionOnStop()`. With `completeAllOnStop`, the shutdown relied on 
the `AggregationIntervalTask` firing during the shutdown window — a race 
condition that caused intermittent failures.
   
   ## Test plan
   
   - [x] `AggregateCompleteAllOnStopWithIntervalTest` passes deterministically 
(20/20 runs)
   - [x] Full aggregator test suite (`org.apache.camel.processor.aggregator.*`) 
passes with no regressions


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to