You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by zh...@apache.org on 2022/06/21 00:06:35 UTC
[camel-quarkus] branch main updated: paho-mqtt5 test failing with Error: Unable to create websockets listener on port 9001 #3860 (#3861)
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 <pp...@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();