Disable Iggy tests on CI

Author: Croway

components/camel-iggy/src/test/java/org/apache/camel/component/iggy/IggyComponentIT.java

@@ -20,7 +20,10 @@
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.component.mock.MockEndpoint;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.condition.DisabledIfSystemProperty;
 
+@DisabledIfSystemProperty(named = "ci.env.name", matches = ".*",
+                          disabledReason = "Iggy 0.6.0+ requires io_uring which is not available on CI environments")
 public class IggyComponentIT extends IggyTestBase {
 
     @Test

components/camel-iggy/src/test/java/org/apache/camel/component/iggy/IggyConsumerIT.java

@@ -23,7 +23,10 @@
 import org.apache.camel.component.mock.MockEndpoint;
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.condition.DisabledIfSystemProperty;
 
+@DisabledIfSystemProperty(named = "ci.env.name", matches = ".*",
+                          disabledReason = "Iggy 0.6.0+ requires io_uring which is not available on CI environments")
 public class IggyConsumerIT extends IggyTestBase {
 
     @Test

components/camel-iggy/src/test/java/org/apache/camel/component/iggy/IggyConsumerOffsetIT.java

@@ -20,7 +20,10 @@
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.component.mock.MockEndpoint;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.condition.DisabledIfSystemProperty;
 
+@DisabledIfSystemProperty(named = "ci.env.name", matches = ".*",
+                          disabledReason = "Iggy 0.6.0+ requires io_uring which is not available on CI environments")
 public class IggyConsumerOffsetIT extends IggyTestBase {
 
     int startingOffset = 5;

components/camel-iggy/src/test/java/org/apache/camel/component/iggy/IggyProducerIT.java

@@ -25,7 +25,10 @@
 import org.apache.iggy.message.Message;
 import org.assertj.core.api.Assertions;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.condition.DisabledIfSystemProperty;
 
+@DisabledIfSystemProperty(named = "ci.env.name", matches = ".*",
+                          disabledReason = "Iggy 0.6.0+ requires io_uring which is not available on CI environments")
 public class IggyProducerIT extends IggyTestBase {
 
     @Test

components/camel-iggy/src/test/java/org/apache/camel/component/iggy/IggyTestBase.java

@@ -16,11 +16,6 @@
  */
 package org.apache.camel.component.iggy;
 
-import java.util.Collections;
-import java.util.List;
-import java.util.Optional;
-import java.util.stream.Stream;
-
 import org.apache.camel.CamelContext;
 import org.apache.camel.RoutesBuilder;
 import org.apache.camel.test.infra.core.CamelContextExtension;
@@ -39,13 +34,13 @@
 import org.apache.iggy.message.PollingStrategy;
 import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.Order;
-import org.junit.jupiter.api.condition.DisabledIfSystemProperty;
 import org.junit.jupiter.api.extension.RegisterExtension;
 
-import static java.util.Optional.empty;
+import java.util.Collections;
+import java.util.List;
+import java.util.Optional;
+import java.util.stream.Stream;
 
-@DisabledIfSystemProperty(named = "ci.env.name", matches = ".*",
-                          disabledReason = "Iggy 0.6.0+ requires io_uring which is not available on CI environments")
 public abstract class IggyTestBase {
 
     @Order(1)

test-infra/camel-test-infra-iggy/src/main/java/org/apache/camel/test/infra/iggy/services/IggyContainer.java

@@ -17,6 +17,9 @@
 
 package org.apache.camel.test.infra.iggy.services;
 
+import java.util.List;
+
+import com.github.dockerjava.api.model.Ulimit;
 import org.apache.camel.test.infra.iggy.common.IggyProperties;
 import org.testcontainers.containers.GenericContainer;
 import org.testcontainers.containers.wait.strategy.Wait;
@@ -44,7 +47,8 @@ public TestInfraIggyContainer() {
                 withCreateContainerCmdModifier(cmd -> {
                     cmd.getHostConfig()
                             .withCapAdd(com.github.dockerjava.api.model.Capability.SYS_NICE)
-                            .withSecurityOpts(java.util.List.of("seccomp:unconfined"));
+                            .withSecurityOpts(java.util.List.of("seccomp:unconfined"))
+                            .withUlimits(List.of(new Ulimit("memlock", -1, -1)));
                 });
 
                 if (fixedPort) {