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.git
commit c69c75cd6f1a002acce86e99b9a31fb14d91845b Author: Otavio Rodolfo Piske <angusyo...@gmail.com> AuthorDate: Tue Mar 8 14:41:06 2022 +0100 CAMEL-17763: cleaned up unused exceptions in camel-aws2-s3 --- .../aws2/s3/S3ComponentVerifierExtensionTest.java | 6 +++--- .../component/aws2/s3/integration/S3ComponentManualIT.java | 10 +++++----- .../camel/component/aws2/s3/integration/S3ConsumerIT.java | 10 +++++----- .../aws2/s3/integration/S3ConsumerIgnoreBodyIT.java | 6 +++--- .../aws2/s3/integration/S3ConsumerIncludeBodyIT.java | 10 +++++----- .../component/aws2/s3/integration/S3ConsumerManualIT.java | 10 +++++----- .../aws2/s3/integration/S3CopyObjectCustomerKeyIT.java | 12 ++++++------ .../aws2/s3/integration/S3CopyObjectOperationManualIT.java | 8 ++++---- .../s3/integration/S3CreateDownloadLinkOperationIT.java | 12 ++++++------ ...CreateDownloadLinkWithProvidedPresignerOperationIT.java | 10 +++++----- .../aws2/s3/integration/S3DeleteBucketOperationIT.java | 8 ++++---- .../component/aws2/s3/integration/S3GzipOperationIT.java | 4 ++-- .../aws2/s3/integration/S3ListObjectsOperationIT.java | 14 +++++++------- .../aws2/s3/integration/S3MultipartUploadOperationIT.java | 10 +++++----- .../s3/integration/S3ObjectRangeOperationManualIT.java | 6 +++--- .../s3/integration/S3SimpleEncryptedUploadOperationIT.java | 10 +++++----- .../aws2/s3/integration/S3SimpleUploadOperationIT.java | 12 ++++++------ .../aws2/s3/integration/S3StreamUploadOperationIT.java | 6 +++--- .../aws2/s3/integration/S3StreamUploadTimeoutIT.java | 6 +++--- .../aws2/s3/integration/S3UploadWithUserMetadataIT.java | 6 +++--- 20 files changed, 88 insertions(+), 88 deletions(-) diff --git a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/S3ComponentVerifierExtensionTest.java b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/S3ComponentVerifierExtensionTest.java index ee83410..a1cac9c 100644 --- a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/S3ComponentVerifierExtensionTest.java +++ b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/S3ComponentVerifierExtensionTest.java @@ -37,7 +37,7 @@ public class S3ComponentVerifierExtensionTest extends CamelTestSupport { } @Test - public void testParameters() throws Exception { + public void testParameters() { Component component = context().getComponent("aws2-s3"); ComponentVerifierExtension verifier @@ -55,7 +55,7 @@ public class S3ComponentVerifierExtensionTest extends CamelTestSupport { } @Test - public void testConnectivity() throws Exception { + public void testConnectivity() { Component component = context().getComponent("aws2-s3"); ComponentVerifierExtension verifier = component.getExtension(ComponentVerifierExtension.class).orElseThrow(IllegalStateException::new); @@ -72,7 +72,7 @@ public class S3ComponentVerifierExtensionTest extends CamelTestSupport { } @Test - public void testConnectivityAndRegion() throws Exception { + public void testConnectivityAndRegion() { Component component = context().getComponent("aws2-s3"); ComponentVerifierExtension verifier = component.getExtension(ComponentVerifierExtension.class).orElseThrow(IllegalStateException::new); diff --git a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ComponentManualIT.java b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ComponentManualIT.java index 8c3720b..60e6011 100644 --- a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ComponentManualIT.java +++ b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ComponentManualIT.java @@ -53,14 +53,14 @@ public class S3ComponentManualIT extends CamelTestSupport { result.expectedMessageCount(2); Exchange exchange1 = template.send("direct:start", ExchangePattern.InOnly, new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "CamelUnitTest1"); exchange.getIn().setBody("This is my bucket content."); } }); Exchange exchange2 = template.send("direct:start", ExchangePattern.InOnly, new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "CamelUnitTest2"); exchange.getIn().setBody("This is my bucket content."); } @@ -80,7 +80,7 @@ public class S3ComponentManualIT extends CamelTestSupport { result.expectedMessageCount(1); Exchange exchange = template.send("direct:start", ExchangePattern.InOut, new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "CamelUnitTest"); exchange.getIn().setBody("This is my bucket content."); } @@ -116,10 +116,10 @@ public class S3ComponentManualIT extends CamelTestSupport { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { String s3EndpointUri = "aws2-s3://mycamelbucket?accessKey={{aws.access.key}}&secretKey={{aws.secret.key}}®ion=us-west-1&autoCreateBucket=false"; diff --git a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ConsumerIT.java b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ConsumerIT.java index df33c7b..ff10bd0 100644 --- a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ConsumerIT.java +++ b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ConsumerIT.java @@ -40,7 +40,7 @@ public class S3ConsumerIT extends Aws2S3Base { template.send("direct:putObject", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "test.txt"); exchange.getIn().setBody("Test"); } @@ -49,7 +49,7 @@ public class S3ConsumerIT extends Aws2S3Base { template.send("direct:putObject", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "test1.txt"); exchange.getIn().setBody("Test1"); } @@ -58,7 +58,7 @@ public class S3ConsumerIT extends Aws2S3Base { template.send("direct:putObject", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "test2.txt"); exchange.getIn().setBody("Test2"); } @@ -69,10 +69,10 @@ public class S3ConsumerIT extends Aws2S3Base { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { String awsEndpoint = "aws2-s3://mycamel?autoCreateBucket=true"; from("direct:putObject").startupOrder(1).to(awsEndpoint).to("mock:result"); diff --git a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ConsumerIgnoreBodyIT.java b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ConsumerIgnoreBodyIT.java index 6afc63a..6767b58 100644 --- a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ConsumerIgnoreBodyIT.java +++ b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ConsumerIgnoreBodyIT.java @@ -41,7 +41,7 @@ public class S3ConsumerIgnoreBodyIT extends Aws2S3Base { template.send("direct:putObject", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "test.txt"); exchange.getIn().setBody("Test"); } @@ -53,10 +53,10 @@ public class S3ConsumerIgnoreBodyIT extends Aws2S3Base { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { String awsEndpoint = "aws2-s3://mycamel?autoCreateBucket=true"; from("direct:putObject").startupOrder(1).to(awsEndpoint); diff --git a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ConsumerIncludeBodyIT.java b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ConsumerIncludeBodyIT.java index 8c63f6b..4db6566 100644 --- a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ConsumerIncludeBodyIT.java +++ b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ConsumerIncludeBodyIT.java @@ -43,7 +43,7 @@ public class S3ConsumerIncludeBodyIT extends Aws2S3Base { template.send("direct:putObject", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "test.txt"); exchange.getIn().setBody("Test"); } @@ -52,7 +52,7 @@ public class S3ConsumerIncludeBodyIT extends Aws2S3Base { template.send("direct:putObject", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "test1.txt"); exchange.getIn().setBody("Test1"); } @@ -61,7 +61,7 @@ public class S3ConsumerIncludeBodyIT extends Aws2S3Base { template.send("direct:putObject", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "test2.txt"); exchange.getIn().setBody("Test2"); } @@ -73,10 +73,10 @@ public class S3ConsumerIncludeBodyIT extends Aws2S3Base { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { String awsEndpoint = "aws2-s3://mycamel?autoCreateBucket=true"; from("direct:putObject").startupOrder(1).to(awsEndpoint).to("mock:result"); diff --git a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ConsumerManualIT.java b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ConsumerManualIT.java index d18e656..a2f8a11 100644 --- a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ConsumerManualIT.java +++ b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ConsumerManualIT.java @@ -77,7 +77,7 @@ public class S3ConsumerManualIT extends CamelTestSupport { template.send("direct:putObject", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "test.txt"); exchange.getIn().setBody("Test"); } @@ -86,7 +86,7 @@ public class S3ConsumerManualIT extends CamelTestSupport { template.send("direct:putObject", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "test1.txt"); exchange.getIn().setBody("Test1"); } @@ -95,7 +95,7 @@ public class S3ConsumerManualIT extends CamelTestSupport { template.send("direct:putObject", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "test2.txt"); exchange.getIn().setBody("Test2"); } @@ -199,10 +199,10 @@ public class S3ConsumerManualIT extends CamelTestSupport { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { String template = "aws2-s3://mycamel?autoCreateBucket=true&includeBody=%s&autocloseBody=%s"; String includeBodyTrueAutoCloseTrue = String.format(template, true, true); String includeBodyFalseAutoCloseFalse = String.format(template, false, false); diff --git a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3CopyObjectCustomerKeyIT.java b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3CopyObjectCustomerKeyIT.java index 4f4e6e0..7424a83 100644 --- a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3CopyObjectCustomerKeyIT.java +++ b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3CopyObjectCustomerKeyIT.java @@ -67,7 +67,7 @@ public class S3CopyObjectCustomerKeyIT extends Aws2S3Base { template.send("direct:putObject", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "test.txt"); exchange.getIn().setBody("Test"); } @@ -76,7 +76,7 @@ public class S3CopyObjectCustomerKeyIT extends Aws2S3Base { template.send("direct:copyObject", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "test.txt"); exchange.getIn().setHeader(AWS2S3Constants.DESTINATION_KEY, "test1.txt"); exchange.getIn().setHeader(AWS2S3Constants.BUCKET_DESTINATION_NAME, "mycamel1"); @@ -87,7 +87,7 @@ public class S3CopyObjectCustomerKeyIT extends Aws2S3Base { Exchange res = template.request("direct:getObject", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { GetObjectRequest getObjectRequest = GetObjectRequest.builder() .key("test1.txt") .bucket("mycamel1") @@ -107,7 +107,7 @@ public class S3CopyObjectCustomerKeyIT extends Aws2S3Base { Exchange res1 = template.request("direct:listObject", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.S3_OPERATION, AWS2S3Operations.listObjects); } }); @@ -120,10 +120,10 @@ public class S3CopyObjectCustomerKeyIT extends Aws2S3Base { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { String awsEndpoint = "aws2-s3://mycamel?autoCreateBucket=true&useCustomerKey=true&customerKeyId=RAW(" + b64Key + ")&customerKeyMD5=RAW(" + b64KeyMd5 + ")&customerAlgorithm=" + AES256.name(); String awsEndpoint1 = "aws2-s3://mycamel1?autoCreateBucket=true&pojoRequest=true"; diff --git a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3CopyObjectOperationManualIT.java b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3CopyObjectOperationManualIT.java index c0c8a48..376501e 100644 --- a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3CopyObjectOperationManualIT.java +++ b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3CopyObjectOperationManualIT.java @@ -63,7 +63,7 @@ public class S3CopyObjectOperationManualIT extends CamelTestSupport { template.send("direct:putObject", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "test.txt"); exchange.getIn().setBody("Test"); } @@ -72,7 +72,7 @@ public class S3CopyObjectOperationManualIT extends CamelTestSupport { template.send("direct:copyObject", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "test.txt"); exchange.getIn().setHeader(AWS2S3Constants.DESTINATION_KEY, "test1.txt"); exchange.getIn().setHeader(AWS2S3Constants.BUCKET_DESTINATION_NAME, "mycamel1"); @@ -84,10 +84,10 @@ public class S3CopyObjectOperationManualIT extends CamelTestSupport { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { String awsEndpoint = "aws2-s3://mycamel?autoCreateBucket=false"; from("direct:putObject").to(awsEndpoint); diff --git a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3CreateDownloadLinkOperationIT.java b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3CreateDownloadLinkOperationIT.java index 5dca122..929f4f2 100644 --- a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3CreateDownloadLinkOperationIT.java +++ b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3CreateDownloadLinkOperationIT.java @@ -46,13 +46,13 @@ public class S3CreateDownloadLinkOperationIT extends Aws2S3Base { template.send("direct:listBucket", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.S3_OPERATION, AWS2S3Operations.listBuckets); } }); template.send("direct:addObject", ExchangePattern.InOnly, new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "CamelUnitTest2"); exchange.getIn().setBody("This is my bucket content."); exchange.getIn().removeHeader(AWS2S3Constants.S3_OPERATION); @@ -60,7 +60,7 @@ public class S3CreateDownloadLinkOperationIT extends Aws2S3Base { }); Exchange ex1 = template.request("direct:createDownloadLink", new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "CamelUnitTest2"); exchange.getIn().setHeader(AWS2S3Constants.BUCKET_NAME, "mycamel2"); exchange.getIn().setHeader(AWS2S3Constants.S3_OPERATION, AWS2S3Operations.createDownloadLink); @@ -68,7 +68,7 @@ public class S3CreateDownloadLinkOperationIT extends Aws2S3Base { }); Exchange ex2 = template.request("direct:createDownloadLinkWithoutCredentials", new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "CamelUnitTest2"); exchange.getIn().setHeader(AWS2S3Constants.BUCKET_NAME, "mycamel2"); exchange.getIn().setHeader(AWS2S3Constants.S3_OPERATION, AWS2S3Operations.createDownloadLink); @@ -81,10 +81,10 @@ public class S3CreateDownloadLinkOperationIT extends Aws2S3Base { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { String awsEndpoint = "aws2-s3://mycamel2?autoCreateBucket=true"; from("direct:listBucket").to(awsEndpoint); diff --git a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3CreateDownloadLinkWithProvidedPresignerOperationIT.java b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3CreateDownloadLinkWithProvidedPresignerOperationIT.java index b78ba06..ee24b37 100644 --- a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3CreateDownloadLinkWithProvidedPresignerOperationIT.java +++ b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3CreateDownloadLinkWithProvidedPresignerOperationIT.java @@ -56,13 +56,13 @@ public class S3CreateDownloadLinkWithProvidedPresignerOperationIT extends Aws2S3 template.send("direct:listBucket", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.S3_OPERATION, AWS2S3Operations.listBuckets); } }); template.send("direct:addObject", ExchangePattern.InOnly, new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "CamelUnitTest2"); exchange.getIn().setBody("This is my bucket content."); exchange.getIn().removeHeader(AWS2S3Constants.S3_OPERATION); @@ -70,7 +70,7 @@ public class S3CreateDownloadLinkWithProvidedPresignerOperationIT extends Aws2S3 }); Exchange ex1 = template.request("direct:createDownloadLink", new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "CamelUnitTest2"); exchange.getIn().setHeader(AWS2S3Constants.BUCKET_NAME, "mycamel2"); exchange.getIn().setHeader(AWS2S3Constants.S3_OPERATION, AWS2S3Operations.createDownloadLink); @@ -82,10 +82,10 @@ public class S3CreateDownloadLinkWithProvidedPresignerOperationIT extends Aws2S3 } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { String awsEndpoint = "aws2-s3://mycamel2?autoCreateBucket=true"; from("direct:listBucket").to(awsEndpoint); diff --git a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3DeleteBucketOperationIT.java b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3DeleteBucketOperationIT.java index 6e3e181..39bc6ca 100644 --- a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3DeleteBucketOperationIT.java +++ b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3DeleteBucketOperationIT.java @@ -41,7 +41,7 @@ public class S3DeleteBucketOperationIT extends Aws2S3Base { template.send("direct:listBucket", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.S3_OPERATION, AWS2S3Operations.listBuckets); } }); @@ -49,7 +49,7 @@ public class S3DeleteBucketOperationIT extends Aws2S3Base { template.send("direct:deleteBucket", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.BUCKET_NAME, "mycamel2"); exchange.getIn().setHeader(AWS2S3Constants.S3_OPERATION, AWS2S3Operations.deleteBucket); } @@ -59,10 +59,10 @@ public class S3DeleteBucketOperationIT extends Aws2S3Base { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { String awsEndpoint = "aws2-s3://mycamel2?autoCreateBucket=true"; from("direct:listBucket").to(awsEndpoint); diff --git a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3GzipOperationIT.java b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3GzipOperationIT.java index db831e3..9744ff2 100644 --- a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3GzipOperationIT.java +++ b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3GzipOperationIT.java @@ -66,10 +66,10 @@ public class S3GzipOperationIT extends Aws2S3Base { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("direct:putObject") .marshal().gzipDeflater() .to("aws2-s3://mycamel?autoCreateBucket=true"); diff --git a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ListObjectsOperationIT.java b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ListObjectsOperationIT.java index f9a837f..601e462 100644 --- a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ListObjectsOperationIT.java +++ b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ListObjectsOperationIT.java @@ -48,13 +48,13 @@ public class S3ListObjectsOperationIT extends Aws2S3Base { template.send("direct:listBucket", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.S3_OPERATION, AWS2S3Operations.listBuckets); } }); template.send("direct:addObject", ExchangePattern.InOnly, new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "CamelUnitTest2"); exchange.getIn().setBody("This is my bucket content."); exchange.getIn().removeHeader(AWS2S3Constants.S3_OPERATION); @@ -64,7 +64,7 @@ public class S3ListObjectsOperationIT extends Aws2S3Base { Exchange ex = template.request("direct:listObjects", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.BUCKET_NAME, "mycamel2"); exchange.getIn().setHeader(AWS2S3Constants.S3_OPERATION, AWS2S3Operations.listObjects); } @@ -75,7 +75,7 @@ public class S3ListObjectsOperationIT extends Aws2S3Base { assertEquals("CamelUnitTest2", resp.get(0).key()); template.send("direct:deleteObject", ExchangePattern.InOnly, new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "CamelUnitTest2"); exchange.getIn().setHeader(AWS2S3Constants.BUCKET_NAME, "mycamel2"); exchange.getIn().setHeader(AWS2S3Constants.S3_OPERATION, AWS2S3Operations.deleteObject); @@ -85,7 +85,7 @@ public class S3ListObjectsOperationIT extends Aws2S3Base { template.send("direct:deleteBucket", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.BUCKET_NAME, "mycamel2"); exchange.getIn().setHeader(AWS2S3Constants.S3_OPERATION, AWS2S3Operations.deleteBucket); } @@ -95,10 +95,10 @@ public class S3ListObjectsOperationIT extends Aws2S3Base { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { String awsEndpoint = "aws2-s3://mycamel2?autoCreateBucket=true"; from("direct:listBucket").to(awsEndpoint); diff --git a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3MultipartUploadOperationIT.java b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3MultipartUploadOperationIT.java index e50d16d..543c377 100644 --- a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3MultipartUploadOperationIT.java +++ b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3MultipartUploadOperationIT.java @@ -49,7 +49,7 @@ public class S3MultipartUploadOperationIT extends Aws2S3Base { template.send("direct:putObject", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "empty.txt"); exchange.getIn().setBody(new File("src/test/resources/empty.txt")); } @@ -59,13 +59,13 @@ public class S3MultipartUploadOperationIT extends Aws2S3Base { } @Test - public void sendInWithContentType() throws Exception { + public void sendInWithContentType() { result.expectedMessageCount(1); template.send("direct:putObject", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "camel-content-type.txt"); exchange.getIn().setBody(new File("src/test/resources/empty.txt")); exchange.getIn().setHeader(AWS2S3Constants.CONTENT_TYPE, "application/text"); @@ -79,10 +79,10 @@ public class S3MultipartUploadOperationIT extends Aws2S3Base { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { String awsEndpoint = "aws2-s3://mycamel?multiPartUpload=true&autoCreateBucket=true"; from("direct:putObject").to(awsEndpoint).to("mock:result"); diff --git a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ObjectRangeOperationManualIT.java b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ObjectRangeOperationManualIT.java index cec201c..bc4ff3a 100644 --- a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ObjectRangeOperationManualIT.java +++ b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3ObjectRangeOperationManualIT.java @@ -75,7 +75,7 @@ public class S3ObjectRangeOperationManualIT extends CamelTestSupport { template.send("direct:getObjectRange", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "element.txt"); exchange.getIn().setHeader(AWS2S3Constants.RANGE_START, 0); exchange.getIn().setHeader(AWS2S3Constants.RANGE_END, 9); @@ -86,10 +86,10 @@ public class S3ObjectRangeOperationManualIT extends CamelTestSupport { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { String awsEndpoint = "aws2-s3://mycamelbucket?operation=getObjectRange&autoCreateBucket=false"; from("direct:getObjectRange").to(awsEndpoint).process(new Processor() { diff --git a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3SimpleEncryptedUploadOperationIT.java b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3SimpleEncryptedUploadOperationIT.java index 71496fd..8b7f42e 100644 --- a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3SimpleEncryptedUploadOperationIT.java +++ b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3SimpleEncryptedUploadOperationIT.java @@ -50,7 +50,7 @@ public class S3SimpleEncryptedUploadOperationIT extends Aws2S3Base { template.send("direct:putObject", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "camel.txt"); exchange.getIn().setBody("Camel rocks!"); } @@ -59,7 +59,7 @@ public class S3SimpleEncryptedUploadOperationIT extends Aws2S3Base { template.request("direct:listObjects", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.BUCKET_NAME, "mycamel"); exchange.getIn().setHeader(AWS2S3Constants.S3_OPERATION, AWS2S3Operations.listObjects); } @@ -68,7 +68,7 @@ public class S3SimpleEncryptedUploadOperationIT extends Aws2S3Base { Exchange c = template.request("direct:getObject", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "camel.txt"); exchange.getIn().setHeader(AWS2S3Constants.S3_OPERATION, AWS2S3Operations.getObject); } @@ -84,11 +84,11 @@ public class S3SimpleEncryptedUploadOperationIT extends Aws2S3Base { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { String key = createKmsKey(); return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { String awsEndpoint = "aws2-s3://mycamel?autoCreateBucket=true&useAwsKMS=true&awsKMSKeyId=" + key; from("direct:putObject").to(awsEndpoint); diff --git a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3SimpleUploadOperationIT.java b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3SimpleUploadOperationIT.java index b2e03db..25353cb 100644 --- a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3SimpleUploadOperationIT.java +++ b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3SimpleUploadOperationIT.java @@ -51,7 +51,7 @@ public class S3SimpleUploadOperationIT extends Aws2S3Base { template.send("direct:putObject", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "camel.txt"); exchange.getIn().setBody("Camel rocks!"); } @@ -60,7 +60,7 @@ public class S3SimpleUploadOperationIT extends Aws2S3Base { template.request("direct:listObjects", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.BUCKET_NAME, "mycamel"); exchange.getIn().setHeader(AWS2S3Constants.S3_OPERATION, AWS2S3Operations.listObjects); } @@ -74,13 +74,13 @@ public class S3SimpleUploadOperationIT extends Aws2S3Base { } @Test - public void sendInWithContentType() throws Exception { + public void sendInWithContentType() { result.expectedMessageCount(1); template.send("direct:putObject", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.KEY, "camel-content-type.txt"); exchange.getIn().setHeader(AWS2S3Constants.CONTENT_TYPE, "application/text"); exchange.getIn().setBody("Camel rocks!"); @@ -94,10 +94,10 @@ public class S3SimpleUploadOperationIT extends Aws2S3Base { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { String awsEndpoint = "aws2-s3://mycamel?autoCreateBucket=true"; from("direct:putObject").to(awsEndpoint); diff --git a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3StreamUploadOperationIT.java b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3StreamUploadOperationIT.java index 51dc3da..26fa90f 100644 --- a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3StreamUploadOperationIT.java +++ b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3StreamUploadOperationIT.java @@ -52,7 +52,7 @@ public class S3StreamUploadOperationIT extends Aws2S3Base { Exchange ex = template.request("direct:listObjects", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.S3_OPERATION, AWS2S3Operations.listObjects); } }); @@ -62,10 +62,10 @@ public class S3StreamUploadOperationIT extends Aws2S3Base { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { String awsEndpoint1 = "aws2-s3://mycamel-1?autoCreateBucket=true&streamingUploadMode=true&keyName=fileTest.txt&batchMessageNumber=25&namingStrategy=random"; diff --git a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3StreamUploadTimeoutIT.java b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3StreamUploadTimeoutIT.java index cf337c5..d07ea49 100644 --- a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3StreamUploadTimeoutIT.java +++ b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3StreamUploadTimeoutIT.java @@ -53,7 +53,7 @@ public class S3StreamUploadTimeoutIT extends Aws2S3Base { Exchange ex = template.request("direct:listObjects", new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(AWS2S3Constants.S3_OPERATION, AWS2S3Operations.listObjects); } }); @@ -63,10 +63,10 @@ public class S3StreamUploadTimeoutIT extends Aws2S3Base { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { String awsEndpoint1 = "aws2-s3://mycamel-1?autoCreateBucket=true&streamingUploadMode=true&keyName=fileTest.txt&batchMessageNumber=25&namingStrategy=random&streamingUploadTimeout=10000"; diff --git a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3UploadWithUserMetadataIT.java b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3UploadWithUserMetadataIT.java index e51884a..bc4e452 100644 --- a/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3UploadWithUserMetadataIT.java +++ b/components/camel-aws/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/integration/S3UploadWithUserMetadataIT.java @@ -42,7 +42,7 @@ public class S3UploadWithUserMetadataIT extends Aws2S3Base { private MockEndpoint result; @Test - public void sendInWithUserMetadata() throws Exception { + public void sendInWithUserMetadata() { result.expectedMessageCount(1); template.send("direct:putObject", exchange -> { @@ -59,10 +59,10 @@ public class S3UploadWithUserMetadataIT extends Aws2S3Base { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { String awsEndpoint = "aws2-s3://mycamel?autoCreateBucket=true"; from("direct:putObject").to(awsEndpoint);