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 <[email protected]> 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()
