This is an automated email from the ASF dual-hosted git repository.

ppalaga 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 a8638f6e57 Set explicit nofile ulimit for activemq-artemis-broker 
image to make it work also on system with low default nofile ulimit
a8638f6e57 is described below

commit a8638f6e5735b844984070846d25a1bb1979a021
Author: Peter Palaga <ppal...@redhat.com>
AuthorDate: Fri Sep 30 13:55:20 2022 +0200

    Set explicit nofile ulimit for activemq-artemis-broker image to make it 
work also on system with low default nofile ulimit
---
 .../camel/quarkus/test/support/activemq/ActiveMQTestResource.java    | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/integration-tests-support/activemq/src/main/java/org/apache/camel/quarkus/test/support/activemq/ActiveMQTestResource.java
 
b/integration-tests-support/activemq/src/main/java/org/apache/camel/quarkus/test/support/activemq/ActiveMQTestResource.java
index b729d78b21..780099f589 100644
--- 
a/integration-tests-support/activemq/src/main/java/org/apache/camel/quarkus/test/support/activemq/ActiveMQTestResource.java
+++ 
b/integration-tests-support/activemq/src/main/java/org/apache/camel/quarkus/test/support/activemq/ActiveMQTestResource.java
@@ -20,6 +20,7 @@ import java.util.Arrays;
 import java.util.LinkedHashMap;
 import java.util.Map;
 
+import com.github.dockerjava.api.model.Ulimit;
 import io.quarkus.test.common.QuarkusTestResourceLifecycleManager;
 import org.testcontainers.containers.GenericContainer;
 import org.testcontainers.containers.wait.strategy.Wait;
@@ -53,7 +54,9 @@ public class ActiveMQTestResource implements 
QuarkusTestResourceLifecycleManager
                 .withLogConsumer(frame -> 
System.out.print(frame.getUtf8String()))
                 .withEnv("AMQ_USER", ACTIVEMQ_USERNAME)
                 .withEnv("AMQ_PASSWORD", ACTIVEMQ_PASSWORD)
-                .waitingFor(Wait.forLogMessage(".*AMQ241001.*", 1));
+                .waitingFor(Wait.forLogMessage(".*AMQ241001.*", 1))
+                .withCreateContainerCmdModifier(
+                        cmd -> cmd.getHostConfig().withUlimits(new Ulimit[] { 
new Ulimit("nofile", 2048L, 2048L) }));
 
         container.start();
 

Reply via email to