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&"
