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);
