This is an automated email from the ASF dual-hosted git repository. zhfeng pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
The following commit(s) were added to refs/heads/main by this push: new 470cb4c80c paho-mqtt5 test failing with Error: Unable to create websockets listener on port 9001 #3860 (#3861) 470cb4c80c is described below commit 470cb4c80c40be8f7f69719a563782af4adb8ff1 Author: Peter Palaga <ppal...@redhat.com> AuthorDate: Tue Jun 21 02:06:30 2022 +0200 paho-mqtt5 test failing with Error: Unable to create websockets listener on port 9001 #3860 (#3861) --- .../quarkus/component/paho/mqtt5/it/PahoMqtt5TestResource.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/integration-tests/paho-mqtt5/src/test/java/org/apache/camel/quarkus/component/paho/mqtt5/it/PahoMqtt5TestResource.java b/integration-tests/paho-mqtt5/src/test/java/org/apache/camel/quarkus/component/paho/mqtt5/it/PahoMqtt5TestResource.java index 59581c7815..d6d17d2d2c 100644 --- a/integration-tests/paho-mqtt5/src/test/java/org/apache/camel/quarkus/component/paho/mqtt5/it/PahoMqtt5TestResource.java +++ b/integration-tests/paho-mqtt5/src/test/java/org/apache/camel/quarkus/component/paho/mqtt5/it/PahoMqtt5TestResource.java @@ -19,6 +19,7 @@ package org.apache.camel.quarkus.component.paho.mqtt5.it; import java.util.HashMap; import java.util.Map; +import com.github.dockerjava.api.model.Ulimit; import io.quarkus.test.common.QuarkusTestResourceLifecycleManager; import org.apache.camel.quarkus.test.AvailablePortFinder; import org.apache.camel.util.CollectionHelper; @@ -89,8 +90,9 @@ public class PahoMqtt5TestResource implements QuarkusTestResourceLifecycleManage } container.withLogConsumer(new Slf4jLogConsumer(LOGGER)) - .waitingFor(Wait.forLogMessage(".* mosquitto version .* running", 1)) - .waitingFor(Wait.forListeningPort()); + .waitingFor(Wait.forLogMessage(".* mosquitto version .* running.*", 1)) + .withCreateContainerCmdModifier( + cmd -> cmd.getHostConfig().withUlimits(new Ulimit[] { new Ulimit("nofile", 512L, 512L) })); if (startContainer) { container.start();