You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2022/03/08 16:12:39 UTC
[camel] 15/21: CAMEL-17763: cleaned up unused exceptions in camel-aws2-msk
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 2321278a09df2e82b5d67a9d626f53e6e9433945
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Mar 8 14:41:06 2022 +0100
CAMEL-17763: cleaned up unused exceptions in camel-aws2-msk
---
.../component/aws2/msk/MSKComponentClientRegistryTest.java | 2 +-
.../aws2/msk/MSKComponentVerifierExtensionTest.java | 6 +++---
.../camel/component/aws2/msk/MSKProducerSpringTest.java | 10 +++++-----
.../apache/camel/component/aws2/msk/MSKProducerTest.java | 14 +++++++-------
4 files changed, 16 insertions(+), 16 deletions(-)
diff --git a/components/camel-aws/camel-aws2-msk/src/test/java/org/apache/camel/component/aws2/msk/MSKComponentClientRegistryTest.java b/components/camel-aws/camel-aws2-msk/src/test/java/org/apache/camel/component/aws2/msk/MSKComponentClientRegistryTest.java
index 63bd2a1..9215c94 100644
--- a/components/camel-aws/camel-aws2-msk/src/test/java/org/apache/camel/component/aws2/msk/MSKComponentClientRegistryTest.java
+++ b/components/camel-aws/camel-aws2-msk/src/test/java/org/apache/camel/component/aws2/msk/MSKComponentClientRegistryTest.java
@@ -37,7 +37,7 @@ public class MSKComponentClientRegistryTest extends CamelTestSupport {
}
@Test
- public void createEndpointWithMinimalMSKClientMisconfiguration() throws Exception {
+ public void createEndpointWithMinimalMSKClientMisconfiguration() {
MSK2Component component = context.getComponent("aws2-msk", MSK2Component.class);
assertThrows(IllegalArgumentException.class, () -> {
diff --git a/components/camel-aws/camel-aws2-msk/src/test/java/org/apache/camel/component/aws2/msk/MSKComponentVerifierExtensionTest.java b/components/camel-aws/camel-aws2-msk/src/test/java/org/apache/camel/component/aws2/msk/MSKComponentVerifierExtensionTest.java
index 8578c0b..8583907 100644
--- a/components/camel-aws/camel-aws2-msk/src/test/java/org/apache/camel/component/aws2/msk/MSKComponentVerifierExtensionTest.java
+++ b/components/camel-aws/camel-aws2-msk/src/test/java/org/apache/camel/component/aws2/msk/MSKComponentVerifierExtensionTest.java
@@ -37,7 +37,7 @@ public class MSKComponentVerifierExtensionTest extends CamelTestSupport {
}
@Test
- public void testParameters() throws Exception {
+ public void testParameters() {
Component component = context().getComponent("aws2-msk");
ComponentVerifierExtension verifier
@@ -56,7 +56,7 @@ public class MSKComponentVerifierExtensionTest extends CamelTestSupport {
}
@Test
- public void testConnectivity() throws Exception {
+ public void testConnectivity() {
Component component = context().getComponent("aws2-msk");
ComponentVerifierExtension verifier
= component.getExtension(ComponentVerifierExtension.class).orElseThrow(IllegalStateException::new);
@@ -74,7 +74,7 @@ public class MSKComponentVerifierExtensionTest extends CamelTestSupport {
}
@Test
- public void testConnectivityAndRegion() throws Exception {
+ public void testConnectivityAndRegion() {
Component component = context().getComponent("aws2-msk");
ComponentVerifierExtension verifier
= component.getExtension(ComponentVerifierExtension.class).orElseThrow(IllegalStateException::new);
diff --git a/components/camel-aws/camel-aws2-msk/src/test/java/org/apache/camel/component/aws2/msk/MSKProducerSpringTest.java b/components/camel-aws/camel-aws2-msk/src/test/java/org/apache/camel/component/aws2/msk/MSKProducerSpringTest.java
index 47f9fad..ea4ce94 100644
--- a/components/camel-aws/camel-aws2-msk/src/test/java/org/apache/camel/component/aws2/msk/MSKProducerSpringTest.java
+++ b/components/camel-aws/camel-aws2-msk/src/test/java/org/apache/camel/component/aws2/msk/MSKProducerSpringTest.java
@@ -44,7 +44,7 @@ public class MSKProducerSpringTest extends CamelSpringTestSupport {
mock.expectedMessageCount(1);
Exchange exchange = template.request("direct:listClusters", new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
}
});
@@ -61,7 +61,7 @@ public class MSKProducerSpringTest extends CamelSpringTestSupport {
mock.expectedMessageCount(1);
Exchange exchange = template.request("direct:listClustersPojo", new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setBody(ListClustersRequest.builder().maxResults(10).build());
}
});
@@ -79,7 +79,7 @@ public class MSKProducerSpringTest extends CamelSpringTestSupport {
mock.expectedMessageCount(1);
Exchange exchange = template.request("direct:createCluster", new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setHeader(MSK2Constants.CLUSTER_NAME, "test-kafka");
exchange.getIn().setHeader(MSK2Constants.CLUSTER_KAFKA_VERSION, "2.1.1");
exchange.getIn().setHeader(MSK2Constants.BROKER_NODES_NUMBER, 2);
@@ -101,7 +101,7 @@ public class MSKProducerSpringTest extends CamelSpringTestSupport {
mock.expectedMessageCount(1);
Exchange exchange = template.request("direct:deleteCluster", new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setHeader(MSK2Constants.CLUSTER_ARN, "test-kafka");
}
});
@@ -119,7 +119,7 @@ public class MSKProducerSpringTest extends CamelSpringTestSupport {
mock.expectedMessageCount(1);
Exchange exchange = template.request("direct:describeCluster", new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setHeader(MSK2Constants.CLUSTER_ARN, "test-kafka");
}
});
diff --git a/components/camel-aws/camel-aws2-msk/src/test/java/org/apache/camel/component/aws2/msk/MSKProducerTest.java b/components/camel-aws/camel-aws2-msk/src/test/java/org/apache/camel/component/aws2/msk/MSKProducerTest.java
index daab0d6..9341d6c 100644
--- a/components/camel-aws/camel-aws2-msk/src/test/java/org/apache/camel/component/aws2/msk/MSKProducerTest.java
+++ b/components/camel-aws/camel-aws2-msk/src/test/java/org/apache/camel/component/aws2/msk/MSKProducerTest.java
@@ -48,7 +48,7 @@ public class MSKProducerTest extends CamelTestSupport {
mock.expectedMessageCount(1);
Exchange exchange = template.request("direct:listClusters", new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
}
});
@@ -65,7 +65,7 @@ public class MSKProducerTest extends CamelTestSupport {
mock.expectedMessageCount(1);
Exchange exchange = template.request("direct:listClustersPojo", new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setBody(ListClustersRequest.builder().maxResults(10).build());
}
});
@@ -83,7 +83,7 @@ public class MSKProducerTest extends CamelTestSupport {
mock.expectedMessageCount(1);
Exchange exchange = template.request("direct:createCluster", new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setHeader(MSK2Constants.CLUSTER_NAME, "test-kafka");
exchange.getIn().setHeader(MSK2Constants.CLUSTER_KAFKA_VERSION, "2.1.1");
exchange.getIn().setHeader(MSK2Constants.BROKER_NODES_NUMBER, 2);
@@ -105,7 +105,7 @@ public class MSKProducerTest extends CamelTestSupport {
mock.expectedMessageCount(1);
Exchange exchange = template.request("direct:deleteCluster", new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setHeader(MSK2Constants.CLUSTER_ARN, "test-kafka");
}
});
@@ -123,7 +123,7 @@ public class MSKProducerTest extends CamelTestSupport {
mock.expectedMessageCount(1);
Exchange exchange = template.request("direct:describeCluster", new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setHeader(MSK2Constants.CLUSTER_ARN, "test-kafka");
}
});
@@ -136,10 +136,10 @@ public class MSKProducerTest 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:listClusters").to("aws2-msk://test?mskClient=#amazonMskClient&operation=listClusters")
.to("mock:result");
from("direct:listClustersPojo")