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 12:51:41 UTC
[camel] branch main updated (15e8270 -> 79bafda)
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git.
from 15e8270 Regen for commit b470ece4ca9cc110a9e31c99c2d79fd422f2bb9f
new 5b99429 CAMEL-17763: cleaned up unused exceptions in camel-activemq
new 81d8f2e CAMEL-17763: cleaned up unused exceptions in camel-ahc
new 9a4d355 CAMEL-17763: cleaned up unused exceptions in camel-kafka
new af8093c CAMEL-17763: cleaned up unused exceptions in camel-amqp
new a85b2bc CAMEL-17763: cleaned up unused exceptions in camel-cassandraql
new 7d6bdd0 CAMEL-17763: cleaned up unused exceptions in camel-couchbase
new 39adbd2 CAMEL-17763: cleaned up unused exceptions in camel-couchdb
new 5a8a7fd CAMEL-17763: cleaned up unused exceptions in camel-mongodb
new 79bafda CAMEL-17763: cleaned up unused exceptions in camel-elasticsearch-rest
The 9 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../camel/component/activemq/AMQ2611Test.java | 4 +--
.../component/activemq/ActiveMQConfigureTest.java | 2 +-
.../activemq/ActiveMQJmsHeaderRouteForceTest.java | 4 +--
.../activemq/ActiveMQJmsHeaderRouteTest.java | 6 ++--
.../activemq/ActiveMQOriginalDestinationTest.java | 4 +--
.../ActiveMQReplyToHeaderUsingConverterTest.java | 4 +--
.../component/activemq/ActiveMQRouteTest.java | 4 +--
.../activemq/ActiveMQToDSendDynamicTwoTest.java | 6 ++--
.../activemq/AdvisoryConsumerExampleTest.java | 6 ++--
.../activemq/CamelVMTransportRoutingTest.java | 2 +-
.../activemq/ComplexRequestReplyTest.java | 4 +--
...nvokeRequestReplyUsingJmsReplyToHeaderTest.java | 4 +--
.../activemq/JmsSimpleRequestReplyTest.java | 2 +-
.../camel/component/activemq/SetHeaderTest.java | 2 +-
.../component/activemq/TransactedConsumeTest.java | 2 +-
.../converter/InvokeJmsMessageListenerTest.java | 4 +--
.../converter/InvokeMessageListenerTest.java | 4 +--
.../ahc/AhcBridgeEndpointPathWithSpacesTest.java | 8 ++---
.../camel/component/ahc/AhcBridgeEndpointTest.java | 8 ++---
.../component/ahc/AhcClientConfigRealmUriTest.java | 6 ++--
.../component/ahc/AhcClientConfigUriTest.java | 6 ++--
.../ahc/AhcComponentClientConfigTest.java | 6 ++--
.../ahc/AhcComponentCustomClientConfigTest.java | 6 ++--
.../ahc/AhcComponentNettyClientConfigTest.java | 6 ++--
.../apache/camel/component/ahc/AhcGoogleTest.java | 4 +--
.../camel/component/ahc/AhcProduce500Test.java | 6 ++--
.../component/ahc/AhcProduceClientConfigTest.java | 6 ++--
.../component/ahc/AhcProduceGetHeadersTest.java | 4 +--
.../ahc/AhcProduceGetNoSlashInUriTest.java | 4 +--
.../camel/component/ahc/AhcProduceGetTest.java | 6 ++--
.../AhcProduceNoThrowExceptionOnFailureTest.java | 6 ++--
.../component/ahc/AhcProducePostDoWhileTest.java | 4 +--
.../component/ahc/AhcProducePostHeadersTest.java | 4 +--
.../camel/component/ahc/AhcProducePostTest.java | 6 ++--
.../ahc/AhcProduceTransferExceptionTest.java | 4 +--
...hcProduceWithClientConfigUriParametersTest.java | 6 ++--
.../ahc/AhcProducerConnectionCloseHeadersTest.java | 4 +--
.../component/ahc/AhcProducerSessionTest.java | 6 ++--
.../AhcProducerTwoParametersWithSameKeyTest.java | 12 +++----
.../apache/camel/component/ahc/BaseAhcTest.java | 2 +-
.../ahc/javabody/AhcProduceJavaBodyTest.java | 20 +++++------
.../apache/camel/component/amqp/AMQPRouteTest.java | 2 +-
.../component/amqp/AMQPRouteTraceFrameTest.java | 2 +-
.../component/amqp/AMQPToDSendDynamicTest.java | 4 +--
.../apache/camel/component/amqp/AMQPToDTest.java | 2 +-
.../integration/CassandraComponentBeanRefIT.java | 6 ++--
.../integration/CassandraComponentConsumerIT.java | 8 ++---
.../integration/CassandraComponentProducerIT.java | 19 +++++-----
.../CassandraComponentProducerUnpreparedIT.java | 12 +++----
.../cassandra/CassandraAggregationIT.java | 4 +--
.../CassandraAggregationSerializedHeadersIT.java | 4 +--
.../cassandra/CassandraIdempotentIT.java | 4 +--
.../component/couchbase/CouchbaseEndpointTest.java | 8 ++---
.../component/couchbase/CouchbaseProducerTest.java | 12 +++----
.../integration/ConsumeMessagesWithLimitIT.java | 4 +--
.../integration/ProduceMessagesSimpleIT.java | 2 +-
.../integration/ProduceMessagesWithAutoIDIT.java | 4 +--
.../couchbase/integration/RemoveMessagesIT.java | 4 +--
.../component/couchdb/CouchDbProducerTest.java | 2 +-
...icsearchRestComponentVerifierExtensionTest.java | 4 +--
.../integration/ElasticsearchBulkIT.java | 10 +++---
.../integration/ElasticsearchClusterIndexIT.java | 2 +-
...ElasticsearchGetSearchDeleteExistsUpdateIT.java | 30 ++++++++--------
.../integration/ElasticsearchIndexIT.java | 12 +++----
.../integration/ElasticsearchPingIT.java | 4 +--
.../camel/component/kafka/KafkaComponentTest.java | 8 ++---
.../camel/component/kafka/KafkaConsumerTest.java | 4 +--
.../camel/component/kafka/KafkaProducerTest.java | 4 +--
.../KafkaConsumerAsyncManualCommitIT.java | 2 +-
.../integration/KafkaConsumerBatchSizeIT.java | 4 +--
.../kafka/integration/KafkaConsumerFullIT.java | 7 ++--
.../integration/KafkaConsumerHealthCheckIT.java | 5 ++-
.../integration/KafkaConsumerIdempotentIT.java | 8 ++---
...kaConsumerIdempotentWithCustomSerializerIT.java | 6 ++--
.../KafkaConsumerIdempotentWithProcessorIT.java | 8 ++---
.../KafkaConsumerLastRecordHeaderIT.java | 4 +--
.../integration/KafkaConsumerManualCommitIT.java | 4 +--
.../integration/KafkaConsumerRebalanceIT.java | 6 ++--
.../integration/KafkaConsumerTopicIsPatternIT.java | 4 +--
.../KafkaConsumerWithResumeRouteStrategyIT.java | 4 +--
.../kafka/integration/KafkaProducerFullIT.java | 15 ++++----
.../component/kafka/integration/KafkaToDIT.java | 6 ++--
.../kafka/KafkaIdempotentRepositoryEagerIT.java | 8 ++---
.../kafka/KafkaIdempotentRepositoryNonEagerIT.java | 8 ++---
.../KafkaIdempotentRepositoryPersistenceIT.java | 2 +-
.../mongodb/MongoDbEndpointClientTest.java | 6 ++--
.../mongodb/MongoDbEndpointHostsTest.java | 4 +--
.../integration/MongoDbAggregateOperationIT.java | 4 +--
.../integration/MongoDbBigDecimalConverterIT.java | 2 +-
.../integration/MongoDbBulkWriteOperationIT.java | 8 ++---
.../integration/MongoDbConnectionBeansIT.java | 2 +-
.../mongodb/integration/MongoDbConversionsIT.java | 8 ++---
.../MongoDbCredentialsFromUriConnectionIT.java | 4 +--
.../mongodb/integration/MongoDbDynamicityIT.java | 2 +-
.../integration/MongoDbExceptionHandlingIT.java | 8 ++---
.../integration/MongoDbFindOperationIT.java | 22 ++++++------
.../integration/MongoDbHeaderHandlingIT.java | 10 +++---
.../mongodb/integration/MongoDbIndexIT.java | 2 +-
.../mongodb/integration/MongoDbInsertBatchIT.java | 2 +-
.../mongodb/integration/MongoDbOperationsIT.java | 40 +++++++++++-----------
.../mongodb/integration/MongoDbOutputTypeIT.java | 6 ++--
.../integration/MongoDbSpringDslOperationsIT.java | 4 +--
.../mongodb/integration/MongoDbStopEndpointIT.java | 4 +--
.../MongoDbTailableCursorConsumerIT.java | 2 +-
.../meta/integration/MongoDbMetaExtensionIT.java | 2 +-
.../integration/MongoDbIdempotentRepositoryIT.java | 14 ++++----
106 files changed, 321 insertions(+), 331 deletions(-)
[camel] 04/09: CAMEL-17763: cleaned up unused exceptions in camel-amqp
Posted by or...@apache.org.
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 af8093c3ea32e39982e956d3d3fa82d9af25ad50
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Mar 8 12:21:09 2022 +0100
CAMEL-17763: cleaned up unused exceptions in camel-amqp
---
.../src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java | 2 +-
.../java/org/apache/camel/component/amqp/AMQPRouteTraceFrameTest.java | 2 +-
.../java/org/apache/camel/component/amqp/AMQPToDSendDynamicTest.java | 4 ++--
.../src/test/java/org/apache/camel/component/amqp/AMQPToDTest.java | 2 +-
4 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java b/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java
index 334ec84..f67a32b 100644
--- a/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java
+++ b/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java
@@ -60,7 +60,7 @@ public class AMQPRouteTest extends CamelTestSupport {
String expectedBody = "Hello there!";
@BeforeAll
- public static void beforeClass() throws Exception {
+ public static void beforeClass() {
System.setProperty(AMQPConnectionDetails.AMQP_PORT, amqpPort + "");
}
diff --git a/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTraceFrameTest.java b/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTraceFrameTest.java
index ef8193a..4fe08c8 100644
--- a/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTraceFrameTest.java
+++ b/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTraceFrameTest.java
@@ -48,7 +48,7 @@ public class AMQPRouteTraceFrameTest extends CamelTestSupport {
String expectedBody = "Hello there!";
@BeforeAll
- public static void beforeClass() throws Exception {
+ public static void beforeClass() {
System.setProperty(AMQP_PORT, amqpPort + "");
}
diff --git a/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPToDSendDynamicTest.java b/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPToDSendDynamicTest.java
index b8e6305..b70f696 100644
--- a/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPToDSendDynamicTest.java
+++ b/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPToDSendDynamicTest.java
@@ -41,12 +41,12 @@ public class AMQPToDSendDynamicTest extends CamelTestSupport {
.build();
@BeforeAll
- public static void beforeClass() throws Exception {
+ public static void beforeClass() {
System.setProperty(AMQP_PORT, amqpPort + "");
}
@Test
- public void testToD() throws Exception {
+ public void testToD() {
template.sendBodyAndHeader("direct:start", "Hello bar", "where", "bar");
template.sendBodyAndHeader("direct:start", "Hello beer", "where", "beer");
diff --git a/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPToDTest.java b/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPToDTest.java
index 3396449..3b41232 100644
--- a/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPToDTest.java
+++ b/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPToDTest.java
@@ -40,7 +40,7 @@ public class AMQPToDTest extends CamelTestSupport {
.build();
@BeforeAll
- public static void beforeClass() throws Exception {
+ public static void beforeClass() {
System.setProperty(AMQP_PORT, amqpPort + "");
}
[camel] 09/09: CAMEL-17763: cleaned up unused exceptions in camel-elasticsearch-rest
Posted by or...@apache.org.
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 79bafda16a213ffec7191c38d7b787bbd6655ec0
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Mar 8 12:42:13 2022 +0100
CAMEL-17763: cleaned up unused exceptions in camel-elasticsearch-rest
---
...icsearchRestComponentVerifierExtensionTest.java | 4 +--
.../integration/ElasticsearchBulkIT.java | 10 ++++----
.../integration/ElasticsearchClusterIndexIT.java | 2 +-
...ElasticsearchGetSearchDeleteExistsUpdateIT.java | 30 +++++++++++-----------
.../integration/ElasticsearchIndexIT.java | 12 ++++-----
.../integration/ElasticsearchPingIT.java | 4 +--
6 files changed, 31 insertions(+), 31 deletions(-)
diff --git a/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/ElasticsearchRestComponentVerifierExtensionTest.java b/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/ElasticsearchRestComponentVerifierExtensionTest.java
index 494efee..19b3ce8 100644
--- a/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/ElasticsearchRestComponentVerifierExtensionTest.java
+++ b/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/ElasticsearchRestComponentVerifierExtensionTest.java
@@ -33,7 +33,7 @@ public class ElasticsearchRestComponentVerifierExtensionTest extends CamelTestSu
}
@Test
- public void testParameters() throws Exception {
+ public void testParameters() {
Component component = context().getComponent("elasticsearch-rest");
ComponentVerifierExtension verifier
@@ -49,7 +49,7 @@ public class ElasticsearchRestComponentVerifierExtensionTest extends CamelTestSu
}
@Test
- public void testConnectivity() throws Exception {
+ public void testConnectivity() {
Component component = context().getComponent("elasticsearch-rest");
ComponentVerifierExtension verifier
= component.getExtension(ComponentVerifierExtension.class).orElseThrow(IllegalStateException::new);
diff --git a/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchBulkIT.java b/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchBulkIT.java
index 3d60eca..df5e361 100644
--- a/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchBulkIT.java
+++ b/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchBulkIT.java
@@ -37,7 +37,7 @@ import static org.junit.jupiter.api.Assertions.assertNotNull;
public class ElasticsearchBulkIT extends ElasticsearchTestSupport {
@Test
- public void testBulkIndex() throws Exception {
+ public void testBulkIndex() {
List<Map<String, String>> documents = new ArrayList<>();
Map<String, String> document1 = createIndexedData("1");
Map<String, String> document2 = createIndexedData("2");
@@ -51,7 +51,7 @@ public class ElasticsearchBulkIT extends ElasticsearchTestSupport {
}
@Test
- public void bulkIndexListRequestBody() throws Exception {
+ public void bulkIndexListRequestBody() {
String prefix = createPrefix();
// given
@@ -70,7 +70,7 @@ public class ElasticsearchBulkIT extends ElasticsearchTestSupport {
}
@Test
- public void bulkIndexRequestBody() throws Exception {
+ public void bulkIndexRequestBody() {
String prefix = createPrefix();
// given
@@ -90,7 +90,7 @@ public class ElasticsearchBulkIT extends ElasticsearchTestSupport {
}
@Test
- public void bulkRequestBody() throws Exception {
+ public void bulkRequestBody() {
String prefix = createPrefix();
// given
@@ -107,7 +107,7 @@ public class ElasticsearchBulkIT extends ElasticsearchTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
diff --git a/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchClusterIndexIT.java b/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchClusterIndexIT.java
index b77e6a8..cddeae3 100644
--- a/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchClusterIndexIT.java
+++ b/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchClusterIndexIT.java
@@ -72,7 +72,7 @@ public class ElasticsearchClusterIndexIT extends ElasticsearchTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
diff --git a/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchGetSearchDeleteExistsUpdateIT.java b/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchGetSearchDeleteExistsUpdateIT.java
index 911b736..4c6e17b 100644
--- a/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchGetSearchDeleteExistsUpdateIT.java
+++ b/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchGetSearchDeleteExistsUpdateIT.java
@@ -46,7 +46,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
public class ElasticsearchGetSearchDeleteExistsUpdateIT extends ElasticsearchTestSupport {
@Test
- public void testGet() throws Exception {
+ public void testGet() {
//first, Index a value
Map<String, String> map = createIndexedData();
sendBody("direct:index", map);
@@ -60,7 +60,7 @@ public class ElasticsearchGetSearchDeleteExistsUpdateIT extends ElasticsearchTes
}
@Test
- public void testDelete() throws Exception {
+ public void testDelete() {
//first, Index a value
Map<String, String> map = createIndexedData();
sendBody("direct:index", map);
@@ -83,7 +83,7 @@ public class ElasticsearchGetSearchDeleteExistsUpdateIT extends ElasticsearchTes
}
@Test
- public void testSearchWithMapQuery() throws Exception {
+ public void testSearchWithMapQuery() {
//first, Index a value
Map<String, String> map = createIndexedData();
String indexId = template.requestBody("direct:index", map, String.class);
@@ -106,7 +106,7 @@ public class ElasticsearchGetSearchDeleteExistsUpdateIT extends ElasticsearchTes
}
@Test
- public void testSearchWithStringQuery() throws Exception {
+ public void testSearchWithStringQuery() {
//first, Index a value
Map<String, String> map = createIndexedData();
String indexId = template.requestBody("direct:index", map, String.class);
@@ -132,7 +132,7 @@ public class ElasticsearchGetSearchDeleteExistsUpdateIT extends ElasticsearchTes
}
@Test
- public void testMultiSearch() throws Exception {
+ public void testMultiSearch() {
//first, Index a value
Map<String, String> map = createIndexedData();
String indexId = template.requestBody("direct:index", map, String.class);
@@ -156,7 +156,7 @@ public class ElasticsearchGetSearchDeleteExistsUpdateIT extends ElasticsearchTes
}
@Test
- public void testUpdate() throws Exception {
+ public void testUpdate() {
Map<String, String> map = createIndexedData();
String indexId = template.requestBody("direct:index", map, String.class);
assertNotNull(indexId, "indexId should be set");
@@ -170,7 +170,7 @@ public class ElasticsearchGetSearchDeleteExistsUpdateIT extends ElasticsearchTes
}
@Test
- public void testGetWithHeaders() throws Exception {
+ public void testGetWithHeaders() {
//first, Index a value
Map<String, String> map = createIndexedData();
Map<String, Object> headers = new HashMap<>();
@@ -187,7 +187,7 @@ public class ElasticsearchGetSearchDeleteExistsUpdateIT extends ElasticsearchTes
}
@Test
- public void testExistsWithHeaders() throws Exception {
+ public void testExistsWithHeaders() {
//first, Index a value
Map<String, String> map = createIndexedData();
Map<String, Object> headers = new HashMap<>();
@@ -205,7 +205,7 @@ public class ElasticsearchGetSearchDeleteExistsUpdateIT extends ElasticsearchTes
}
@Test
- public void testNotExistsWithHeaders() throws Exception {
+ public void testNotExistsWithHeaders() {
//first, Index a value
Map<String, String> map = createIndexedData();
Map<String, Object> headers = new HashMap<>();
@@ -223,7 +223,7 @@ public class ElasticsearchGetSearchDeleteExistsUpdateIT extends ElasticsearchTes
}
@Test
- public void testDeleteWithHeaders() throws Exception {
+ public void testDeleteWithHeaders() {
//first, Index a value
Map<String, String> map = createIndexedData();
Map<String, Object> headers = new HashMap<>();
@@ -252,7 +252,7 @@ public class ElasticsearchGetSearchDeleteExistsUpdateIT extends ElasticsearchTes
}
@Test
- public void testUpdateWithIDInHeader() throws Exception {
+ public void testUpdateWithIDInHeader() {
Map<String, String> map = createIndexedData();
Map<String, Object> headers = new HashMap<>();
headers.put(ElasticsearchConstants.PARAM_OPERATION, ElasticsearchOperation.Index);
@@ -271,7 +271,7 @@ public class ElasticsearchGetSearchDeleteExistsUpdateIT extends ElasticsearchTes
}
@Test
- public void getRequestBody() throws Exception {
+ public void getRequestBody() {
String prefix = createPrefix();
// given
@@ -292,7 +292,7 @@ public class ElasticsearchGetSearchDeleteExistsUpdateIT extends ElasticsearchTes
}
@Test
- public void deleteRequestBody() throws Exception {
+ public void deleteRequestBody() {
String prefix = createPrefix();
// given
@@ -311,7 +311,7 @@ public class ElasticsearchGetSearchDeleteExistsUpdateIT extends ElasticsearchTes
}
@Test
- public void testStringUpdate() throws Exception {
+ public void testStringUpdate() {
Map<String, String> map = createIndexedData();
String indexId = template.requestBody("direct:index", map, String.class);
assertNotNull(indexId, "indexId should be set");
@@ -328,7 +328,7 @@ public class ElasticsearchGetSearchDeleteExistsUpdateIT extends ElasticsearchTes
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
diff --git a/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchIndexIT.java b/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchIndexIT.java
index c667548..850c1b6 100644
--- a/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchIndexIT.java
+++ b/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchIndexIT.java
@@ -31,14 +31,14 @@ import static org.junit.jupiter.api.Assertions.assertNotNull;
public class ElasticsearchIndexIT extends ElasticsearchTestSupport {
@Test
- public void testIndex() throws Exception {
+ public void testIndex() {
Map<String, String> map = createIndexedData();
String indexId = template.requestBody("direct:index", map, String.class);
assertNotNull(indexId, "indexId should be set");
}
@Test
- public void testIndexDelete() throws Exception {
+ public void testIndexDelete() {
Map<String, String> map = createIndexedData();
String indexId = template.requestBody("direct:index", map, String.class);
assertNotNull(indexId, "indexId should be set");
@@ -49,14 +49,14 @@ public class ElasticsearchIndexIT extends ElasticsearchTestSupport {
}
@Test
- public void testIndexWithReplication() throws Exception {
+ public void testIndexWithReplication() {
Map<String, String> map = createIndexedData();
String indexId = template.requestBody("direct:indexWithReplication", map, String.class);
assertNotNull(indexId, "indexId should be set");
}
@Test
- public void testIndexWithHeaders() throws Exception {
+ public void testIndexWithHeaders() {
Map<String, String> map = createIndexedData();
Map<String, Object> headers = new HashMap<>();
headers.put(ElasticsearchConstants.PARAM_OPERATION, ElasticsearchOperation.Index);
@@ -67,7 +67,7 @@ public class ElasticsearchIndexIT extends ElasticsearchTestSupport {
}
@Test
- public void testIndexWithIDInHeader() throws Exception {
+ public void testIndexWithIDInHeader() {
Map<String, String> map = createIndexedData();
Map<String, Object> headers = new HashMap<>();
headers.put(ElasticsearchConstants.PARAM_OPERATION, ElasticsearchOperation.Index);
@@ -80,7 +80,7 @@ public class ElasticsearchIndexIT extends ElasticsearchTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
diff --git a/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchPingIT.java b/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchPingIT.java
index 312fd76..689827d 100644
--- a/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchPingIT.java
+++ b/components/camel-elasticsearch-rest/src/test/java/org/apache/camel/component/elasticsearch/integration/ElasticsearchPingIT.java
@@ -24,13 +24,13 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
public class ElasticsearchPingIT extends ElasticsearchTestSupport {
@Test
- public void testPing() throws Exception {
+ public void testPing() {
boolean pingResult = template.requestBody("direct:ping", "test", Boolean.class);
assertTrue(pingResult, "indexId should be set");
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
[camel] 01/09: CAMEL-17763: cleaned up unused exceptions in camel-activemq
Posted by or...@apache.org.
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 5b9942947ccdb38d1bc900d68266226f987125c5
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Mar 8 11:55:41 2022 +0100
CAMEL-17763: cleaned up unused exceptions in camel-activemq
---
.../test/java/org/apache/camel/component/activemq/AMQ2611Test.java | 4 ++--
.../org/apache/camel/component/activemq/ActiveMQConfigureTest.java | 2 +-
.../camel/component/activemq/ActiveMQJmsHeaderRouteForceTest.java | 4 ++--
.../apache/camel/component/activemq/ActiveMQJmsHeaderRouteTest.java | 6 +++---
.../camel/component/activemq/ActiveMQOriginalDestinationTest.java | 4 ++--
.../component/activemq/ActiveMQReplyToHeaderUsingConverterTest.java | 4 ++--
.../java/org/apache/camel/component/activemq/ActiveMQRouteTest.java | 4 ++--
.../camel/component/activemq/ActiveMQToDSendDynamicTwoTest.java | 6 +++---
.../camel/component/activemq/AdvisoryConsumerExampleTest.java | 6 +++---
.../camel/component/activemq/CamelVMTransportRoutingTest.java | 2 +-
.../apache/camel/component/activemq/ComplexRequestReplyTest.java | 4 ++--
.../activemq/InvokeRequestReplyUsingJmsReplyToHeaderTest.java | 4 ++--
.../apache/camel/component/activemq/JmsSimpleRequestReplyTest.java | 2 +-
.../java/org/apache/camel/component/activemq/SetHeaderTest.java | 2 +-
.../org/apache/camel/component/activemq/TransactedConsumeTest.java | 2 +-
.../component/activemq/converter/InvokeJmsMessageListenerTest.java | 4 ++--
.../component/activemq/converter/InvokeMessageListenerTest.java | 4 ++--
17 files changed, 32 insertions(+), 32 deletions(-)
diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/AMQ2611Test.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/AMQ2611Test.java
index c791826..f96547a 100644
--- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/AMQ2611Test.java
+++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/AMQ2611Test.java
@@ -62,7 +62,7 @@ public class AMQ2611Test implements ActiveMQSupport {
final String queueEndpointName = "activemq:queue" + QUEUE_NAME;
camelContext.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(queueEndpointName).bean(Consumer.class, "consume");
}
});
@@ -86,7 +86,7 @@ public class AMQ2611Test implements ActiveMQSupport {
producerTemplate.sendBody(queueEndpointName, "message");
}
- private void destroyCamelContext() throws Exception {
+ private void destroyCamelContext() {
LOG.info("destroying context");
camelContext.stop();
camelContext = null;
diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQConfigureTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQConfigureTest.java
index d572909..00d5963 100644
--- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQConfigureTest.java
+++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQConfigureTest.java
@@ -63,7 +63,7 @@ public class ActiveMQConfigureTest extends ActiveMQTestSupport {
}
@Test
- public void testSessionTransactedWithoutTransactionManager() throws Exception {
+ public void testSessionTransactedWithoutTransactionManager() {
JmsEndpoint endpoint = resolveMandatoryEndpoint("activemq:test.foo?transacted=true&lazyCreateTransactionManager=false");
JmsConfiguration configuration = endpoint.getConfiguration();
diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQJmsHeaderRouteForceTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQJmsHeaderRouteForceTest.java
index a606af9..f4061ef 100644
--- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQJmsHeaderRouteForceTest.java
+++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQJmsHeaderRouteForceTest.java
@@ -29,9 +29,9 @@ import static org.apache.camel.test.junit5.TestSupport.assertIsInstanceOf;
public class ActiveMQJmsHeaderRouteForceTest extends ActiveMQJmsHeaderRouteTest {
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
// do not map jms message as we want to tamper with the JMS
// message directly, and not use the Camel API for that
from("activemq:test.a?mapJmsMessage=false").process(new Processor() {
diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQJmsHeaderRouteTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQJmsHeaderRouteTest.java
index 53ca137..3be327d 100644
--- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQJmsHeaderRouteTest.java
+++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQJmsHeaderRouteTest.java
@@ -85,11 +85,11 @@ public class ActiveMQJmsHeaderRouteTest extends ActiveMQTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:test.a").process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
// lets set the custom JMS headers using the Camel API
exchange.getIn().setHeader("JMSReplyTo", replyQueue);
exchange.getIn().setHeader("JMSCorrelationID", correlationID);
diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQOriginalDestinationTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQOriginalDestinationTest.java
index 8aa2ffc..5f5fe27 100644
--- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQOriginalDestinationTest.java
+++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQOriginalDestinationTest.java
@@ -66,10 +66,10 @@ public class ActiveMQOriginalDestinationTest extends ActiveMQTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("activemq:queue:foo").to("activemq:queue:bar").to("mock:result");
}
};
diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQReplyToHeaderUsingConverterTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQReplyToHeaderUsingConverterTest.java
index 9c2b9b1..4b3a4f3 100644
--- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQReplyToHeaderUsingConverterTest.java
+++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQReplyToHeaderUsingConverterTest.java
@@ -107,9 +107,9 @@ public class ActiveMQReplyToHeaderUsingConverterTest extends ActiveMQTestSupport
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("activemq:test.a").to("activemq:test.b?preserveMessageQos=true");
from("activemq:test.b").to("mock:result");
diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQRouteTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQRouteTest.java
index de756f7..32c53ab 100644
--- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQRouteTest.java
+++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQRouteTest.java
@@ -70,9 +70,9 @@ public class ActiveMQRouteTest extends ActiveMQTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(startEndpointUri).to("activemq:queue:test.b");
from("activemq:queue:test.b").to("mock:result");
diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQToDSendDynamicTwoTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQToDSendDynamicTwoTest.java
index 3959d99..7356f15 100644
--- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQToDSendDynamicTwoTest.java
+++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ActiveMQToDSendDynamicTwoTest.java
@@ -26,7 +26,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class ActiveMQToDSendDynamicTwoTest extends ActiveMQTestSupport {
@Test
- public void testToD() throws Exception {
+ public void testToD() {
template.sendBodyAndHeader("direct:start", "Hello bar", "where", "bar");
template.sendBodyAndHeader("direct:start", "Hello beer", "where", "beer");
template.sendBodyAndHeader("direct:start", "Hello gin", "where", "gin");
@@ -40,10 +40,10 @@ public class ActiveMQToDSendDynamicTwoTest extends ActiveMQTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
context.addComponent("activemq", activeMQComponent(vmUri("?broker.persistent=false")));
// route message dynamic using toD
diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/AdvisoryConsumerExampleTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/AdvisoryConsumerExampleTest.java
index 311cc42..c593311 100644
--- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/AdvisoryConsumerExampleTest.java
+++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/AdvisoryConsumerExampleTest.java
@@ -39,16 +39,16 @@ public class AdvisoryConsumerExampleTest extends ActiveMQTestSupport {
private static final Logger LOG = LoggerFactory.getLogger(AdvisoryConsumerExampleTest.class);
@Test
- public void testWorks() throws Exception {
+ public void testWorks() {
// lets create a new queue
assertDoesNotThrow(
() -> template.sendBody("activemq:NewQueue." + System.currentTimeMillis(), "<hello>world!</hello>"));
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
context.addComponent("activemq", activeMQComponent(vmUri("?broker.persistent=false")));
// lets force the creation of a queue up front
diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/CamelVMTransportRoutingTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/CamelVMTransportRoutingTest.java
index 01cd50b..98ef5e6 100644
--- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/CamelVMTransportRoutingTest.java
+++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/CamelVMTransportRoutingTest.java
@@ -139,7 +139,7 @@ public class CamelVMTransportRoutingTest implements ActiveMQSupport {
ActiveMQComponent.activeMQComponent(vmUri("?create=false&waitForStart=10000")));
camelContext.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(fromEndpoint).to(toEndpoint);
}
});
diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ComplexRequestReplyTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ComplexRequestReplyTest.java
index 77f42f3..74464c2 100644
--- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ComplexRequestReplyTest.java
+++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/ComplexRequestReplyTest.java
@@ -132,7 +132,7 @@ public class ComplexRequestReplyTest implements ActiveMQSupport {
camelContext.addComponent("activemq", amqComponent);
camelContext.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(fromEndpoint).to(ExchangePattern.InOut, toEndpoint);
}
});
@@ -149,7 +149,7 @@ public class ComplexRequestReplyTest implements ActiveMQSupport {
ActiveMQComponent.activeMQComponent(vmUri(brokerName + "?create=false&waitForStart=1000")));
camelContext.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(brokerEndpoint).setBody().simple("Returning ${body}")
.log("***Reply sent to ${header.JMSReplyTo} CoorId = ${header.JMSCorrelationID}");
}
diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/InvokeRequestReplyUsingJmsReplyToHeaderTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/InvokeRequestReplyUsingJmsReplyToHeaderTest.java
index 447ab77..e448ade 100644
--- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/InvokeRequestReplyUsingJmsReplyToHeaderTest.java
+++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/InvokeRequestReplyUsingJmsReplyToHeaderTest.java
@@ -54,7 +54,7 @@ public class InvokeRequestReplyUsingJmsReplyToHeaderTest extends ActiveMQTestSup
private MyServer myBean = new MyServer();
@Test
- public void testPerformRequestReplyOverJms() throws Exception {
+ public void testPerformRequestReplyOverJms() {
Map<String, Object> headers = new HashMap<>();
headers.put("cheese", 123);
headers.put("JMSReplyTo", replyQueueName);
@@ -104,7 +104,7 @@ public class InvokeRequestReplyUsingJmsReplyToHeaderTest extends ActiveMQTestSup
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("activemq:test.server").bean(myBean);
diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/JmsSimpleRequestReplyTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/JmsSimpleRequestReplyTest.java
index ee09aaa..4844899 100644
--- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/JmsSimpleRequestReplyTest.java
+++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/JmsSimpleRequestReplyTest.java
@@ -69,7 +69,7 @@ public class JmsSimpleRequestReplyTest extends ActiveMQTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("activemq:queue:hello").process(exchange -> {
diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/SetHeaderTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/SetHeaderTest.java
index 105883e..bfa66dd 100644
--- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/SetHeaderTest.java
+++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/SetHeaderTest.java
@@ -66,7 +66,7 @@ public class SetHeaderTest {
*/
public static class SetGroupIdProcessor implements Processor {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
// lets copy the IN to the OUT message
Message out = exchange.getMessage();
out.copyFrom(exchange.getIn());
diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/TransactedConsumeTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/TransactedConsumeTest.java
index a3df1eb..d60efb6 100644
--- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/TransactedConsumeTest.java
+++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/TransactedConsumeTest.java
@@ -142,7 +142,7 @@ public class TransactedConsumeTest extends ActiveMQSpringTestSupport {
static class ConnectionLog implements Processor {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
if (consumed.getAndIncrement() == 0) {
firstConsumed.set(System.currentTimeMillis());
}
diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/converter/InvokeJmsMessageListenerTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/converter/InvokeJmsMessageListenerTest.java
index 6da8234..651958b 100644
--- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/converter/InvokeJmsMessageListenerTest.java
+++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/converter/InvokeJmsMessageListenerTest.java
@@ -46,9 +46,9 @@ public class InvokeJmsMessageListenerTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").bean(messageListener);
}
};
diff --git a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/converter/InvokeMessageListenerTest.java b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/converter/InvokeMessageListenerTest.java
index 4bbd7ad..fadff8b 100644
--- a/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/converter/InvokeMessageListenerTest.java
+++ b/components/camel-activemq/src/test/java/org/apache/camel/component/activemq/converter/InvokeMessageListenerTest.java
@@ -68,9 +68,9 @@ public class InvokeMessageListenerTest extends ActiveMQTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(startEndpointUri).bean(listener);
}
};
[camel] 02/09: CAMEL-17763: cleaned up unused exceptions in camel-ahc
Posted by or...@apache.org.
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 81d8f2e5ebcd62cc773c469632c26f85c1d342c4
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Mar 8 12:06:39 2022 +0100
CAMEL-17763: cleaned up unused exceptions in camel-ahc
---
.../ahc/AhcBridgeEndpointPathWithSpacesTest.java | 8 ++++----
.../camel/component/ahc/AhcBridgeEndpointTest.java | 8 ++++----
.../component/ahc/AhcClientConfigRealmUriTest.java | 6 +++---
.../camel/component/ahc/AhcClientConfigUriTest.java | 6 +++---
.../component/ahc/AhcComponentClientConfigTest.java | 6 +++---
.../ahc/AhcComponentCustomClientConfigTest.java | 6 +++---
.../ahc/AhcComponentNettyClientConfigTest.java | 6 +++---
.../apache/camel/component/ahc/AhcGoogleTest.java | 4 ++--
.../camel/component/ahc/AhcProduce500Test.java | 6 +++---
.../component/ahc/AhcProduceClientConfigTest.java | 6 +++---
.../component/ahc/AhcProduceGetHeadersTest.java | 4 ++--
.../component/ahc/AhcProduceGetNoSlashInUriTest.java | 4 ++--
.../camel/component/ahc/AhcProduceGetTest.java | 6 +++---
.../ahc/AhcProduceNoThrowExceptionOnFailureTest.java | 6 +++---
.../component/ahc/AhcProducePostDoWhileTest.java | 4 ++--
.../component/ahc/AhcProducePostHeadersTest.java | 4 ++--
.../camel/component/ahc/AhcProducePostTest.java | 6 +++---
.../ahc/AhcProduceTransferExceptionTest.java | 4 ++--
.../AhcProduceWithClientConfigUriParametersTest.java | 6 +++---
.../ahc/AhcProducerConnectionCloseHeadersTest.java | 4 ++--
.../camel/component/ahc/AhcProducerSessionTest.java | 6 +++---
.../ahc/AhcProducerTwoParametersWithSameKeyTest.java | 12 ++++++------
.../org/apache/camel/component/ahc/BaseAhcTest.java | 2 +-
.../ahc/javabody/AhcProduceJavaBodyTest.java | 20 ++++++++++----------
24 files changed, 75 insertions(+), 75 deletions(-)
diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcBridgeEndpointPathWithSpacesTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcBridgeEndpointPathWithSpacesTest.java
index 8c4123c..4301792 100644
--- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcBridgeEndpointPathWithSpacesTest.java
+++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcBridgeEndpointPathWithSpacesTest.java
@@ -31,22 +31,22 @@ public class AhcBridgeEndpointPathWithSpacesTest extends BaseAhcTest {
private int port2;
@Test
- public void testBridgeEndpoint() throws Exception {
+ public void testBridgeEndpoint() {
String response = template.requestBodyAndHeader("http://localhost:" + port1 + "/test bar/hello",
new ByteArrayInputStream("This is a test".getBytes()), "Content-Type", "application/xml", String.class);
assertEquals("/proxy%20bar/hello", response, "Get a wrong response");
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
port1 = getPort();
port2 = getNextPort();
Processor serviceProc = new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
// get the request URL and copy it to the request body
String uri = exchange.getIn().getHeader(Exchange.HTTP_URI, String.class);
exchange.getMessage().setBody(uri);
diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcBridgeEndpointTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcBridgeEndpointTest.java
index 1d36a64..264fbef 100644
--- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcBridgeEndpointTest.java
+++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcBridgeEndpointTest.java
@@ -34,7 +34,7 @@ public class AhcBridgeEndpointTest extends BaseAhcTest {
private int port2;
@Test
- public void testBridgeEndpoint() throws Exception {
+ public void testBridgeEndpoint() {
String response = template.requestBodyAndHeader("http://localhost:" + port1 + "/test/hello",
new ByteArrayInputStream("This is a test".getBytes()), "Content-Type", "application/xml", String.class);
assertEquals("/", response, "Get a wrong response");
@@ -51,15 +51,15 @@ public class AhcBridgeEndpointTest extends BaseAhcTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
port1 = getPort();
port2 = getNextPort();
Processor serviceProc = new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
// get the request URL and copy it to the request body
String uri = exchange.getIn().getHeader(Exchange.HTTP_URI, String.class);
exchange.getMessage().setBody(uri);
diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcClientConfigRealmUriTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcClientConfigRealmUriTest.java
index 5c7f7b2..3bc2979 100644
--- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcClientConfigRealmUriTest.java
+++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcClientConfigRealmUriTest.java
@@ -24,7 +24,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class AhcClientConfigRealmUriTest extends BaseAhcTest {
@Test
- public void testAhcProduce() throws Exception {
+ public void testAhcProduce() {
Object out = template.requestBody(getAhcEndpointUri()
+ "?clientConfig.realm.scheme=DIGEST&clientConfig.realm.principal=someUser"
+ "&clientConfig.realm.password=somePass&clientConfig.realm.usePreemptiveAuth=true",
@@ -33,10 +33,10 @@ public class AhcClientConfigRealmUriTest extends BaseAhcTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(getTestServerEndpointUri())
.transform(constant("Bye World"));
}
diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcClientConfigUriTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcClientConfigUriTest.java
index 9b29667..42c7679 100644
--- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcClientConfigUriTest.java
+++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcClientConfigUriTest.java
@@ -24,16 +24,16 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class AhcClientConfigUriTest extends BaseAhcTest {
@Test
- public void testAhcProduce() throws Exception {
+ public void testAhcProduce() {
Object out = template.requestBody(getAhcEndpointUri() + "?clientConfig.maxRedirects=4", null, String.class);
assertEquals("Bye World", out);
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(getTestServerEndpointUri())
.transform(constant("Bye World"));
}
diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentClientConfigTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentClientConfigTest.java
index 5274dd6..819a70d 100644
--- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentClientConfigTest.java
+++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentClientConfigTest.java
@@ -49,10 +49,10 @@ public class AhcComponentClientConfigTest extends BaseAhcTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
configureComponent();
from("direct:start")
@@ -61,7 +61,7 @@ public class AhcComponentClientConfigTest extends BaseAhcTest {
from(getTestServerEndpointUri())
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
// redirect to test the client config worked as we told it to follow redirects
exchange.getMessage().setHeader(Exchange.HTTP_RESPONSE_CODE, "301");
exchange.getMessage().setHeader("Location", getTestServerEndpointTwoUrl());
diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentCustomClientConfigTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentCustomClientConfigTest.java
index 9feeb18..40637a8 100644
--- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentCustomClientConfigTest.java
+++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentCustomClientConfigTest.java
@@ -48,17 +48,17 @@ public class AhcComponentCustomClientConfigTest extends BaseAhcTest {
}
@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(getAhcEndpointUri())
.to("mock:result");
from(getTestServerEndpointUri())
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
// redirect to test the client config worked as we told it to follow redirects
exchange.getMessage().setHeader(Exchange.HTTP_RESPONSE_CODE, "301");
exchange.getMessage().setHeader("Location", getTestServerEndpointTwoUrl());
diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentNettyClientConfigTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentNettyClientConfigTest.java
index 0d10d7d..14fcfa8 100644
--- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentNettyClientConfigTest.java
+++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentNettyClientConfigTest.java
@@ -50,17 +50,17 @@ public class AhcComponentNettyClientConfigTest extends BaseAhcTest {
}
@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(getAhcEndpointUri())
.to("mock:result");
from(getTestServerEndpointUri())
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
// redirect to test the client config worked as we told it to follow redirects
exchange.getMessage().setHeader(Exchange.HTTP_RESPONSE_CODE, "301");
exchange.getMessage().setHeader("Location", getTestServerEndpointTwoUrl());
diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcGoogleTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcGoogleTest.java
index 14b3387..521c9bd 100644
--- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcGoogleTest.java
+++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcGoogleTest.java
@@ -37,10 +37,10 @@ public class AhcGoogleTest 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("ahc:http://www.google.se")
.to("log:result?showAll=true")
diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduce500Test.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduce500Test.java
index 15c2754..07f8f1e 100644
--- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduce500Test.java
+++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduce500Test.java
@@ -50,17 +50,17 @@ public class AhcProduce500Test extends BaseAhcTest {
}
@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(getAhcEndpointUri())
.to("mock:result");
from(getTestServerEndpointUri())
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getMessage().setHeader(Exchange.HTTP_RESPONSE_CODE, 500);
exchange.getMessage().setBody("Does not work");
}
diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceClientConfigTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceClientConfigTest.java
index c5dd59c..58e9d19 100644
--- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceClientConfigTest.java
+++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceClientConfigTest.java
@@ -44,17 +44,17 @@ public class AhcProduceClientConfigTest extends BaseAhcTest {
}
@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(getAhcEndpointUri())
.to("mock:result");
from(getTestServerEndpointUri())
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
// redirect to test the client config worked as we told it to follow redirects
exchange.getMessage().setHeader(Exchange.HTTP_RESPONSE_CODE, "301");
exchange.getMessage().setHeader("Location", getTestServerEndpointTwoUrl());
diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceGetHeadersTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceGetHeadersTest.java
index f0070a6..c77a073 100644
--- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceGetHeadersTest.java
+++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceGetHeadersTest.java
@@ -44,10 +44,10 @@ public class AhcProduceGetHeadersTest extends BaseAhcTest {
}
@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(getAhcEndpointUri())
.to("mock:result");
diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceGetNoSlashInUriTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceGetNoSlashInUriTest.java
index 44dadf4..41ea858 100644
--- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceGetNoSlashInUriTest.java
+++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceGetNoSlashInUriTest.java
@@ -36,10 +36,10 @@ public class AhcProduceGetNoSlashInUriTest extends BaseAhcTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
// no // slash in uri should still work
.to(getAhcEndpointUri())
diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceGetTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceGetTest.java
index 275ade6..d6a48de 100644
--- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceGetTest.java
+++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceGetTest.java
@@ -43,7 +43,7 @@ public class AhcProduceGetTest extends BaseAhcTest {
}
@Test
- public void testAhcProduceDirectly() throws Exception {
+ public void testAhcProduceDirectly() {
Object out = template.requestBody(getAhcEndpointUri(), null, String.class);
assertEquals("Bye World", out);
}
@@ -58,10 +58,10 @@ public class AhcProduceGetTest extends BaseAhcTest {
}
@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(getAhcEndpointUri())
.to("mock:result");
diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceNoThrowExceptionOnFailureTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceNoThrowExceptionOnFailureTest.java
index 1b89531..9212750 100644
--- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceNoThrowExceptionOnFailureTest.java
+++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceNoThrowExceptionOnFailureTest.java
@@ -40,17 +40,17 @@ public class AhcProduceNoThrowExceptionOnFailureTest extends BaseAhcTest {
}
@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(getAhcEndpointUri())
.to("mock:result");
from(getTestServerEndpointUri())
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getMessage().setHeader(Exchange.HTTP_RESPONSE_CODE, 500);
exchange.getMessage().setBody("Does not work");
}
diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducePostDoWhileTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducePostDoWhileTest.java
index 582a518..14e0f3e 100644
--- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducePostDoWhileTest.java
+++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducePostDoWhileTest.java
@@ -34,10 +34,10 @@ public class AhcProducePostDoWhileTest extends BaseAhcTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").streamCaching()
.loopDoWhile(body().isNotEqualTo("done"))
.to(getAhcEndpointUri())
diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducePostHeadersTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducePostHeadersTest.java
index 974b758..18d3e28 100644
--- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducePostHeadersTest.java
+++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducePostHeadersTest.java
@@ -43,10 +43,10 @@ public class AhcProducePostHeadersTest extends BaseAhcTest {
}
@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(getAhcEndpointUri())
.to("mock:result");
diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducePostTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducePostTest.java
index eab677d..a16f44f9 100644
--- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducePostTest.java
+++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducePostTest.java
@@ -71,7 +71,7 @@ public class AhcProducePostTest extends BaseAhcTest {
}
@Test
- public void testAhcProduceDirectly() throws Exception {
+ public void testAhcProduceDirectly() {
Object out = template.requestBody(getAhcEndpointUri(), "World", String.class);
assertEquals("Bye World", out);
}
@@ -86,10 +86,10 @@ public class AhcProducePostTest extends BaseAhcTest {
}
@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(getAhcEndpointUri())
.to("mock:result");
diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceTransferExceptionTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceTransferExceptionTest.java
index baa4995..2b5c70a 100644
--- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceTransferExceptionTest.java
+++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceTransferExceptionTest.java
@@ -54,10 +54,10 @@ public class AhcProduceTransferExceptionTest extends BaseAhcTest {
}
@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(getAhcEndpointUri())
.to("mock:result");
diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceWithClientConfigUriParametersTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceWithClientConfigUriParametersTest.java
index a63d1c3..c95a96f 100644
--- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceWithClientConfigUriParametersTest.java
+++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProduceWithClientConfigUriParametersTest.java
@@ -37,17 +37,17 @@ public class AhcProduceWithClientConfigUriParametersTest extends BaseAhcTest {
}
@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(getAhcEndpointUri())
.to("mock:result");
from(getTestServerEndpointUri())
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
// redirect to test the client config worked as we told it to follow redirects
exchange.getMessage().setHeader(Exchange.HTTP_RESPONSE_CODE, "301");
exchange.getMessage().setHeader("Location", getTestServerEndpointTwoUrl());
diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducerConnectionCloseHeadersTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducerConnectionCloseHeadersTest.java
index ae16345..5a6104b 100644
--- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducerConnectionCloseHeadersTest.java
+++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducerConnectionCloseHeadersTest.java
@@ -45,10 +45,10 @@ public class AhcProducerConnectionCloseHeadersTest extends BaseAhcTest {
}
@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(getAhcEndpointUri() + "?connectionClose=true")
.to("mock:result");
diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducerSessionTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducerSessionTest.java
index 89e3d02..c221ece 100644
--- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducerSessionTest.java
+++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducerSessionTest.java
@@ -94,10 +94,10 @@ public class AhcProducerSessionTest extends BaseAhcTest {
}
@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("ahc:" + getTestServerEndpointSessionUrl())
.to("ahc:" + getTestServerEndpointSessionUrl())
@@ -128,7 +128,7 @@ public class AhcProducerSessionTest extends BaseAhcTest {
from(getTestServerEndpointSessionUri())
.process(new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
HttpMessage message = exchange.getIn(HttpMessage.class);
Object cookiesObj = message.getHeader("Cookie");
HttpSession session = message.getRequest().getSession();
diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducerTwoParametersWithSameKeyTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducerTwoParametersWithSameKeyTest.java
index b5eb248..f0508d7 100644
--- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducerTwoParametersWithSameKeyTest.java
+++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcProducerTwoParametersWithSameKeyTest.java
@@ -34,7 +34,7 @@ import static org.junit.jupiter.api.Assertions.assertNotNull;
public class AhcProducerTwoParametersWithSameKeyTest extends BaseAhcTest {
@Test
- public void testTwoParametersWithSameKey() throws Exception {
+ public void testTwoParametersWithSameKey() {
Exchange out = template.request("ahc:http://localhost:{{port}}/myapp?from=me&to=foo&to=bar", null);
assertNotNull(out);
@@ -44,9 +44,9 @@ public class AhcProducerTwoParametersWithSameKeyTest extends BaseAhcTest {
}
@Test
- public void testTwoHeadersWithSameKeyHeader() throws Exception {
+ public void testTwoHeadersWithSameKeyHeader() {
Exchange out = template.request("ahc:http://localhost:{{port}}/myapp", new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setBody(null);
exchange.getIn().setHeader("from", "me");
List<String> list = new ArrayList<>();
@@ -64,12 +64,12 @@ public class AhcProducerTwoParametersWithSameKeyTest extends BaseAhcTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("jetty://http://localhost:{{port}}/myapp").process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
String from = exchange.getIn().getHeader("from", String.class);
assertEquals("me", from);
diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/BaseAhcTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/BaseAhcTest.java
index 15a4b18..3fc222d 100644
--- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/BaseAhcTest.java
+++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/BaseAhcTest.java
@@ -37,7 +37,7 @@ public abstract class BaseAhcTest extends CamelTestSupport {
private static volatile int port;
@BeforeAll
- public static void initPort() throws Exception {
+ public static void initPort() {
port = AvailablePortFinder.getNextAvailable();
}
diff --git a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/javabody/AhcProduceJavaBodyTest.java b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/javabody/AhcProduceJavaBodyTest.java
index 2a71c4d..0b11655 100644
--- a/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/javabody/AhcProduceJavaBodyTest.java
+++ b/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/javabody/AhcProduceJavaBodyTest.java
@@ -52,10 +52,10 @@ public class AhcProduceJavaBodyTest extends BaseAhcTest {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(getTestServerEndpointUri())
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
MyCoolBean cool = exchange.getIn().getBody(MyCoolBean.class);
assertNotNull(cool);
@@ -89,10 +89,10 @@ public class AhcProduceJavaBodyTest extends BaseAhcTest {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(getTestServerEndpointUri())
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
MyCoolBean cool = exchange.getIn().getBody(MyCoolBean.class);
assertNotNull(cool);
@@ -128,10 +128,10 @@ public class AhcProduceJavaBodyTest extends BaseAhcTest {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(getTestServerEndpointUri())
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
String body = exchange.getIn().getBody(String.class);
assertNotNull(body);
assertEquals("Hello World", body);
@@ -162,10 +162,10 @@ public class AhcProduceJavaBodyTest extends BaseAhcTest {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(getTestServerEndpointUri())
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
String body = exchange.getIn().getBody(String.class);
assertNotNull(body);
assertEquals("Hello World", body);
@@ -195,10 +195,10 @@ public class AhcProduceJavaBodyTest extends BaseAhcTest {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(getTestServerEndpointUri())
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
String body = exchange.getIn().getBody(String.class);
assertNotNull(body);
assertEquals("Hello World", body);
[camel] 08/09: CAMEL-17763: cleaned up unused exceptions in camel-mongodb
Posted by or...@apache.org.
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 5a8a7fd7173adfb6026662f693f1f457353ea911
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Mar 8 12:39:46 2022 +0100
CAMEL-17763: cleaned up unused exceptions in camel-mongodb
---
.../mongodb/MongoDbEndpointClientTest.java | 6 ++--
.../mongodb/MongoDbEndpointHostsTest.java | 4 +--
.../integration/MongoDbAggregateOperationIT.java | 4 +--
.../integration/MongoDbBigDecimalConverterIT.java | 2 +-
.../integration/MongoDbBulkWriteOperationIT.java | 8 ++---
.../integration/MongoDbConnectionBeansIT.java | 2 +-
.../mongodb/integration/MongoDbConversionsIT.java | 8 ++---
.../MongoDbCredentialsFromUriConnectionIT.java | 4 +--
.../mongodb/integration/MongoDbDynamicityIT.java | 2 +-
.../integration/MongoDbExceptionHandlingIT.java | 8 ++---
.../integration/MongoDbFindOperationIT.java | 22 ++++++------
.../integration/MongoDbHeaderHandlingIT.java | 10 +++---
.../mongodb/integration/MongoDbIndexIT.java | 2 +-
.../mongodb/integration/MongoDbInsertBatchIT.java | 2 +-
.../mongodb/integration/MongoDbOperationsIT.java | 40 +++++++++++-----------
.../mongodb/integration/MongoDbOutputTypeIT.java | 6 ++--
.../integration/MongoDbSpringDslOperationsIT.java | 4 +--
.../mongodb/integration/MongoDbStopEndpointIT.java | 4 +--
.../MongoDbTailableCursorConsumerIT.java | 2 +-
.../meta/integration/MongoDbMetaExtensionIT.java | 2 +-
.../integration/MongoDbIdempotentRepositoryIT.java | 14 ++++----
21 files changed, 78 insertions(+), 78 deletions(-)
diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbEndpointClientTest.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbEndpointClientTest.java
index abff7ff..befd579 100644
--- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbEndpointClientTest.java
+++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbEndpointClientTest.java
@@ -27,7 +27,7 @@ import static org.junit.jupiter.api.Assertions.*;
class MongoDbEndpointClientTest extends CamelTestSupport {
@Override
- protected void bindToRegistry(Registry registry) throws Exception {
+ protected void bindToRegistry(Registry registry) {
registry.bind("mongoClient", MongoClients.create("mongodb://localhost"));
}
@@ -44,10 +44,10 @@ class MongoDbEndpointClientTest 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:dbFromBean").to("mongodb:mongoClient?database=test&collection=test&operation=findAll");
}
};
diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbEndpointHostsTest.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbEndpointHostsTest.java
index ac07211..35b9927 100644
--- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbEndpointHostsTest.java
+++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/MongoDbEndpointHostsTest.java
@@ -37,10 +37,10 @@ class MongoDbEndpointHostsTest 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:dbFromHost").to("mongodb:dummy?hosts=localhost&database=test&collection=test&operation=findAll");
}
};
diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbAggregateOperationIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbAggregateOperationIT.java
index dcd9e97..9a8b0b33 100644
--- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbAggregateOperationIT.java
+++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbAggregateOperationIT.java
@@ -34,7 +34,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
public class MongoDbAggregateOperationIT extends AbstractMongoDbITSupport {
@Test
- public void testAggregate() throws Exception {
+ public void testAggregate() {
// Test that the collection has 0 documents in it
assertEquals(0, testCollection.countDocuments());
pumpDataIntoTestCollection();
@@ -111,7 +111,7 @@ public class MongoDbAggregateOperationIT extends AbstractMongoDbITSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("direct:aggregate")
diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbBigDecimalConverterIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbBigDecimalConverterIT.java
index 0e10c5d..6cad896 100644
--- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbBigDecimalConverterIT.java
+++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbBigDecimalConverterIT.java
@@ -53,7 +53,7 @@ public class MongoDbBigDecimalConverterIT extends AbstractMongoDbITSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("direct:insert")
diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbBulkWriteOperationIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbBulkWriteOperationIT.java
index 0bb1a65..7c95993 100644
--- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbBulkWriteOperationIT.java
+++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbBulkWriteOperationIT.java
@@ -40,7 +40,7 @@ import static org.junit.jupiter.api.Assertions.fail;
public class MongoDbBulkWriteOperationIT extends AbstractMongoDbITSupport {
@Test
- public void testBulkWrite() throws Exception {
+ public void testBulkWrite() {
// Test that the collection has 0 documents in it
assertEquals(0, testCollection.countDocuments());
pumpDataIntoTestCollection();
@@ -69,7 +69,7 @@ public class MongoDbBulkWriteOperationIT extends AbstractMongoDbITSupport {
}
@Test
- public void testOrderedBulkWriteWithError() throws Exception {
+ public void testOrderedBulkWriteWithError() {
// Test that the collection has 0 documents in it
assertEquals(0, testCollection.countDocuments());
pumpDataIntoTestCollection();
@@ -94,7 +94,7 @@ public class MongoDbBulkWriteOperationIT extends AbstractMongoDbITSupport {
}
@Test
- public void testUnorderedBulkWriteWithError() throws Exception {
+ public void testUnorderedBulkWriteWithError() {
// Test that the collection has 0 documents in it
assertEquals(0, testCollection.countDocuments());
pumpDataIntoTestCollection();
@@ -118,7 +118,7 @@ public class MongoDbBulkWriteOperationIT extends AbstractMongoDbITSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("direct:bulkWrite").to(
diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbConnectionBeansIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbConnectionBeansIT.java
index 5a10501..0fca614 100644
--- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbConnectionBeansIT.java
+++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbConnectionBeansIT.java
@@ -77,7 +77,7 @@ public class MongoDbConnectionBeansIT extends AbstractMongoDbITSupport {
}
@Test
- public void checkConnectionOnComponent() throws Exception {
+ public void checkConnectionOnComponent() {
Endpoint endpoint = context.getEndpoint("mongodb:justARouteName");
assertIsInstanceOf(MongoDbEndpoint.class, endpoint);
diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbConversionsIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbConversionsIT.java
index 7a39f20..1dab32f 100644
--- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbConversionsIT.java
+++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbConversionsIT.java
@@ -37,7 +37,7 @@ import static org.junit.jupiter.api.Assertions.assertNotNull;
public class MongoDbConversionsIT extends AbstractMongoDbITSupport {
@Test
- public void testInsertMap() throws InterruptedException {
+ public void testInsertMap() {
assertEquals(0, testCollection.countDocuments());
Map<String, Object> m1 = new HashMap<>();
@@ -111,7 +111,7 @@ public class MongoDbConversionsIT extends AbstractMongoDbITSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
@@ -140,7 +140,7 @@ public class MongoDbConversionsIT extends AbstractMongoDbITSupport {
}
@Test
- public void shouldConvertJsonStringListToBSONList() throws InterruptedException {
+ public void shouldConvertJsonStringListToBSONList() {
String jsonListArray = "[{\"key\":\"value1\"}, {\"key\":\"value2\"}]";
List<Bson> bsonList = MongoDbBasicConverters.fromStringToList(jsonListArray);
assertNotNull(bsonList);
@@ -153,7 +153,7 @@ public class MongoDbConversionsIT extends AbstractMongoDbITSupport {
}
@Test
- public void shouldNotConvertJsonStringListToBSONList() throws InterruptedException {
+ public void shouldNotConvertJsonStringListToBSONList() {
String jsonSingleValue = "{\"key\":\"value1\"}";
List<Bson> bsonList = MongoDbBasicConverters.fromStringToList(jsonSingleValue);
assertNull(bsonList);
diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbCredentialsFromUriConnectionIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbCredentialsFromUriConnectionIT.java
index 212d919..71ee0a2 100644
--- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbCredentialsFromUriConnectionIT.java
+++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbCredentialsFromUriConnectionIT.java
@@ -42,7 +42,7 @@ public class MongoDbCredentialsFromUriConnectionIT extends MongoDbOperationsIT {
}
@Override
- protected CamelContext createCamelContext() throws Exception {
+ protected CamelContext createCamelContext() {
//This is necessary to avoid creating connection bean for the mongodb component and test credentials instead
@SuppressWarnings("deprecation")
CamelContext ctx = new DefaultCamelContext();
@@ -67,7 +67,7 @@ public class MongoDbCredentialsFromUriConnectionIT extends MongoDbOperationsIT {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbDynamicityIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbDynamicityIT.java
index 0db7eaf..82092fc 100644
--- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbDynamicityIT.java
+++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbDynamicityIT.java
@@ -149,7 +149,7 @@ public class MongoDbDynamicityIT extends AbstractMongoDbITSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbExceptionHandlingIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbExceptionHandlingIT.java
index fd5fad57..1ccfcb2 100644
--- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbExceptionHandlingIT.java
+++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbExceptionHandlingIT.java
@@ -29,7 +29,7 @@ import static org.junit.jupiter.api.Assertions.fail;
public class MongoDbExceptionHandlingIT extends AbstractMongoDbITSupport {
@Test
- public void testInduceParseException() throws Exception {
+ public void testInduceParseException() {
// Test that the collection has 0 documents in it
assertEquals(0, testCollection.countDocuments());
pumpDataIntoTestCollection();
@@ -44,7 +44,7 @@ public class MongoDbExceptionHandlingIT extends AbstractMongoDbITSupport {
}
@Test
- public void testInduceParseAndThenOkException() throws Exception {
+ public void testInduceParseAndThenOkException() {
// Test that the collection has 0 documents in it
assertEquals(0, testCollection.countDocuments());
pumpDataIntoTestCollection();
@@ -64,7 +64,7 @@ public class MongoDbExceptionHandlingIT extends AbstractMongoDbITSupport {
}
@Test
- public void testErroneousDynamicOperation() throws Exception {
+ public void testErroneousDynamicOperation() {
// Test that the collection has 0 documents in it
assertEquals(0, testCollection.countDocuments());
pumpDataIntoTestCollection();
@@ -80,7 +80,7 @@ public class MongoDbExceptionHandlingIT extends AbstractMongoDbITSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbFindOperationIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbFindOperationIT.java
index 4b5b77b..70b1abd 100644
--- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbFindOperationIT.java
+++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbFindOperationIT.java
@@ -98,7 +98,7 @@ public class MongoDbFindOperationIT extends CamelTestSupport {
}
@Override
- protected CamelContext createCamelContext() throws Exception {
+ protected CamelContext createCamelContext() {
MongoDbComponent component = new MongoDbComponent();
component.setMongoConnection(mongo);
@@ -128,7 +128,7 @@ public class MongoDbFindOperationIT extends CamelTestSupport {
}
@Test
- public void testFindAllNoCriteriaOperation() throws Exception {
+ public void testFindAllNoCriteriaOperation() {
// Test that the collection has 0 documents in it
assertEquals(0, testCollection.countDocuments());
pumpDataIntoTestCollection();
@@ -158,7 +158,7 @@ public class MongoDbFindOperationIT extends CamelTestSupport {
}
@Test
- public void testFindAllAllowDiskUse() throws Exception {
+ public void testFindAllAllowDiskUse() {
// Test that the collection has 0 documents in it
assertEquals(0, testCollection.countDocuments());
pumpDataIntoTestCollection();
@@ -179,7 +179,7 @@ public class MongoDbFindOperationIT extends CamelTestSupport {
}
@Test
- public void testFindAllWithQueryAndNoFIlter() throws Exception {
+ public void testFindAllWithQueryAndNoFIlter() {
// Test that the collection has 0 documents in it
assertEquals(0, testCollection.countDocuments());
pumpDataIntoTestCollection();
@@ -207,7 +207,7 @@ public class MongoDbFindOperationIT extends CamelTestSupport {
}
@Test
- public void testFindAllWithQueryAndFilter() throws Exception {
+ public void testFindAllWithQueryAndFilter() {
// Test that the collection has 0 documents in it
assertEquals(0, testCollection.countDocuments());
pumpDataIntoTestCollection();
@@ -236,7 +236,7 @@ public class MongoDbFindOperationIT extends CamelTestSupport {
}
@Test
- public void testFindAllNoCriteriaWithFilterOperation() throws Exception {
+ public void testFindAllNoCriteriaWithFilterOperation() {
// Test that the collection has 0 documents in it
assertEquals(0, testCollection.countDocuments());
pumpDataIntoTestCollection();
@@ -267,7 +267,7 @@ public class MongoDbFindOperationIT extends CamelTestSupport {
}
@Test
- public void testFindAllIterationOperation() throws Exception {
+ public void testFindAllIterationOperation() {
// Test that the collection has 0 documents in it
assertEquals(0, testCollection.countDocuments());
pumpDataIntoTestCollection();
@@ -343,7 +343,7 @@ public class MongoDbFindOperationIT extends CamelTestSupport {
}
@Test
- public void testFindOneByQuery() throws Exception {
+ public void testFindOneByQuery() {
// Test that the collection has 0 documents in it
assertEquals(0, testCollection.countDocuments());
pumpDataIntoTestCollection();
@@ -359,7 +359,7 @@ public class MongoDbFindOperationIT extends CamelTestSupport {
}
@Test
- public void testFindOneById() throws Exception {
+ public void testFindOneById() {
// Test that the collection has 0 documents in it
assertEquals(0, testCollection.countDocuments());
pumpDataIntoTestCollection();
@@ -377,7 +377,7 @@ public class MongoDbFindOperationIT extends CamelTestSupport {
}
@Test
- public void testFindOneByIdWithObjectId() throws Exception {
+ public void testFindOneByIdWithObjectId() {
// Test that the collection has 0 documents in it
assertEquals(0, testCollection.countDocuments());
Document insertObject = new Document("scientist", "Einstein");
@@ -398,7 +398,7 @@ public class MongoDbFindOperationIT extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbHeaderHandlingIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbHeaderHandlingIT.java
index f79f4f7..c80a5ea 100644
--- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbHeaderHandlingIT.java
+++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbHeaderHandlingIT.java
@@ -39,7 +39,7 @@ public class MongoDbHeaderHandlingIT extends AbstractMongoDbITSupport {
assertEquals(0, testCollection.countDocuments());
Exchange result = template.request("direct:count", new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setBody("irrelevant body");
exchange.getIn().setHeader("abc", "def");
}
@@ -53,7 +53,7 @@ public class MongoDbHeaderHandlingIT extends AbstractMongoDbITSupport {
public void testInHeadersTransferredToOutOnInsert() {
Exchange result = template.request("direct:insert", new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setBody("{\"_id\":\"testInsertString\", \"scientist\":\"Einstein\"}");
exchange.getIn().setHeader("abc", "def");
}
@@ -87,7 +87,7 @@ public class MongoDbHeaderHandlingIT extends AbstractMongoDbITSupport {
// with the CamelMongoDbWriteResult header
Exchange resultExch = template.request("direct:save", new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setBody(record1);
}
});
@@ -105,7 +105,7 @@ public class MongoDbHeaderHandlingIT extends AbstractMongoDbITSupport {
public void testWriteResultAsHeaderWithReadOp() {
Exchange resultExch = template.request("direct:getDbStats", new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setBody("irrelevantBody");
exchange.getIn().setHeader("abc", "def");
}
@@ -116,7 +116,7 @@ public class MongoDbHeaderHandlingIT extends AbstractMongoDbITSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbIndexIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbIndexIT.java
index 16b7be4..7058596 100644
--- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbIndexIT.java
+++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbIndexIT.java
@@ -203,7 +203,7 @@ public class MongoDbIndexIT extends AbstractMongoDbITSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("direct:dynamicityEnabled").to(
diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbInsertBatchIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbInsertBatchIT.java
index 8d60e52..b5d4a53 100644
--- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbInsertBatchIT.java
+++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbInsertBatchIT.java
@@ -64,7 +64,7 @@ public class MongoDbInsertBatchIT extends AbstractMongoDbITSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("direct:insert")
diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbOperationsIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbOperationsIT.java
index cc7cd93..d5d7782 100644
--- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbOperationsIT.java
+++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbOperationsIT.java
@@ -53,7 +53,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
public class MongoDbOperationsIT extends AbstractMongoDbITSupport {
@Test
- public void testCountOperation() throws Exception {
+ public void testCountOperation() {
// Test that the collection has 0 documents in it
assertEquals(0, testCollection.countDocuments());
Object result = template.requestBody("direct:count", "irrelevantBody");
@@ -77,7 +77,7 @@ public class MongoDbOperationsIT extends AbstractMongoDbITSupport {
}
@Test
- public void testInsertString() throws Exception {
+ public void testInsertString() {
assertEquals(0, testCollection.countDocuments());
Object result = template.requestBody("direct:insert",
new Document(MONGO_ID, "testInsertString").append("scientist", "Einstein").toJson());
@@ -87,14 +87,14 @@ public class MongoDbOperationsIT extends AbstractMongoDbITSupport {
}
@Test
- public void testStoreOidOnInsert() throws Exception {
+ public void testStoreOidOnInsert() {
Document document = new Document();
ObjectId oid = template.requestBody("direct:testStoreOidOnInsert", document, ObjectId.class);
assertEquals(document.get(MONGO_ID), oid);
}
@Test
- public void testStoreOidsOnInsert() throws Exception {
+ public void testStoreOidsOnInsert() {
Document firsDocument = new Document();
Document secondDoocument = new Document();
List<?> oids
@@ -104,7 +104,7 @@ public class MongoDbOperationsIT extends AbstractMongoDbITSupport {
}
@Test
- public void testSave() throws Exception {
+ public void testSave() {
// Prepare test
assertEquals(0, testCollection.countDocuments());
Object[] req = new Object[] {
@@ -149,21 +149,21 @@ public class MongoDbOperationsIT extends AbstractMongoDbITSupport {
}
@Test
- public void testStoreOidOnSaveWithoutId() throws Exception {
+ public void testStoreOidOnSaveWithoutId() {
Document document = new Document();
ObjectId oid = template.requestBody("direct:testStoreOidOnSave", document, ObjectId.class);
assertNotNull(oid);
}
@Test
- public void testStoreOidOnSave() throws Exception {
+ public void testStoreOidOnSave() {
Document document = new Document(MONGO_ID, new ObjectId("5847e39e0824d6b54194e197"));
ObjectId oid = template.requestBody("direct:testStoreOidOnSave", document, ObjectId.class);
assertEquals(document.get(MONGO_ID), oid);
}
@Test
- public void testUpdate() throws Exception {
+ public void testUpdate() {
// Prepare test
assertEquals(0, testCollection.countDocuments());
for (int i = 1; i <= 100; i++) {
@@ -191,7 +191,7 @@ public class MongoDbOperationsIT extends AbstractMongoDbITSupport {
Exchange resultExchange = template.request("direct:update", new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setBody(new Bson[] { extraField, updateObj });
exchange.getIn().setHeader(MongoDbConstants.MULTIUPDATE, true);
}
@@ -206,7 +206,7 @@ public class MongoDbOperationsIT extends AbstractMongoDbITSupport {
}
@Test
- public void testUpdateFromString() throws Exception {
+ public void testUpdateFromString() {
// Prepare test
assertEquals(0, testCollection.countDocuments());
for (int i = 1; i <= 100; i++) {
@@ -238,7 +238,7 @@ public class MongoDbOperationsIT extends AbstractMongoDbITSupport {
Exchange resultExchange = template.request("direct:update", new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setBody(updates);
exchange.getIn().setHeader(MongoDbConstants.MULTIUPDATE, true);
}
@@ -253,7 +253,7 @@ public class MongoDbOperationsIT extends AbstractMongoDbITSupport {
}
@Test
- public void testUpdateUsingFieldsFilterHeader() throws Exception {
+ public void testUpdateUsingFieldsFilterHeader() {
// Prepare test
assertEquals(0, testCollection.countDocuments());
for (int i = 1; i <= 100; i++) {
@@ -290,7 +290,7 @@ public class MongoDbOperationsIT extends AbstractMongoDbITSupport {
}
@Test
- public void testRemove() throws Exception {
+ public void testRemove() {
// Prepare test
assertEquals(0, testCollection.countDocuments());
for (int i = 1; i <= 100; i++) {
@@ -314,7 +314,7 @@ public class MongoDbOperationsIT extends AbstractMongoDbITSupport {
Exchange resultExchange = template.request("direct:remove", new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setBody(extraField);
}
});
@@ -329,7 +329,7 @@ public class MongoDbOperationsIT extends AbstractMongoDbITSupport {
}
@Test
- public void testAggregate() throws Exception {
+ public void testAggregate() {
// Test that the collection has 0 documents in it
assertEquals(0, testCollection.countDocuments());
pumpDataIntoTestCollection();
@@ -347,7 +347,7 @@ public class MongoDbOperationsIT extends AbstractMongoDbITSupport {
}
@Test
- public void testDbStats() throws Exception {
+ public void testDbStats() {
assertEquals(0, testCollection.countDocuments());
Object result = template.requestBody("direct:getDbStats", "irrelevantBody");
assertTrue(result instanceof Document, "Result is not of type Document");
@@ -355,7 +355,7 @@ public class MongoDbOperationsIT extends AbstractMongoDbITSupport {
}
@Test
- public void testColStats() throws Exception {
+ public void testColStats() {
assertEquals(0, testCollection.countDocuments());
// Add some records to the collection (and do it via camel-mongodb)
@@ -374,7 +374,7 @@ public class MongoDbOperationsIT extends AbstractMongoDbITSupport {
}
@Test
- public void testCommand() throws Exception {
+ public void testCommand() {
// Call hostInfo, command working with every configuration
Object result = template.requestBody("direct:command", "{\"hostInfo\":\"1\"}");
assertTrue(result instanceof Document, "Result is not of type Document");
@@ -382,7 +382,7 @@ public class MongoDbOperationsIT extends AbstractMongoDbITSupport {
}
@Test
- public void testOperationHeader() throws Exception {
+ public void testOperationHeader() {
// Test that the collection has 0 documents in it
assertEquals(0, testCollection.countDocuments());
@@ -403,7 +403,7 @@ public class MongoDbOperationsIT extends AbstractMongoDbITSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbOutputTypeIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbOutputTypeIT.java
index e66cd07..b6bb6a7 100644
--- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbOutputTypeIT.java
+++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbOutputTypeIT.java
@@ -95,7 +95,7 @@ public class MongoDbOutputTypeIT extends AbstractMongoDbITSupport {
try {
RouteBuilder taillableRouteBuilder = new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("mongodb:myDb?database={{mongodb.testDb}}&collection={{mongodb.testCollection}}&operation=findById&dynamicity=true&outputType=MongoIterable")
.to("mock:dummy");
}
@@ -113,7 +113,7 @@ public class MongoDbOutputTypeIT extends AbstractMongoDbITSupport {
try {
RouteBuilder taillableRouteBuilder = new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("mongodb:myDb?database={{mongodb.testDb}}&collection={{mongodb.cappedTestCollection}}&tailTrackIncreasingField=increasing&outputType=MongoIterable")
.id("tailableCursorConsumer1").autoStartup(false).to("mock:test");
}
@@ -127,7 +127,7 @@ public class MongoDbOutputTypeIT extends AbstractMongoDbITSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbSpringDslOperationsIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbSpringDslOperationsIT.java
index d294bed..aa7a62b 100644
--- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbSpringDslOperationsIT.java
+++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbSpringDslOperationsIT.java
@@ -42,10 +42,10 @@ public class MongoDbSpringDslOperationsIT extends MongoDbOperationsIT {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// Nothing, all routes are initialized by the Spring DSL context
// file
}
diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbStopEndpointIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbStopEndpointIT.java
index 5ef8aee..f3c743f 100644
--- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbStopEndpointIT.java
+++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbStopEndpointIT.java
@@ -33,7 +33,7 @@ public class MongoDbStopEndpointIT extends AbstractMongoDbITSupport {
MongoDbEndpoint endpoint;
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("direct:insertJsonString").routeId("insert").to(endpoint);
@@ -44,7 +44,7 @@ public class MongoDbStopEndpointIT extends AbstractMongoDbITSupport {
}
@Test
- public void testStopEndpoint() throws Exception {
+ public void testStopEndpoint() {
assertEquals(0, testCollection.countDocuments());
template.requestBody("direct:insertJsonString", "{\"scientist\": \"Newton\", \"_id\": \"" + MY_ID + "\"}");
diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbTailableCursorConsumerIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbTailableCursorConsumerIT.java
index 336f2d0..b878907 100644
--- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbTailableCursorConsumerIT.java
+++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/integration/MongoDbTailableCursorConsumerIT.java
@@ -426,7 +426,7 @@ public class MongoDbTailableCursorConsumerIT extends AbstractMongoDbITSupport {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("mongodb:myDb?database={{mongodb.testDb}}&collection={{mongodb.cappedTestCollection}}&tailTrackIncreasingField=increasing")
.id("tailableCursorConsumer1")
diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/meta/integration/MongoDbMetaExtensionIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/meta/integration/MongoDbMetaExtensionIT.java
index 9a6b6e8..cf6972d 100644
--- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/meta/integration/MongoDbMetaExtensionIT.java
+++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/meta/integration/MongoDbMetaExtensionIT.java
@@ -52,7 +52,7 @@ public class MongoDbMetaExtensionIT extends AbstractMongoDbITSupport {
}
@Test
- public void testValidMetaData() throws Exception {
+ public void testValidMetaData() {
// When
final String database = "test";
final String collection = "validatedCollection";
diff --git a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/processor/idempotent/integration/MongoDbIdempotentRepositoryIT.java b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/processor/idempotent/integration/MongoDbIdempotentRepositoryIT.java
index 6bcf03f..a8d9aa4 100644
--- a/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/processor/idempotent/integration/MongoDbIdempotentRepositoryIT.java
+++ b/components/camel-mongodb/src/test/java/org/apache/camel/component/mongodb/processor/idempotent/integration/MongoDbIdempotentRepositoryIT.java
@@ -45,7 +45,7 @@ public class MongoDbIdempotentRepositoryIT extends AbstractMongoDbITSupport {
}
@Test
- public void add() throws Exception {
+ public void add() {
String randomUUIDString = UUID.randomUUID().toString();
boolean added = repo.add(randomUUIDString);
@@ -54,7 +54,7 @@ public class MongoDbIdempotentRepositoryIT extends AbstractMongoDbITSupport {
}
@Test
- public void addAndContains() throws Exception {
+ public void addAndContains() {
String randomUUIDString = UUID.randomUUID().toString();
repo.add(randomUUIDString);
@@ -65,7 +65,7 @@ public class MongoDbIdempotentRepositoryIT extends AbstractMongoDbITSupport {
}
@Test
- public void addAndRemove() throws Exception {
+ public void addAndRemove() {
String randomUUIDString = UUID.randomUUID().toString();
repo.add(randomUUIDString);
@@ -77,7 +77,7 @@ public class MongoDbIdempotentRepositoryIT extends AbstractMongoDbITSupport {
}
@Test
- public void addDuplicatedFails() throws Exception {
+ public void addDuplicatedFails() {
String randomUUIDString = UUID.randomUUID().toString();
repo.add(randomUUIDString);
@@ -89,7 +89,7 @@ public class MongoDbIdempotentRepositoryIT extends AbstractMongoDbITSupport {
}
@Test
- public void deleteMissingiIsFailse() throws Exception {
+ public void deleteMissingiIsFailse() {
String randomUUIDString = UUID.randomUUID().toString();
assertEquals(0, testCollection.countDocuments());
boolean removed = repo.remove(randomUUIDString);
@@ -97,14 +97,14 @@ public class MongoDbIdempotentRepositoryIT extends AbstractMongoDbITSupport {
}
@Test
- public void containsMissingReturnsFalse() throws Exception {
+ public void containsMissingReturnsFalse() {
String randomUUIDString = UUID.randomUUID().toString();
boolean found = repo.contains(randomUUIDString);
assertTrue(!found, "Non existing item is not found");
}
@Test
- public void confirmAllwaysReturnsTrue() throws Exception {
+ public void confirmAllwaysReturnsTrue() {
String randomUUIDString = UUID.randomUUID().toString();
boolean found = repo.confirm(randomUUIDString);
assertTrue(found, "Confirm always returns true");
[camel] 05/09: CAMEL-17763: cleaned up unused exceptions in camel-cassandraql
Posted by or...@apache.org.
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 <an...@gmail.com>
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");
}
};
[camel] 03/09: CAMEL-17763: cleaned up unused exceptions in camel-kafka
Posted by or...@apache.org.
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 9a4d3556fc2448a34e096ccfbcf4cad7e0ed4a0d
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Mar 8 12:18:44 2022 +0100
CAMEL-17763: cleaned up unused exceptions in camel-kafka
---
.../apache/camel/component/kafka/KafkaComponentTest.java | 8 ++++----
.../apache/camel/component/kafka/KafkaConsumerTest.java | 4 ++--
.../apache/camel/component/kafka/KafkaProducerTest.java | 4 ++--
.../integration/KafkaConsumerAsyncManualCommitIT.java | 2 +-
.../kafka/integration/KafkaConsumerBatchSizeIT.java | 4 ++--
.../component/kafka/integration/KafkaConsumerFullIT.java | 7 +++----
.../kafka/integration/KafkaConsumerHealthCheckIT.java | 5 ++---
.../kafka/integration/KafkaConsumerIdempotentIT.java | 8 +++-----
.../KafkaConsumerIdempotentWithCustomSerializerIT.java | 6 ++----
.../KafkaConsumerIdempotentWithProcessorIT.java | 8 +++-----
.../integration/KafkaConsumerLastRecordHeaderIT.java | 4 ++--
.../kafka/integration/KafkaConsumerManualCommitIT.java | 4 ++--
.../kafka/integration/KafkaConsumerRebalanceIT.java | 6 +++---
.../kafka/integration/KafkaConsumerTopicIsPatternIT.java | 4 ++--
.../KafkaConsumerWithResumeRouteStrategyIT.java | 4 ++--
.../component/kafka/integration/KafkaProducerFullIT.java | 15 +++++++--------
.../camel/component/kafka/integration/KafkaToDIT.java | 6 +++---
.../kafka/KafkaIdempotentRepositoryEagerIT.java | 8 ++++----
.../kafka/KafkaIdempotentRepositoryNonEagerIT.java | 8 ++++----
.../kafka/KafkaIdempotentRepositoryPersistenceIT.java | 2 +-
20 files changed, 54 insertions(+), 63 deletions(-)
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaComponentTest.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaComponentTest.java
index b95efcb..53cc175 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaComponentTest.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaComponentTest.java
@@ -36,7 +36,7 @@ import static org.junit.jupiter.api.Assertions.assertNull;
public class KafkaComponentTest extends CamelTestSupport {
@Test
- public void testPropertiesSet() throws Exception {
+ public void testPropertiesSet() {
String uri = "kafka:mytopic?brokers=broker1:12345,broker2:12566&partitioner=com.class.Party";
KafkaEndpoint endpoint = context.getEndpoint(uri, KafkaEndpoint.class);
@@ -46,7 +46,7 @@ public class KafkaComponentTest extends CamelTestSupport {
}
@Test
- public void testBrokersOnComponent() throws Exception {
+ public void testBrokersOnComponent() {
KafkaComponent kafka = context.getComponent("kafka", KafkaComponent.class);
kafka.getConfiguration().setBrokers("broker1:12345,broker2:12566");
@@ -255,7 +255,7 @@ public class KafkaComponentTest extends CamelTestSupport {
}
@Test
- public void testCreateProducerConfigTruststorePassword() throws Exception {
+ public void testCreateProducerConfigTruststorePassword() {
KeyStoreParameters keyStoreParameters = new KeyStoreParameters();
keyStoreParameters.setPassword("my-password");
@@ -275,7 +275,7 @@ public class KafkaComponentTest extends CamelTestSupport {
}
@Test
- public void testCreateConsumerConfigTruststorePassword() throws Exception {
+ public void testCreateConsumerConfigTruststorePassword() {
KeyStoreParameters keyStoreParameters = new KeyStoreParameters();
keyStoreParameters.setPassword("my-password");
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaConsumerTest.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaConsumerTest.java
index 7171264..426f12b 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaConsumerTest.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaConsumerTest.java
@@ -38,7 +38,7 @@ public class KafkaConsumerTest {
private ExchangeFactory ef = mock(ExchangeFactory.class);
@Test
- public void consumerRequiresBootstrapServers() throws Exception {
+ public void consumerRequiresBootstrapServers() {
when(endpoint.getCamelContext()).thenReturn(ecc);
when(ecc.adapt(ExtendedCamelContext.class)).thenReturn(ecc);
when(ecc.getExchangeFactory()).thenReturn(ef);
@@ -55,7 +55,7 @@ public class KafkaConsumerTest {
}
@Test
- public void consumerOnlyRequiresBootstrapServers() throws Exception {
+ public void consumerOnlyRequiresBootstrapServers() {
when(endpoint.getCamelContext()).thenReturn(ecc);
when(ecc.adapt(ExtendedCamelContext.class)).thenReturn(ecc);
when(ecc.getExchangeFactory()).thenReturn(ef);
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java
index ec2750d..3261e2a 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java
@@ -107,7 +107,7 @@ public class KafkaProducerTest {
}
@Test
- public void testPropertyBuilder() throws Exception {
+ public void testPropertyBuilder() {
Properties props = producer.getProps();
assertEquals("broker1:1234,broker2:4567", props.getProperty(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG));
}
@@ -142,7 +142,7 @@ public class KafkaProducerTest {
}
@Test
- public void processAsyncSendsMessage() throws Exception {
+ public void processAsyncSendsMessage() {
endpoint.getConfiguration().setTopic("sometopic");
Mockito.when(exchange.getIn()).thenReturn(in);
Mockito.when(exchange.getMessage()).thenReturn(in);
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java
index 6f2a642..dc82ca2 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerAsyncManualCommitIT.java
@@ -73,7 +73,7 @@ public class KafkaConsumerAsyncManualCommitIT extends BaseEmbeddedKafkaTestSuppo
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerBatchSizeIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerBatchSizeIT.java
index b3b366b..2229811 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerBatchSizeIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerBatchSizeIT.java
@@ -56,10 +56,10 @@ public class KafkaConsumerBatchSizeIT extends BaseEmbeddedKafkaTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(from).routeId("foo").to(to).setId("First");
}
};
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerFullIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerFullIT.java
index f772423..2e0792e 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerFullIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerFullIT.java
@@ -16,7 +16,6 @@
*/
package org.apache.camel.component.kafka.integration;
-import java.io.IOException;
import java.util.Collections;
import java.util.Map;
import java.util.Properties;
@@ -84,7 +83,7 @@ public class KafkaConsumerFullIT extends BaseEmbeddedKafkaTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
@@ -97,7 +96,7 @@ public class KafkaConsumerFullIT extends BaseEmbeddedKafkaTestSupport {
@Order(3)
@Test
- public void kafkaMessageIsConsumedByCamel() throws InterruptedException, IOException {
+ public void kafkaMessageIsConsumedByCamel() throws InterruptedException {
String propagatedHeaderKey = "PropagatedCustomHeader";
byte[] propagatedHeaderValue = "propagated header value".getBytes();
String skippedHeaderKey = "CamelSkippedHeader";
@@ -128,7 +127,7 @@ public class KafkaConsumerFullIT extends BaseEmbeddedKafkaTestSupport {
@Order(2)
@Test
- public void kafkaRecordSpecificHeadersAreNotOverwritten() throws InterruptedException, IOException {
+ public void kafkaRecordSpecificHeadersAreNotOverwritten() throws InterruptedException {
String propagatedHeaderKey = KafkaConstants.TOPIC;
byte[] propagatedHeaderValue = "propagated incorrect topic".getBytes();
to.expectedHeaderReceived(KafkaConstants.TOPIC, TOPIC);
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java
index d5e973c..a115113 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerHealthCheckIT.java
@@ -16,7 +16,6 @@
*/
package org.apache.camel.component.kafka.integration;
-import java.io.IOException;
import java.util.Collection;
import java.util.Collections;
import java.util.Map;
@@ -110,7 +109,7 @@ public class KafkaConsumerHealthCheckIT extends BaseEmbeddedKafkaTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
@@ -123,7 +122,7 @@ public class KafkaConsumerHealthCheckIT extends BaseEmbeddedKafkaTestSupport {
@Order(1)
@Test
- public void kafkaConsumerHealthCheck() throws InterruptedException, IOException {
+ public void kafkaConsumerHealthCheck() throws InterruptedException {
// health-check liveness should be UP
Collection<HealthCheck.Result> res = HealthCheckHelper.invokeLiveness(context);
boolean up = res.stream().allMatch(r -> r.getState().equals(HealthCheck.State.UP));
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentIT.java
index b954fa4..2976de3 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentIT.java
@@ -17,8 +17,6 @@
package org.apache.camel.component.kafka.integration;
import java.util.Arrays;
-import java.util.concurrent.ExecutionException;
-import java.util.concurrent.TimeoutException;
import org.apache.camel.BindToRegistry;
import org.apache.camel.Endpoint;
@@ -57,7 +55,7 @@ public class KafkaConsumerIdempotentIT extends KafkaConsumerIdempotentTestSuppor
private int size = 200;
@BeforeEach
- public void before() throws ExecutionException, InterruptedException, TimeoutException {
+ public void before() {
kafkaAdminClient.deleteTopics(Arrays.asList(TOPIC, "TEST_IDEMPOTENT")).all();
doSend(size, TOPIC);
}
@@ -68,12 +66,12 @@ public class KafkaConsumerIdempotentIT extends KafkaConsumerIdempotentTestSuppor
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(from).routeId("foo")
.idempotentConsumer(numericHeader("id"))
.idempotentRepository("kafkaIdempotentRepository")
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithCustomSerializerIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithCustomSerializerIT.java
index 2608054..2e80a8d 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithCustomSerializerIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithCustomSerializerIT.java
@@ -17,8 +17,6 @@
package org.apache.camel.component.kafka.integration;
import java.util.Arrays;
-import java.util.concurrent.ExecutionException;
-import java.util.concurrent.TimeoutException;
import org.apache.camel.BindToRegistry;
import org.apache.camel.Endpoint;
@@ -53,7 +51,7 @@ public class KafkaConsumerIdempotentWithCustomSerializerIT extends KafkaConsumer
private int size = 200;
@BeforeEach
- public void before() throws ExecutionException, InterruptedException, TimeoutException {
+ public void before() {
kafkaIdempotentRepository.clear();
kafkaAdminClient.deleteTopics(Arrays.asList(TOPIC, "TEST_IDEMPOTENT")).all();
doSend(size, TOPIC);
@@ -65,7 +63,7 @@ public class KafkaConsumerIdempotentWithCustomSerializerIT extends KafkaConsumer
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithProcessorIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithProcessorIT.java
index 95dc245..4a5f9ff 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithProcessorIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerIdempotentWithProcessorIT.java
@@ -18,8 +18,6 @@ package org.apache.camel.component.kafka.integration;
import java.math.BigInteger;
import java.util.Arrays;
-import java.util.concurrent.ExecutionException;
-import java.util.concurrent.TimeoutException;
import org.apache.camel.BindToRegistry;
import org.apache.camel.Endpoint;
@@ -52,7 +50,7 @@ public class KafkaConsumerIdempotentWithProcessorIT extends KafkaConsumerIdempot
private int size = 200;
@BeforeEach
- public void before() throws ExecutionException, InterruptedException, TimeoutException {
+ public void before() {
kafkaIdempotentRepository.clear();
kafkaAdminClient.deleteTopics(Arrays.asList(TOPIC, "TEST_IDEMPOTENT")).all();
doSend(size, TOPIC);
@@ -65,12 +63,12 @@ public class KafkaConsumerIdempotentWithProcessorIT extends KafkaConsumerIdempot
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(from).routeId("idemp-with-prop")
.process(exchange -> {
byte[] id = exchange.getIn().getHeader("id", byte[].class);
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerLastRecordHeaderIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerLastRecordHeaderIT.java
index 13ec664..5d30d5e 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerLastRecordHeaderIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerLastRecordHeaderIT.java
@@ -84,10 +84,10 @@ public class KafkaConsumerLastRecordHeaderIT extends BaseEmbeddedKafkaTestSuppor
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("kafka:" + TOPIC + "?groupId=A&autoOffsetReset=earliest&autoCommitEnable=false").to("mock:result");
}
};
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerManualCommitIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerManualCommitIT.java
index 5334aa5..e57e25f 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerManualCommitIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerManualCommitIT.java
@@ -65,11 +65,11 @@ public class KafkaConsumerManualCommitIT extends BaseEmbeddedKafkaTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(from).routeId("foo").to(to).process(e -> {
KafkaManualCommit manual = e.getIn().getHeader(KafkaConstants.MANUAL_COMMIT, KafkaManualCommit.class);
assertNotNull(manual);
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerRebalanceIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerRebalanceIT.java
index 4fbef30..b56211f 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerRebalanceIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerRebalanceIT.java
@@ -43,7 +43,7 @@ public class KafkaConsumerRebalanceIT extends BaseEmbeddedKafkaTestSupport {
private CountDownLatch messagesLatch;
@Override
- protected void doPreSetup() throws Exception {
+ protected void doPreSetup() {
messagesLatch = new CountDownLatch(1);
stateRepository = new OffsetStateRepository(messagesLatch);
}
@@ -63,10 +63,10 @@ public class KafkaConsumerRebalanceIT extends BaseEmbeddedKafkaTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("kafka:" + TOPIC + "?groupId=" + TOPIC + "_GROUP" + "&autoCommitIntervalMs=1000"
+ "&autoOffsetReset=latest" + "&consumersCount=1"
+ "&offsetRepository=#offset").routeId("consumer-rebalance-route").to("mock:result");
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerTopicIsPatternIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerTopicIsPatternIT.java
index 5c4702a..ebe39dc 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerTopicIsPatternIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerTopicIsPatternIT.java
@@ -65,11 +65,11 @@ public class KafkaConsumerTopicIsPatternIT extends BaseEmbeddedKafkaTestSupport
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(from).to(to);
}
};
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerWithResumeRouteStrategyIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerWithResumeRouteStrategyIT.java
index dbc9d91..02bccec 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerWithResumeRouteStrategyIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaConsumerWithResumeRouteStrategyIT.java
@@ -216,10 +216,10 @@ public class KafkaConsumerWithResumeRouteStrategyIT extends BaseEmbeddedKafkaTes
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("kafka:" + TOPIC + "?groupId=" + TOPIC + "_GROUP&autoCommitIntervalMs=1000"
+ "&autoOffsetReset=earliest&consumersCount=1")
.routeId("resume-strategy-route")
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaProducerFullIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaProducerFullIT.java
index e62fe61..c17cd47 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaProducerFullIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaProducerFullIT.java
@@ -16,7 +16,6 @@
*/
package org.apache.camel.component.kafka.integration;
-import java.io.IOException;
import java.nio.ByteBuffer;
import java.time.Duration;
import java.util.ArrayList;
@@ -141,10 +140,10 @@ public class KafkaProducerFullIT extends BaseEmbeddedKafkaTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:startStrings").to(toStrings).to(mockEndpoint);
from("direct:startStrings2").to(toStrings2).to(mockEndpoint);
@@ -161,7 +160,7 @@ public class KafkaProducerFullIT extends BaseEmbeddedKafkaTestSupport {
}
@Test
- public void producedStringMessageIsReceivedByKafka() throws InterruptedException, IOException {
+ public void producedStringMessageIsReceivedByKafka() throws InterruptedException {
int messageInTopic = 10;
int messageInOtherTopic = 5;
@@ -192,7 +191,7 @@ public class KafkaProducerFullIT extends BaseEmbeddedKafkaTestSupport {
}
@Test
- public void producedString2MessageIsReceivedByKafka() throws InterruptedException, IOException {
+ public void producedString2MessageIsReceivedByKafka() throws InterruptedException {
int messageInTopic = 10;
int messageInOtherTopic = 5;
@@ -223,7 +222,7 @@ public class KafkaProducerFullIT extends BaseEmbeddedKafkaTestSupport {
}
@Test
- public void producedStringMessageIsIntercepted() throws InterruptedException, IOException {
+ public void producedStringMessageIsIntercepted() throws InterruptedException {
int messageInTopic = 10;
int messageInOtherTopic = 5;
@@ -244,7 +243,7 @@ public class KafkaProducerFullIT extends BaseEmbeddedKafkaTestSupport {
}
@Test
- public void producedStringCollectionMessageIsReceivedByKafka() throws InterruptedException, IOException {
+ public void producedStringCollectionMessageIsReceivedByKafka() throws InterruptedException {
int messageInTopic = 10;
int messageInOtherTopic = 5;
@@ -290,7 +289,7 @@ public class KafkaProducerFullIT extends BaseEmbeddedKafkaTestSupport {
}
@Test
- public void producedBytesMessageIsReceivedByKafka() throws InterruptedException, IOException {
+ public void producedBytesMessageIsReceivedByKafka() throws InterruptedException {
int messageInTopic = 10;
int messageInOtherTopic = 5;
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaToDIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaToDIT.java
index 5037895..8234d5c 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaToDIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaToDIT.java
@@ -24,7 +24,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class KafkaToDIT extends BaseEmbeddedKafkaTestSupport {
@Test
- public void testToD() throws Exception {
+ public void testToD() {
template.sendBodyAndHeader("direct:start", "Hello bar", "where", "bar");
template.sendBodyAndHeader("direct:start", "Hello beer", "where", "beer");
@@ -34,10 +34,10 @@ public class KafkaToDIT extends BaseEmbeddedKafkaTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// route message dynamic using toD
from("direct:start").toD("kafka://${header.where}");
}
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryEagerIT.java b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryEagerIT.java
index 9fb1e4e8..a859306 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryEagerIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryEagerIT.java
@@ -46,10 +46,10 @@ public class KafkaIdempotentRepositoryEagerIT extends BaseEmbeddedKafkaTestSuppo
private MockEndpoint mockBefore;
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:in").to("mock:before").idempotentConsumer(header("id"))
.idempotentRepository("kafkaIdempotentRepository").to("mock:out").end();
}
@@ -57,7 +57,7 @@ public class KafkaIdempotentRepositoryEagerIT extends BaseEmbeddedKafkaTestSuppo
}
@Test
- public void testRemovesDuplicates() throws InterruptedException {
+ public void testRemovesDuplicates() {
for (int i = 0; i < 10; i++) {
template.sendBodyAndHeader("direct:in", "Test message", "id", i % 5);
}
@@ -69,7 +69,7 @@ public class KafkaIdempotentRepositoryEagerIT extends BaseEmbeddedKafkaTestSuppo
}
@Test
- public void testRollsBackOnException() throws InterruptedException {
+ public void testRollsBackOnException() {
mockOut.whenAnyExchangeReceived(exchange -> {
int id = exchange.getIn().getHeader("id", Integer.class);
if (id == 0) {
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryNonEagerIT.java b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryNonEagerIT.java
index a4f3690..ba3563f 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryNonEagerIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryNonEagerIT.java
@@ -48,10 +48,10 @@ public class KafkaIdempotentRepositoryNonEagerIT extends BaseEmbeddedKafkaTestSu
private MockEndpoint mockBefore;
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:in").to("mock:before").idempotentConsumer(header("id"))
.idempotentRepository("kafkaIdempotentRepository").eager(false).to("mock:out").end();
}
@@ -59,7 +59,7 @@ public class KafkaIdempotentRepositoryNonEagerIT extends BaseEmbeddedKafkaTestSu
}
@Test
- public void testRemovesDuplicates() throws InterruptedException {
+ public void testRemovesDuplicates() {
for (int i = 0; i < 10; i++) {
template.sendBodyAndHeader("direct:in", "Test message", "id", i % 5);
}
@@ -71,7 +71,7 @@ public class KafkaIdempotentRepositoryNonEagerIT extends BaseEmbeddedKafkaTestSu
}
@Test
- public void testRollsBackOnException() throws InterruptedException {
+ public void testRollsBackOnException() {
mockOut.whenAnyExchangeReceived(exchange -> {
int id = exchange.getIn().getHeader("id", Integer.class);
if (id == 0) {
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryPersistenceIT.java b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryPersistenceIT.java
index 98b82f7..dfb8d8e 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryPersistenceIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaIdempotentRepositoryPersistenceIT.java
@@ -65,7 +65,7 @@ public class KafkaIdempotentRepositoryPersistenceIT extends BaseEmbeddedKafkaTes
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
[camel] 06/09: CAMEL-17763: cleaned up unused exceptions in camel-couchbase
Posted by or...@apache.org.
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 7d6bdd0442866143a965e8774e65829d96bdda72
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Mar 8 12:33:31 2022 +0100
CAMEL-17763: cleaned up unused exceptions in camel-couchbase
---
.../camel/component/couchbase/CouchbaseEndpointTest.java | 8 ++++----
.../camel/component/couchbase/CouchbaseProducerTest.java | 12 ++++++------
.../couchbase/integration/ConsumeMessagesWithLimitIT.java | 4 ++--
.../couchbase/integration/ProduceMessagesSimpleIT.java | 2 +-
.../couchbase/integration/ProduceMessagesWithAutoIDIT.java | 4 ++--
.../component/couchbase/integration/RemoveMessagesIT.java | 4 ++--
6 files changed, 17 insertions(+), 17 deletions(-)
diff --git a/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/CouchbaseEndpointTest.java b/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/CouchbaseEndpointTest.java
index 646def3..bf050e2 100644
--- a/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/CouchbaseEndpointTest.java
+++ b/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/CouchbaseEndpointTest.java
@@ -45,7 +45,7 @@ public class CouchbaseEndpointTest {
}
@Test
- public void testHostnameRequired() throws Exception {
+ public void testHostnameRequired() {
final CouchbaseComponent component = new CouchbaseComponent();
assertThrows(IllegalArgumentException.class,
@@ -55,7 +55,7 @@ public class CouchbaseEndpointTest {
}
@Test
- public void testSchemeRequired() throws Exception {
+ public void testSchemeRequired() {
final CouchbaseComponent component = new CouchbaseComponent();
assertThrows(IllegalArgumentException.class,
@@ -70,7 +70,7 @@ public class CouchbaseEndpointTest {
}
@Test
- public void testCouchbaseEndpointWithoutProtocol() throws Exception {
+ public void testCouchbaseEndpointWithoutProtocol() {
final CouchbaseComponent component = new CouchbaseComponent();
assertThrows(IllegalArgumentException.class,
@@ -85,7 +85,7 @@ public class CouchbaseEndpointTest {
}
@Test
- public void testCouchbaseEndpointCreateProducer() throws Exception {
+ public void testCouchbaseEndpointCreateProducer() {
Map<String, Object> params = new HashMap<>();
params.put("bucket", "bucket");
diff --git a/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/CouchbaseProducerTest.java b/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/CouchbaseProducerTest.java
index bbc4710..bbb7ea1 100644
--- a/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/CouchbaseProducerTest.java
+++ b/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/CouchbaseProducerTest.java
@@ -74,7 +74,7 @@ public class CouchbaseProducerTest {
private CouchbaseProducer producer;
@BeforeEach
- public void before() throws Exception {
+ public void before() {
lenient().when(endpoint.getProducerRetryAttempts()).thenReturn(CouchbaseConstants.DEFAULT_PRODUCER_RETRIES);
lenient().when(endpoint.getProducerRetryAttempts()).thenReturn(3);
lenient().when(endpoint.getProducerRetryPause()).thenReturn(200);
@@ -85,31 +85,31 @@ public class CouchbaseProducerTest {
}
@Test
- public void testBodyMandatory() throws Exception {
+ public void testBodyMandatory() {
assertThrows(CouchbaseException.class,
() -> producer.process(exchange));
}
@Test
- public void testPersistToLowerThanSupported() throws Exception {
+ public void testPersistToLowerThanSupported() {
assertThrows(IllegalArgumentException.class,
() -> new CouchbaseProducer(endpoint, client, -1, 0));
}
@Test
- public void testPersistToHigherThanSupported() throws Exception {
+ public void testPersistToHigherThanSupported() {
assertThrows(IllegalArgumentException.class,
() -> new CouchbaseProducer(endpoint, client, 5, 0));
}
@Test
- public void testReplicateToLowerThanSupported() throws Exception {
+ public void testReplicateToLowerThanSupported() {
assertThrows(IllegalArgumentException.class,
() -> new CouchbaseProducer(endpoint, client, 0, -1));
}
@Test
- public void testReplicateToHigherThanSupported() throws Exception {
+ public void testReplicateToHigherThanSupported() {
assertThrows(IllegalArgumentException.class,
() -> new CouchbaseProducer(endpoint, client, 0, 4));
}
diff --git a/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/ConsumeMessagesWithLimitIT.java b/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/ConsumeMessagesWithLimitIT.java
index 4f58e6a..0170aed 100644
--- a/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/ConsumeMessagesWithLimitIT.java
+++ b/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/ConsumeMessagesWithLimitIT.java
@@ -43,10 +43,10 @@ public class ConsumeMessagesWithLimitIT extends CouchbaseIntegrationTestBase {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(String.format("%s&designDocumentName=%s&viewName=%s&limit=10", getConnectionUri(), bucketName, bucketName))
.log("message received")
.to("mock:result");
diff --git a/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/ProduceMessagesSimpleIT.java b/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/ProduceMessagesSimpleIT.java
index 26f63c5..03507ce 100644
--- a/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/ProduceMessagesSimpleIT.java
+++ b/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/ProduceMessagesSimpleIT.java
@@ -41,7 +41,7 @@ public class ProduceMessagesSimpleIT extends CouchbaseIntegrationTestBase {
protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// need couchbase installed on localhost
from("direct:start").setHeader(CouchbaseConstants.HEADER_ID, constant("SimpleDocument_1"))
diff --git a/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/ProduceMessagesWithAutoIDIT.java b/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/ProduceMessagesWithAutoIDIT.java
index 8f1fc0c..118d8f4 100644
--- a/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/ProduceMessagesWithAutoIDIT.java
+++ b/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/ProduceMessagesWithAutoIDIT.java
@@ -34,10 +34,10 @@ public class ProduceMessagesWithAutoIDIT extends CouchbaseIntegrationTestBase {
}
@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(
getConnectionUri() + "&autoStartIdForInserts=true&startingIdForInsertsFrom=1000")
.to("mock:result");
diff --git a/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/RemoveMessagesIT.java b/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/RemoveMessagesIT.java
index 8951052..3199ffb 100644
--- a/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/RemoveMessagesIT.java
+++ b/components/camel-couchbase/src/test/java/org/apache/camel/component/couchbase/integration/RemoveMessagesIT.java
@@ -41,10 +41,10 @@ public class RemoveMessagesIT extends CouchbaseIntegrationTestBase {
}
@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(getConnectionUri() + "&operation=" + COUCHBASE_DELETE)
.to("mock:result");
[camel] 07/09: CAMEL-17763: cleaned up unused exceptions in camel-couchdb
Posted by or...@apache.org.
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 39adbd2c78fe6cffd0e915dffbfb19f60590c1e2
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Mar 8 12:35:11 2022 +0100
CAMEL-17763: cleaned up unused exceptions in camel-couchdb
---
.../java/org/apache/camel/component/couchdb/CouchDbProducerTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/components/camel-couchdb/src/test/java/org/apache/camel/component/couchdb/CouchDbProducerTest.java b/components/camel-couchdb/src/test/java/org/apache/camel/component/couchdb/CouchDbProducerTest.java
index 276b62a..4e9ffea 100644
--- a/components/camel-couchdb/src/test/java/org/apache/camel/component/couchdb/CouchDbProducerTest.java
+++ b/components/camel-couchdb/src/test/java/org/apache/camel/component/couchdb/CouchDbProducerTest.java
@@ -141,7 +141,7 @@ public class CouchDbProducerTest {
when(client.save(any())).thenAnswer(new Answer<Response>() {
@Override
- public Response answer(InvocationOnMock invocation) throws Throwable {
+ public Response answer(InvocationOnMock invocation) {
assertTrue(invocation.getArguments()[0] instanceof JsonElement,
invocation.getArguments()[0].getClass() + " but wanted " + JsonElement.class);
return new Response();