[camel-kafka-connector] 10/10: Avoid spawning Jetty servers too quickly as they seem to cause GH actions to fail

[or...@apache.org]

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

orpiske pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git

commit 56ddf9e1e9c272199d002e38e041aee3c0be9ee2
Author: Otavio Rodolfo Piske <op...@redhat.com>
AuthorDate: Mon Feb 15 11:03:37 2021 +0100

    Avoid spawning Jetty servers too quickly as they seem to cause GH actions to fail
---
 .../syslog/source/CamelSourceSyslogITCase.java        | 19 ++++++++++++++++++-
 1 file changed, 18 insertions(+), 1 deletion(-)

diff --git a/tests/itests-syslog/src/test/java/org/apache/camel/kafkaconnector/syslog/source/CamelSourceSyslogITCase.java b/tests/itests-syslog/src/test/java/org/apache/camel/kafkaconnector/syslog/source/CamelSourceSyslogITCase.java
index 3a14ac2..ab80914 100644
--- a/tests/itests-syslog/src/test/java/org/apache/camel/kafkaconnector/syslog/source/CamelSourceSyslogITCase.java
+++ b/tests/itests-syslog/src/test/java/org/apache/camel/kafkaconnector/syslog/source/CamelSourceSyslogITCase.java
@@ -25,11 +25,15 @@ import org.apache.camel.kafkaconnector.common.test.CamelSourceTestSupport;
 import org.apache.camel.kafkaconnector.common.test.StringMessageConsumer;
 import org.apache.camel.kafkaconnector.common.test.TestMessageConsumer;
 import org.apache.camel.kafkaconnector.common.utils.NetworkUtils;
+import org.apache.camel.kafkaconnector.common.utils.TestUtils;
 import org.apache.camel.kafkaconnector.syslog.services.SyslogService;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.RepeatedTest;
+import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.TestInstance;
 import org.junit.jupiter.api.Timeout;
+import org.junit.jupiter.api.condition.DisabledIfSystemProperty;
+import org.junit.jupiter.api.condition.EnabledIfSystemProperty;
 import org.junit.jupiter.api.extension.RegisterExtension;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
@@ -77,11 +81,16 @@ public class CamelSourceSyslogITCase extends CamelSourceTestSupport {
     }
 
 
-    @RepeatedTest(3)
+
+
     @Timeout(90)
+    @Test
+    @DisabledIfSystemProperty(named = "enable.flaky.tests", matches = "true",
+            disabledReason = "Already executed with testBasicSendStress")
     public void testBasicSend() throws ExecutionException, InterruptedException {
         ConnectorPropertyFactory connectorPropertyFactory = CamelSyslogPropertyFactory
                 .basic()
+                .withName("CamelSyslogSourceConnector" + TestUtils.randomWithRange(0, 1000))
                 .withKafkaTopic(topicName)
                 .withHost(HOST)
                 .withPort(FREE_PORT)
@@ -92,4 +101,12 @@ public class CamelSourceSyslogITCase extends CamelSourceTestSupport {
 
         runTestBlocking(connectorPropertyFactory, stringMessageConsumer);
     }
+
+    @RepeatedTest(3)
+    @Timeout(90)
+    @EnabledIfSystemProperty(named = "enable.flaky.tests", matches = "true",
+            disabledReason = "Quickly spawning multiple Jetty Servers doesn't work well on Github Actions")
+    public void testBasicSendStress() throws ExecutionException, InterruptedException {
+        testBasicSend();
+    }
 }