You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2026/10/13 11:32:13 UTC
(camel) branch main updated: CAMEL-25234: Fix flaky JmsComponentIbmMQTest by extending IBM MQ container startup timeout (#27597)
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 <gn...@gmail.com>
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),