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/01 15:30:19 UTC
[camel-kafka-connector] branch camel-master updated: Ensure all
tests have timeouts
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 <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/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()