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 <[email protected]> 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")
