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 a85b2bccd613e2999c979e8b474e340db66175f9 Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Tue Mar 8 12:25:38 2022 +0100 CAMEL-17763: cleaned up unused exceptions in camel-cassandraql --- .../integration/CassandraComponentBeanRefIT.java | 6 +++--- .../integration/CassandraComponentConsumerIT.java | 8 ++++---- .../integration/CassandraComponentProducerIT.java | 19 +++++++++---------- .../CassandraComponentProducerUnpreparedIT.java | 12 ++++++------ .../aggregate/cassandra/CassandraAggregationIT.java | 4 ++-- .../CassandraAggregationSerializedHeadersIT.java | 4 ++-- .../idempotent/cassandra/CassandraIdempotentIT.java | 4 ++-- 7 files changed, 28 insertions(+), 29 deletions(-) diff --git a/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentBeanRefIT.java b/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentBeanRefIT.java index f9a5ecc..dfad578 100644 --- a/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentBeanRefIT.java +++ b/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentBeanRefIT.java @@ -30,14 +30,14 @@ public class CassandraComponentBeanRefIT extends BaseCassandra { public static final String SESSION_URI = "cql:bean:cassandraSession?cql=" + CQL; @Override - protected Registry createCamelRegistry() throws Exception { + protected Registry createCamelRegistry() { SimpleRegistry registry = new SimpleRegistry(); registry.bind("cassandraSession", getSession()); return registry; } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { public void configure() { from("direct:inputSession").to(SESSION_URI); @@ -46,7 +46,7 @@ public class CassandraComponentBeanRefIT extends BaseCassandra { } @Test - public void testSession() throws Exception { + public void testSession() { CassandraEndpoint endpoint = getMandatoryEndpoint(SESSION_URI, CassandraEndpoint.class); assertEquals(KEYSPACE_NAME, endpoint.getKeyspace()); diff --git a/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentConsumerIT.java b/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentConsumerIT.java index fc02803..28cad34 100644 --- a/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentConsumerIT.java +++ b/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentConsumerIT.java @@ -38,7 +38,7 @@ public class CassandraComponentConsumerIT extends BaseCassandra { mock.expectedMinimumMessageCount(1); mock.whenAnyExchangeReceived(new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { Object body = exchange.getIn().getBody(); assertTrue(body instanceof List); } @@ -53,7 +53,7 @@ public class CassandraComponentConsumerIT extends BaseCassandra { mock.expectedMinimumMessageCount(1); mock.whenAnyExchangeReceived(new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { Object body = exchange.getIn().getBody(); assertTrue(body instanceof List); } @@ -68,7 +68,7 @@ public class CassandraComponentConsumerIT extends BaseCassandra { mock.expectedMinimumMessageCount(1); mock.whenAnyExchangeReceived(new Processor() { @Override - public void process(Exchange exchange) throws Exception { + public void process(Exchange exchange) { Object body = exchange.getIn().getBody(); assertTrue(body instanceof Row); } @@ -79,7 +79,7 @@ public class CassandraComponentConsumerIT extends BaseCassandra { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { public void configure() { from(String.format("cql://%s/%s?cql=%s", getUrl(), KEYSPACE_NAME, CQL)).to("mock:resultAll"); diff --git a/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentProducerIT.java b/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentProducerIT.java index 6545c11..9e1a357 100644 --- a/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentProducerIT.java +++ b/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentProducerIT.java @@ -38,7 +38,6 @@ import static com.datastax.oss.driver.api.querybuilder.QueryBuilder.bindMarker; import static org.apache.camel.test.junit5.TestSupport.assertIsInstanceOf; import static org.junit.jupiter.api.Assertions.assertEquals; import static org.junit.jupiter.api.Assertions.assertNotNull; -import static org.junit.jupiter.api.Assertions.assertTrue; public class CassandraComponentProducerIT extends BaseCassandra { @@ -61,7 +60,7 @@ public class CassandraComponentProducerIT extends BaseCassandra { ProducerTemplate producerTemplateNoEndpointCql; @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { public void configure() { @@ -79,7 +78,7 @@ public class CassandraComponentProducerIT extends BaseCassandra { } @Test - public void testRequestUriCql() throws Exception { + public void testRequestUriCql() { producerTemplate.requestBody(Arrays.asList("w_jiang", "Willem", "Jiang")); ResultSet resultSet = getSession() @@ -91,7 +90,7 @@ public class CassandraComponentProducerIT extends BaseCassandra { } @Test - public void testRequestNoParameterNull() throws Exception { + public void testRequestNoParameterNull() { Object response = noParameterProducerTemplate.requestBody(null); assertNotNull(response); @@ -99,7 +98,7 @@ public class CassandraComponentProducerIT extends BaseCassandra { } @Test - public void testRequestNoParameterEmpty() throws Exception { + public void testRequestNoParameterEmpty() { Object response = noParameterProducerTemplate.requestBody(Collections.emptyList()); assertNotNull(response); @@ -107,7 +106,7 @@ public class CassandraComponentProducerIT extends BaseCassandra { } @Test - public void testRequestMessageCql() throws Exception { + public void testRequestMessageCql() { producerTemplate.requestBodyAndHeader(new Object[] { "Claus 2", "Ibsen 2", "c_ibsen" }, CassandraConstants.CQL_QUERY, "update camel_user set first_name=?, last_name=? where login=?"); @@ -120,7 +119,7 @@ public class CassandraComponentProducerIT extends BaseCassandra { } @Test - public void testLoadBalancing() throws Exception { + public void testLoadBalancing() { loadBalancingPolicyTemplate.requestBodyAndHeader(new Object[] { "Claus 2", "Ibsen 2", "c_ibsen" }, CassandraConstants.CQL_QUERY, "update camel_user set first_name=?, last_name=? where login=?"); @@ -139,7 +138,7 @@ public class CassandraComponentProducerIT extends BaseCassandra { * Test with incoming message containing a header with RegularStatement. */ @Test - public void testRequestMessageStatement() throws Exception { + public void testRequestMessageStatement() { Update update = QueryBuilder.update("camel_user") .setColumn("first_name", bindMarker()) @@ -161,7 +160,7 @@ public class CassandraComponentProducerIT extends BaseCassandra { * the cassandracql endpoint not containing a "cql" Uri parameter */ @Test - public void testEndpointNoCqlParameter() throws Exception { + public void testEndpointNoCqlParameter() { Update update = QueryBuilder.update("camel_user") .setColumn("first_name", bindMarker()) .whereColumn("login").isEqualTo(bindMarker()); @@ -190,7 +189,7 @@ public class CassandraComponentProducerIT extends BaseCassandra { } @Test - public void testRequestNotConsistent() throws Exception { + public void testRequestNotConsistent() { CassandraEndpoint endpoint = getMandatoryEndpoint(String.format("cql://%s/%s?cql=%s&consistencyLevel=ANY", getUrl(), KEYSPACE_NAME, CQL), CassandraEndpoint.class); diff --git a/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentProducerUnpreparedIT.java b/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentProducerUnpreparedIT.java index 9364647..16ce29e 100644 --- a/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentProducerUnpreparedIT.java +++ b/components/camel-cassandraql/src/test/java/org/apache/camel/component/cassandra/integration/CassandraComponentProducerUnpreparedIT.java @@ -46,7 +46,7 @@ public class CassandraComponentProducerUnpreparedIT extends BaseCassandra { ProducerTemplate noParameterProducerTemplate; @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { public void configure() { @@ -59,7 +59,7 @@ public class CassandraComponentProducerUnpreparedIT extends BaseCassandra { } @Test - public void testRequestUriCql() throws Exception { + public void testRequestUriCql() { producerTemplate.requestBody(Arrays.asList("w_jiang", "Willem", "Jiang")); ResultSet resultSet = getSession() @@ -71,7 +71,7 @@ public class CassandraComponentProducerUnpreparedIT extends BaseCassandra { } @Test - public void testRequestNoParameterNull() throws Exception { + public void testRequestNoParameterNull() { Object response = noParameterProducerTemplate.requestBody(null); assertNotNull(response); @@ -79,7 +79,7 @@ public class CassandraComponentProducerUnpreparedIT extends BaseCassandra { } @Test - public void testRequestNoParameterEmpty() throws Exception { + public void testRequestNoParameterEmpty() { Object response = noParameterProducerTemplate.requestBody(null); assertNotNull(response); @@ -87,7 +87,7 @@ public class CassandraComponentProducerUnpreparedIT extends BaseCassandra { } @Test - public void testRequestMessageCql() throws Exception { + public void testRequestMessageCql() { producerTemplate.requestBodyAndHeader(new Object[] { "Claus 2", "Ibsen 2", "c_ibsen" }, CassandraConstants.CQL_QUERY, "update camel_user set first_name=?, last_name=? where login=?"); @@ -103,7 +103,7 @@ public class CassandraComponentProducerUnpreparedIT extends BaseCassandra { * Test with incoming message containing a header with RegularStatement. */ @Test - public void testRequestMessageStatement() throws Exception { + public void testRequestMessageStatement() { Update update = QueryBuilder.update("camel_user") .setColumn("first_name", literal("Claus 2")) .setColumn("last_name", literal("Ibsen 2")) diff --git a/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationIT.java b/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationIT.java index 2f87a4a..82701ea 100644 --- a/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationIT.java +++ b/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationIT.java @@ -47,10 +47,10 @@ public class CassandraAggregationIT extends BaseCassandra { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { AggregationStrategy aggregationStrategy = new AggregationStrategy() { @Override public Exchange aggregate(Exchange oldExchange, Exchange newExchange) { diff --git a/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationSerializedHeadersIT.java b/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationSerializedHeadersIT.java index b17aa3c..0f845ad 100644 --- a/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationSerializedHeadersIT.java +++ b/components/camel-cassandraql/src/test/java/org/apache/camel/processor/aggregate/cassandra/CassandraAggregationSerializedHeadersIT.java @@ -49,10 +49,10 @@ public class CassandraAggregationSerializedHeadersIT extends BaseCassandra { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { AggregationStrategy aggregationStrategy = new AggregationStrategy() { @Override public Exchange aggregate(Exchange oldExchange, Exchange newExchange) { diff --git a/components/camel-cassandraql/src/test/java/org/apache/camel/processor/idempotent/cassandra/CassandraIdempotentIT.java b/components/camel-cassandraql/src/test/java/org/apache/camel/processor/idempotent/cassandra/CassandraIdempotentIT.java index 156471b..1f5ca44 100644 --- a/components/camel-cassandraql/src/test/java/org/apache/camel/processor/idempotent/cassandra/CassandraIdempotentIT.java +++ b/components/camel-cassandraql/src/test/java/org/apache/camel/processor/idempotent/cassandra/CassandraIdempotentIT.java @@ -45,10 +45,10 @@ public class CassandraIdempotentIT extends BaseCassandra { } @Override - protected RouteBuilder createRouteBuilder() throws Exception { + protected RouteBuilder createRouteBuilder() { return new RouteBuilder() { @Override - public void configure() throws Exception { + public void configure() { from("direct:input").idempotentConsumer(header("idempotentId"), idempotentRepository).to("mock:output"); } };
