atiaomar1978-hub opened a new pull request, #25333: URL: https://github.com/apache/camel/pull/25333
## Summary Fixes [CAMEL-24024](https://issues.apache.org/jira/browse/CAMEL-24024): `InOutQueueProducerAsyncLoadTest` is flaky in CI under load. The core fix (500 messages, `CountDownLatch`, `AtomicInteger` failure tracking) was merged as [CAMEL-24027](https://issues.apache.org/jira/browse/CAMEL-24027) in #24626. This PR addresses remaining flake sources: - **Inflight race:** poll with Awaitility until `context.getInflightRepository().size()` is 0 instead of asserting immediately after executor shutdown - **JMS listener thread:** replace `fail()` in `onMessage` with `AtomicInteger` error tracking (JUnit `fail()` from a JMS callback thread is unreliable) - **Executor lifecycle:** wrap submission/wait in `try/finally` so shutdown always runs - **Null-safe cleanup:** guard `MessageProducer.close()` when no message was processed - Drop unnecessary `public` modifiers per JUnit 5 conventions ## Test plan - [x] `./mvnw -pl components/camel-sjms -am test -Dtest=InOutQueueProducerAsyncLoadTest` --- _AI-generated PR description on behalf of atiaomar1978-hub_ -- 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]
