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 21f23efaa5ab1e3c3b5d6c785783a6758cde49f2 Author: Otavio Rodolfo Piske <angusyo...@gmail.com> AuthorDate: Tue Mar 8 14:41:07 2022 +0100 CAMEL-17763: cleaned up unused exceptions in camel-aws2-sns --- .../component/aws2/sns/SNSComponentClientRegistryTest.java | 2 +- .../component/aws2/sns/SnsComponentConfigurationTest.java | 4 ++-- .../camel/component/aws2/sns/SnsComponentSpringTest.java | 8 ++++---- .../apache/camel/component/aws2/sns/SnsComponentTest.java | 12 ++++++------ .../aws2/sns/SnsComponentVerifierExtensionTest.java | 6 +++--- .../aws2/sns/integration/SnsComponentFifoManualIT.java | 12 ++++++------ .../component/aws2/sns/integration/SnsComponentManualIT.java | 12 ++++++------ .../aws2/sns/integration/SnsTopicProducerCustomConfigIT.java | 12 ++++++------ .../component/aws2/sns/integration/SnsTopicProducerIT.java | 12 ++++++------ .../sns/integration/SnsTopicProducerWithSubscriptionIT.java | 8 ++++---- .../sns/integration/SnsTopicWithKmsEncryptionManualIT.java | 12 ++++++------ 11 files changed, 50 insertions(+), 50 deletions(-) diff --git a/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/SNSComponentClientRegistryTest.java b/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/SNSComponentClientRegistryTest.java index 1677395..77db7e1 100644 --- a/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/SNSComponentClientRegistryTest.java +++ b/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/SNSComponentClientRegistryTest.java @@ -37,7 +37,7 @@ public class SNSComponentClientRegistryTest extends CamelTestSupport { } @Test - public void createEndpointWithMinimalSNSClientMisconfiguration() throws Exception { + public void createEndpointWithMinimalSNSClientMisconfiguration() { Sns2Component component = context.getComponent("aws2-sns", Sns2Component.class); assertThrows(IllegalArgumentException.class, () -> { diff --git a/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/SnsComponentConfigurationTest.java b/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/SnsComponentConfigurationTest.java index 8944612..b98097a 100644 --- a/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/SnsComponentConfigurationTest.java +++ b/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/SnsComponentConfigurationTest.java @@ -145,7 +145,7 @@ public class SnsComponentConfigurationTest extends CamelTestSupport { } @Test - public void createEndpointWithoutAccessKeyConfiguration() throws Exception { + public void createEndpointWithoutAccessKeyConfiguration() { Sns2Component component = context.getComponent("aws2-sns", Sns2Component.class); assertThrows(IllegalArgumentException.class, () -> { component.createEndpoint("aws2-sns://MyTopic?secretKey=yyy"); @@ -153,7 +153,7 @@ public class SnsComponentConfigurationTest extends CamelTestSupport { } @Test - public void createEndpointWithoutSecretKeyConfiguration() throws Exception { + public void createEndpointWithoutSecretKeyConfiguration() { Sns2Component component = new Sns2Component(context); assertThrows(IllegalArgumentException.class, () -> { component.createEndpoint("aws2-sns://MyTopic?accessKey=xxx"); diff --git a/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/SnsComponentSpringTest.java b/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/SnsComponentSpringTest.java index 7817c45..03fcfb1 100644 --- a/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/SnsComponentSpringTest.java +++ b/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/SnsComponentSpringTest.java @@ -28,9 +28,9 @@ import static org.junit.jupiter.api.Assertions.assertEquals; public class SnsComponentSpringTest extends CamelSpringTestSupport { @Test - public void sendInOnly() throws Exception { + public void sendInOnly() { Exchange exchange = template.send("direct:start", ExchangePattern.InOnly, new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(Sns2Constants.SUBJECT, "This is my subject text."); exchange.getIn().setBody("This is my message text."); } @@ -40,9 +40,9 @@ public class SnsComponentSpringTest extends CamelSpringTestSupport { } @Test - public void sendInOut() throws Exception { + public void sendInOut() { 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(Sns2Constants.SUBJECT, "This is my subject text."); exchange.getIn().setBody("This is my message text."); } diff --git a/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/SnsComponentTest.java b/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/SnsComponentTest.java index 5799ed5..46652ee 100644 --- a/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/SnsComponentTest.java +++ b/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/SnsComponentTest.java @@ -33,9 +33,9 @@ public class SnsComponentTest extends CamelTestSupport { AmazonSNSClientMock client = new AmazonSNSClientMock(); @Test - public void sendInOnly() throws Exception { + public void sendInOnly() { Exchange exchange = template.send("direct:start", ExchangePattern.InOnly, new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(Sns2Constants.SUBJECT, "This is my subject text."); exchange.getIn().setBody("This is my message text."); } @@ -45,9 +45,9 @@ public class SnsComponentTest extends CamelTestSupport { } @Test - public void sendInOut() throws Exception { + public void sendInOut() { 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(Sns2Constants.SUBJECT, "This is my subject text."); exchange.getIn().setBody("This is my message text."); } @@ -57,10 +57,10 @@ public class SnsComponentTest extends CamelTestSupport { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("direct:start").to("aws2-sns://MyTopic?amazonSNSClient=#amazonSNSClient"); } }; diff --git a/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/SnsComponentVerifierExtensionTest.java b/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/SnsComponentVerifierExtensionTest.java index 2dbc6ff..b0260c2 100644 --- a/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/SnsComponentVerifierExtensionTest.java +++ b/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/SnsComponentVerifierExtensionTest.java @@ -37,7 +37,7 @@ public class SnsComponentVerifierExtensionTest extends CamelTestSupport { } @Test - public void testParameters() throws Exception { + public void testParameters() { Component component = context().getComponent("aws2-sns"); ComponentVerifierExtension verifier @@ -55,7 +55,7 @@ public class SnsComponentVerifierExtensionTest extends CamelTestSupport { } @Test - public void testConnectivity() throws Exception { + public void testConnectivity() { Component component = context().getComponent("aws2-sns"); ComponentVerifierExtension verifier = component.getExtension(ComponentVerifierExtension.class).orElseThrow(IllegalStateException::new); @@ -72,7 +72,7 @@ public class SnsComponentVerifierExtensionTest extends CamelTestSupport { } @Test - public void testConnectivityAndRegion() throws Exception { + public void testConnectivityAndRegion() { Component component = context().getComponent("aws2-sns"); ComponentVerifierExtension verifier = component.getExtension(ComponentVerifierExtension.class).orElseThrow(IllegalStateException::new); diff --git a/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsComponentFifoManualIT.java b/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsComponentFifoManualIT.java index 7e9e5de..07a7b35 100644 --- a/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsComponentFifoManualIT.java +++ b/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsComponentFifoManualIT.java @@ -36,9 +36,9 @@ import static org.junit.jupiter.api.Assertions.assertNotNull; public class SnsComponentFifoManualIT extends CamelTestSupport { @Test - public void sendInOnly() throws Exception { + public void sendInOnly() { Exchange exchange = template.send("direct:start", ExchangePattern.InOnly, new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(Sns2Constants.SUBJECT, "This is my subject"); exchange.getIn().setBody("This is my message text."); } @@ -48,9 +48,9 @@ public class SnsComponentFifoManualIT extends CamelTestSupport { } @Test - public void sendInOut() throws Exception { + public void sendInOut() { 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(Sns2Constants.SUBJECT, "This is my subject"); exchange.getIn().setBody("This is my message text."); } @@ -60,10 +60,10 @@ public class SnsComponentFifoManualIT extends CamelTestSupport { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("direct:start") .to("aws2-sns://Order.fifo?accessKey=RAW({{aws.manual.access.key}})&secretKey=RAW({{aws.manual.secret.key}})®ion=eu-west-1&subject=The+subject+message&messageGroupIdStrategy=useExchangeId&autoCreateTopic=true"); } diff --git a/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsComponentManualIT.java b/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsComponentManualIT.java index 75133ba..ec833bb 100644 --- a/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsComponentManualIT.java +++ b/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsComponentManualIT.java @@ -36,9 +36,9 @@ import static org.junit.jupiter.api.Assertions.assertNotNull; public class SnsComponentManualIT extends CamelTestSupport { @Test - public void sendInOnly() throws Exception { + public void sendInOnly() { Exchange exchange = template.send("direct:start", ExchangePattern.InOnly, new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(Sns2Constants.SUBJECT, "This is my subject"); exchange.getIn().setBody("This is my message text."); } @@ -48,9 +48,9 @@ public class SnsComponentManualIT extends CamelTestSupport { } @Test - public void sendInOut() throws Exception { + public void sendInOut() { 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(Sns2Constants.SUBJECT, "This is my subject"); exchange.getIn().setBody("This is my message text."); } @@ -60,10 +60,10 @@ public class SnsComponentManualIT extends CamelTestSupport { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("direct:start") .to("aws2-sns://MyNewTopic?accessKey={{aws.manual.access.key}}&secretKey={{aws.manual.secret.key}}&policy=%7B%22Version%22%3A%222008-10-17%22,%22Statement%22%3A%5B%7B%22Sid%22%3A%221%22,%22Effect%22%3A%22Allow%22," + "%22Principal%22%3A%7B%22AWS%22%3A%5B%22*%22%5D%7D,%22Action%22%3A%5B%22sns%3ASubscribe%22%5D%7D%5D%7D&subject=The+subject+message&autoCreateTopic=true"); diff --git a/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsTopicProducerCustomConfigIT.java b/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsTopicProducerCustomConfigIT.java index e69a00d..84263b7 100644 --- a/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsTopicProducerCustomConfigIT.java +++ b/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsTopicProducerCustomConfigIT.java @@ -34,9 +34,9 @@ public class SnsTopicProducerCustomConfigIT extends Aws2SNSBase { public static SharedNameGenerator sharedNameGenerator = new TestEntityNameGenerator(); @Test - public void sendInOnly() throws Exception { + public void sendInOnly() { Exchange exchange = template.send("direct:start", ExchangePattern.InOnly, new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(Sns2Constants.SUBJECT, "This is my subject"); exchange.getIn().setBody("This is my message text."); } @@ -46,9 +46,9 @@ public class SnsTopicProducerCustomConfigIT extends Aws2SNSBase { } @Test - public void sendInOut() throws Exception { + public void sendInOut() { 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(Sns2Constants.SUBJECT, "This is my subject"); exchange.getIn().setBody("This is my message text."); } @@ -58,10 +58,10 @@ public class SnsTopicProducerCustomConfigIT extends Aws2SNSBase { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("direct:start") .toF("aws2-sns://%s?subject=The+subject+message&configuration=#class:%s&autoCreateTopic=true", sharedNameGenerator.getName(), TestSnsConfiguration.class.getName()); diff --git a/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsTopicProducerIT.java b/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsTopicProducerIT.java index 6b6e871..7b5993d 100644 --- a/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsTopicProducerIT.java +++ b/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsTopicProducerIT.java @@ -34,9 +34,9 @@ public class SnsTopicProducerIT extends Aws2SNSBase { public static SharedNameGenerator sharedNameGenerator = new TestEntityNameGenerator(); @Test - public void sendInOnly() throws Exception { + public void sendInOnly() { Exchange exchange = template.send("direct:start", ExchangePattern.InOnly, new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(Sns2Constants.SUBJECT, "This is my subject"); exchange.getIn().setBody("This is my message text."); } @@ -46,9 +46,9 @@ public class SnsTopicProducerIT extends Aws2SNSBase { } @Test - public void sendInOut() throws Exception { + public void sendInOut() { 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(Sns2Constants.SUBJECT, "This is my subject"); exchange.getIn().setBody("This is my message text."); } @@ -58,10 +58,10 @@ public class SnsTopicProducerIT extends Aws2SNSBase { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("direct:start") .toF("aws2-sns://%s?subject=The+subject+message&autoCreateTopic=true", sharedNameGenerator.getName()); } diff --git a/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsTopicProducerWithSubscriptionIT.java b/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsTopicProducerWithSubscriptionIT.java index fcd5da3..a936ac0 100644 --- a/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsTopicProducerWithSubscriptionIT.java +++ b/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsTopicProducerWithSubscriptionIT.java @@ -103,9 +103,9 @@ public class SnsTopicProducerWithSubscriptionIT extends Aws2SNSBase { } @Test - public void sendInOnly() throws Exception { + public void sendInOnly() { Exchange exchange = template.send("direct:start", ExchangePattern.InOnly, new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(Sns2Constants.SUBJECT, "This is my subject"); exchange.getIn().setBody("This is my message text."); } @@ -119,12 +119,12 @@ public class SnsTopicProducerWithSubscriptionIT extends Aws2SNSBase { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { setUpQueue(); return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("direct:start") .toF("aws2-sns://%s?subject=The+subject+message&autoCreateTopic=true&subscribeSNStoSQS=true&queueUrl=%s", sharedNameGenerator.getName(), sqsQueueUrl); diff --git a/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsTopicWithKmsEncryptionManualIT.java b/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsTopicWithKmsEncryptionManualIT.java index e328241..2b8a3a2 100644 --- a/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsTopicWithKmsEncryptionManualIT.java +++ b/components/camel-aws/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsTopicWithKmsEncryptionManualIT.java @@ -36,9 +36,9 @@ import static org.junit.jupiter.api.Assertions.assertNotNull; public class SnsTopicWithKmsEncryptionManualIT extends CamelTestSupport { @Test - public void sendInOnly() throws Exception { + public void sendInOnly() { Exchange exchange = template.send("direct:start", ExchangePattern.InOnly, new Processor() { - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { exchange.getIn().setHeader(Sns2Constants.SUBJECT, "This is my subject"); exchange.getIn().setBody("This is my message text."); } @@ -48,9 +48,9 @@ public class SnsTopicWithKmsEncryptionManualIT extends CamelTestSupport { } @Test - public void sendInOut() throws Exception { + public void sendInOut() { 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(Sns2Constants.SUBJECT, "This is my subject"); exchange.getIn().setBody("This is my message text."); } @@ -60,10 +60,10 @@ public class SnsTopicWithKmsEncryptionManualIT extends CamelTestSupport { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("direct:start") .to("aws2-sns://MyNewTopic1?accessKey=RAW({{aws.manual.access.key}})&secretKey=RAW({{aws.manual.secret.key}})" + "®ion=EU_WEST_1&subject=The+subject+message&serverSideEncryptionEnabled=true&"