[camel-kafka-connector] branch camel-master updated: Ensure all tests have timeouts

[orpiske]

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


The following commit(s) were added to refs/heads/camel-master by this push:
     new d749b06  Ensure all tests have timeouts
d749b06 is described below

commit d749b067963a077f0aeea9fe1dd3416bb1cad5a4
Author: Otavio Rodolfo Piske <opi...@redhat.com>
AuthorDate: Mon Mar 1 11:48:12 2021 +0100

    Ensure all tests have timeouts
---
 .../camel/kafkaconnector/aws/v2/s3/sink/CamelSinkAWSS3ITCase.java      | 3 ++-
 .../org/apache/camel/kafkaconnector/cxf/sink/CamelSinkCXFITCase.java   | 1 +
 .../org/apache/camel/kafkaconnector/sql/sink/CamelSinkSQLITCase.java   | 2 ++
 .../camel/kafkaconnector/syslog/source/CamelSourceSyslogITCase.java    | 2 ++
 4 files changed, 7 insertions(+), 1 deletion(-)

diff --git 
a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/s3/sink/CamelSinkAWSS3ITCase.java
 
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/s3/sink/CamelSinkAWSS3ITCase.java
index fe404c4..d3c3816 100644
--- 
a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/s3/sink/CamelSinkAWSS3ITCase.java
+++ 
b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/s3/sink/CamelSinkAWSS3ITCase.java
@@ -38,6 +38,7 @@ import 
org.apache.camel.test.infra.aws2.services.AWSServiceFactory;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
 import org.junit.jupiter.api.condition.EnabledIfSystemProperty;
 import org.junit.jupiter.api.extension.RegisterExtension;
 import org.slf4j.Logger;
@@ -144,7 +145,7 @@ public class CamelSinkAWSS3ITCase extends 
CamelSinkTestSupport {
     }
 
     @Test
-//    @Timeout(180)
+    @Timeout(180)
     public void testBasicSendReceive() throws Exception {
         Properties amazonProperties = service.getConnectionProperties();
         String topicName = TestUtils.getDefaultTestTopic(this.getClass());
diff --git 
a/tests/itests-cxf/src/test/java/org/apache/camel/kafkaconnector/cxf/sink/CamelSinkCXFITCase.java
 
b/tests/itests-cxf/src/test/java/org/apache/camel/kafkaconnector/cxf/sink/CamelSinkCXFITCase.java
index 6690341..a80b3bd 100644
--- 
a/tests/itests-cxf/src/test/java/org/apache/camel/kafkaconnector/cxf/sink/CamelSinkCXFITCase.java
+++ 
b/tests/itests-cxf/src/test/java/org/apache/camel/kafkaconnector/cxf/sink/CamelSinkCXFITCase.java
@@ -99,6 +99,7 @@ public class CamelSinkCXFITCase extends CamelSinkTestSupport {
         return service.getJaxWsServerAddress() + 
"?serviceClass=org.apache.hello_world_soap_http.Greeter";
     }
 
+    @Timeout(20)
     @Test
     public void testBasicSendReceiveUsingUrl() throws Exception {
         InputStream stream = 
this.getClass().getResource("/hello-service-test.xml").openStream();
diff --git 
a/tests/itests-sql/src/test/java/org/apache/camel/kafkaconnector/sql/sink/CamelSinkSQLITCase.java
 
b/tests/itests-sql/src/test/java/org/apache/camel/kafkaconnector/sql/sink/CamelSinkSQLITCase.java
index a6d8bdd..c659970 100644
--- 
a/tests/itests-sql/src/test/java/org/apache/camel/kafkaconnector/sql/sink/CamelSinkSQLITCase.java
+++ 
b/tests/itests-sql/src/test/java/org/apache/camel/kafkaconnector/sql/sink/CamelSinkSQLITCase.java
@@ -34,6 +34,7 @@ import org.apache.camel.test.infra.jdbc.services.JDBCService;
 import org.apache.camel.test.infra.jdbc.services.JDBCServiceBuilder;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
 import org.junit.jupiter.api.extension.RegisterExtension;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -149,6 +150,7 @@ public class CamelSinkSQLITCase extends 
CamelSinkTestSupport {
         }
     }
 
+    @Timeout(60)
     @Test
     public void testDBFetch() throws Exception {
         CamelSqlPropertyFactory factory = CamelSqlPropertyFactory
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 e6c63f9..4768d9c 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
@@ -30,6 +30,7 @@ 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.Timeout;
 import org.junit.jupiter.api.condition.EnabledIfSystemProperty;
 import org.junit.jupiter.api.extension.RegisterExtension;
 
@@ -81,6 +82,7 @@ public class CamelSourceSyslogITCase extends 
CamelSourceTestSupport {
 
     @RepeatedTest(3)
     @Test
+    @Timeout(180)
     public void testBasicSend() throws ExecutionException, 
InterruptedException {
         ConnectorPropertyFactory connectorPropertyFactory = 
CamelSyslogPropertyFactory
                 .basic()