[camel-quarkus] branch main updated: paho-mqtt5 test failing with Error: Unable to create websockets listener on port 9001 #3860 (#3861)

[zhfeng]

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();