Disabled the urlBased test on the AWS S3 IT test

Related to the known issue #260 on Github
apache · Jun 10, 2020 · 0b49cfc · 0b49cfc
1 parent b782821
commit 0b49cfc
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...s/src/test/java/org/apache/camel/kafkaconnector/aws/s3/source/CamelSourceAWSS3ITCase.java b/...s/src/test/java/org/apache/camel/kafkaconnector/aws/s3/source/CamelSourceAWSS3ITCase.java
@@ -34,6 +34,7 @@
 import org.apache.kafka.clients.consumer.ConsumerRecord;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.Timeout;
 import org.junit.jupiter.api.extension.RegisterExtension;
@@ -158,6 +159,7 @@ public void testBasicSendReceiveWithKafkaStyle() throws ExecutionException, Inte
     }
 
 
+    @Disabled("Disabled due to issue #260")
     @Test
     @Timeout(180)
     public void testBasicSendReceiveUsingUrl() throws ExecutionException, InterruptedException {
@@ -167,10 +169,9 @@ public void testBasicSendReceiveUsingUrl() throws ExecutionException, Interrupte
                 .basic()
                 .withKafkaTopic(TestUtils.getDefaultTestTopic(this.getClass()))
                 .withUrl(AWSCommon.DEFAULT_S3_BUCKET)
-                    .append("configuration", "#class:" + TestS3Configuration.class.getName())
+                    .append("configuration", CamelAWSS3PropertyFactory.classRef(TestS3Configuration.class.getName()))
                     .append("accessKey", amazonProperties.getProperty(AWSConfigs.ACCESS_KEY))
                     .append("secretKey", amazonProperties.getProperty(AWSConfigs.SECRET_KEY))
-                    .append("protocol", amazonProperties.getProperty(AWSConfigs.PROTOCOL))
                     .append("region", amazonProperties.getProperty(AWSConfigs.REGION, Regions.US_EAST_1.name()))
                     .buildUrl();