apupier opened a new pull request, #29305: URL: https://github.com/apache/camel/pull/29305
## Description Fixes the flaky `DisruptorMultipleConsumersOnCompletionTest` (`testFailureThenSuccess` and `testBothFail` failed with `mock://slow Received message count. Expected: <1> but was: <0>`). ### Cause With `multipleConsumers=true`, each consumer copies the original exchange when it starts. The consumer that fails copies its result back to the original exchange, so a consumer that started late could copy the exception of the other consumer and fail at once, before it reached `mock:slow`. ### Fix Test-only change: both consumer routes now wait (with a `CountDownLatch(2)`) until both consumers have copied the exchange before processing it. No production code change and no `Thread.sleep()`. ### Testing `mvn test -Dtest=DisruptorMultipleConsumersOnCompletionTest` in `components/camel-disruptor`, run several times in a row without failure. --- _Bob (IBM Bob 2.2.1) on behalf of apupier_ - AI-generated content. -- 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]
