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/04/28 11:29:39 UTC

[camel-kafka-connector] 02/02: Documented the reason why some AWS SQS source tests are disabled

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

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

commit 6176d3b9466425d6db534bc8ef18f6d50ed65a55
Author: Otavio Rodolfo Piske <op...@redhat.com>
AuthorDate: Wed Apr 28 11:08:58 2021 +0200

    Documented the reason why some AWS SQS source tests are disabled
---
 .../kafkaconnector/aws/v2/sqs/sink/CamelSinkAWSSQSITCase.java     | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/sqs/sink/CamelSinkAWSSQSITCase.java b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/sqs/sink/CamelSinkAWSSQSITCase.java
index c686377..8cd2eb1 100644
--- a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/sqs/sink/CamelSinkAWSSQSITCase.java
+++ b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/sqs/sink/CamelSinkAWSSQSITCase.java
@@ -135,6 +135,7 @@ public class CamelSinkAWSSQSITCase extends CamelSinkTestSupport {
                     .withName("CamelAwssqsSinkConnectorSpringBootStyle")
                     .withTopics(topicName)
                     .withAmazonConfig(amazonProperties)
+                    .withAutoCreateQueue(true)
                     .withQueueNameOrArn(queueName);
 
             runTest(testProperties, topicName, expect);
@@ -144,7 +145,8 @@ public class CamelSinkAWSSQSITCase extends CamelSinkTestSupport {
         }
     }
 
-    @DisabledIfSystemProperty(named = "aws-service.instance.type", matches = "remote")
+    @DisabledIfSystemProperty(named = "aws-service.instance.type", matches = "remote",
+            disabledReason = "Runs repeatedly, so it's disabled to avoid abusing the free tier")
     @Timeout(value = 120)
     @RepeatedTest(3)
     public void testBasicSendReceiveUsingKafkaStyle() {
@@ -157,6 +159,7 @@ public class CamelSinkAWSSQSITCase extends CamelSinkTestSupport {
                     .withName("CamelAwssqsSinkConnectorKafkaStyle")
                     .withTopics(topicName)
                     .withAmazonConfig(amazonProperties, CamelAWSSQSPropertyFactory.KAFKA_STYLE)
+                    .withAutoCreateQueue(true)
                     .withQueueNameOrArn(queueName);
 
             runTest(testProperties, topicName, expect);
@@ -167,7 +170,8 @@ public class CamelSinkAWSSQSITCase extends CamelSinkTestSupport {
         }
     }
 
-    @DisabledIfSystemProperty(named = "aws-service.instance.type", matches = "remote")
+    @DisabledIfSystemProperty(named = "aws-service.instance.type", matches = "remote",
+            disabledReason = "Uses arguments that may require additional setup on AWS or are not available in remote mode")
     @Timeout(value = 120)
     @RepeatedTest(3)
     public void testBasicSendReceiveUsingUrl() {