This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 2ec95e695afa CAMEL-25234: Fix flaky JmsComponentIbmMQTest by extending
IBM MQ container startup timeout (#27597)
2ec95e695afa is described below
commit 2ec95e695afa411e544511ed30c7998f3292ab17
Author: Guillaume Nodet <[email protected]>
AuthorDate: Tue Oct 13 13:32:05 2026 +0200
CAMEL-25234: Fix flaky JmsComponentIbmMQTest by extending IBM MQ container
startup timeout (#27597)
---
.../infra/ibmmq/services/IbmMQLocalContainerInfraService.java | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
diff --git
a/test-infra/camel-test-infra-ibmmq/src/main/java/org/apache/camel/test/infra/ibmmq/services/IbmMQLocalContainerInfraService.java
b/test-infra/camel-test-infra-ibmmq/src/main/java/org/apache/camel/test/infra/ibmmq/services/IbmMQLocalContainerInfraService.java
index 25eb678e9ed5..c189a305ac9a 100644
---
a/test-infra/camel-test-infra-ibmmq/src/main/java/org/apache/camel/test/infra/ibmmq/services/IbmMQLocalContainerInfraService.java
+++
b/test-infra/camel-test-infra-ibmmq/src/main/java/org/apache/camel/test/infra/ibmmq/services/IbmMQLocalContainerInfraService.java
@@ -16,6 +16,7 @@
*/
package org.apache.camel.test.infra.ibmmq.services;
+import java.time.Duration;
import java.util.concurrent.TimeUnit;
import jakarta.jms.Connection;
@@ -74,10 +75,14 @@ public class IbmMQLocalContainerInfraService implements
IbmMQInfraService, Conta
// AND the listener-port and log-message checks; a
plain chained waitingFor() would replace,
// not combine, the strategies.
WITH_INDIVIDUAL_TIMEOUTS_ONLY keeps each strategy's own timeout
// instead of the 30s outer cap the default
WaitAllStrategy mode would impose.
+ // Note: withStartupTimeout() must be called on each
strategy individually when using
+ // WITH_INDIVIDUAL_TIMEOUTS_ONLY mode; calling it on
the WaitAllStrategy itself would
+ // throw an IllegalStateException.
.waitingFor(new
WaitAllStrategy(WaitAllStrategy.Mode.WITH_INDIVIDUAL_TIMEOUTS_ONLY)
- .withStrategy(Wait.forListeningPort())
+
.withStrategy(Wait.forListeningPort().withStartupTimeout(Duration.ofMinutes(3L)))
.withStrategy(Wait.forLogMessage(
- ".*Queued Publish/Subscribe Daemon
started for queue manager.*", 1)));
+ ".*Queued Publish/Subscribe Daemon
started for queue manager.*", 1)
+
.withStartupTimeout(Duration.ofMinutes(3L))));
ContainerEnvironmentUtil.configurePorts(this,
ContainerEnvironmentUtil.isFixedPort(IbmMQLocalContainerInfraService.class),
