You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2021/03/03 08:06:11 UTC
[camel-kafka-connector] 11/11: Ensure all tests have timeouts
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 10ef1d68131fb41cf6c504a6feb02b04d82e6e0a
Author: Otavio Rodolfo Piske <op...@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/sql/sink/CamelSinkSQLITCase.java | 2 ++
.../camel/kafkaconnector/syslog/source/CamelSourceSyslogITCase.java | 2 ++
3 files changed, 6 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-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()