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/09 14:24:27 UTC
[camel] 07/07: CAMEL-17763: cleaned up unused exceptions in camel-sql
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 dd90ad24a5d120df71efed41106609b4f9fa3e9b
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Wed Mar 9 14:28:22 2022 +0100
CAMEL-17763: cleaned up unused exceptions in camel-sql
---
.../camel/component/sql/SqlAggregateBatchTest.java | 2 +-
.../sql/SqlConsumerDeleteBatchCompleteTest.java | 4 ++--
.../component/sql/SqlConsumerDeleteFailedTest.java | 6 +++---
.../camel/component/sql/SqlConsumerDeleteTest.java | 4 ++--
.../component/sql/SqlConsumerDeleteTransformTest.java | 4 ++--
.../component/sql/SqlConsumerDynamicParameterTest.java | 4 ++--
.../component/sql/SqlConsumerFromClasspathTest.java | 4 ++--
.../sql/SqlConsumerMaxMessagesPerPollTest.java | 4 ++--
.../sql/SqlConsumerOutputTypeSelectListTest.java | 4 ++--
.../SqlConsumerOutputTypeSelectListWithClassTest.java | 4 ++--
.../sql/SqlConsumerOutputTypeSelectOneTest.java | 12 ++++++------
.../sql/SqlConsumerOutputTypeStreamListTest.java | 2 +-
.../apache/camel/component/sql/SqlConsumerTest.java | 4 ++--
.../camel/component/sql/SqlDataSourceRefTest.java | 4 ++--
.../apache/camel/component/sql/SqlDataSourceTest.java | 4 ++--
.../camel/component/sql/SqlEndpointLikeTest.java | 6 +++---
.../sql/SqlEndpointMisconfigureDataSourceTest.java | 2 +-
.../apache/camel/component/sql/SqlEndpointTest.java | 2 +-
.../camel/component/sql/SqlGeneratedKeysTest.java | 18 +++++++++---------
.../camel/component/sql/SqlPreserveHeaderTest.java | 2 +-
.../SqlProducerAlwaysPopulateStatementFalseTest.java | 2 +-
.../sql/SqlProducerAlwaysPopulateStatementTest.java | 2 +-
.../camel/component/sql/SqlProducerAndInTest.java | 4 ++--
.../camel/component/sql/SqlProducerConcurrentTest.java | 4 ++--
.../sql/SqlProducerExpressionParameterTest.java | 2 +-
.../component/sql/SqlProducerInExpressionTest.java | 4 ++--
.../sql/SqlProducerInMultiExpressionTest.java | 4 ++--
.../sql/SqlProducerInMultiQueryEndpointTest.java | 4 ++--
.../camel/component/sql/SqlProducerInMultiTest.java | 4 ++--
.../component/sql/SqlProducerInQueryEndpointTest.java | 4 ++--
.../sql/SqlProducerInSimpleExpressionTest.java | 4 ++--
.../apache/camel/component/sql/SqlProducerInTest.java | 4 ++--
.../camel/component/sql/SqlProducerInsertNullTest.java | 2 +-
.../camel/component/sql/SqlProducerJSONTest.java | 2 +-
.../sql/SqlProducerNamedParameterNotExistTest.java | 6 +++---
.../component/sql/SqlProducerNamedParameterTest.java | 2 +-
.../component/sql/SqlProducerNamedParametersTest.java | 2 +-
.../camel/component/sql/SqlProducerNoopTest.java | 4 ++--
.../component/sql/SqlProducerNullBodyHeaderTest.java | 2 +-
.../camel/component/sql/SqlProducerNullBodyTest.java | 2 +-
.../component/sql/SqlProducerOutputHeaderTest.java | 4 ++--
.../sql/SqlProducerOutputHeaderWithQueryTest.java | 4 ++--
.../sql/SqlProducerOutputTypeSelectListTest.java | 2 +-
.../SqlProducerOutputTypeSelectListWithClassTest.java | 2 +-
.../SqlProducerOutputTypeSelectOneNoResultTest.java | 2 +-
.../sql/SqlProducerOutputTypeSelectOneTest.java | 12 ++++++------
.../sql/SqlProducerOutputTypeStreamListTest.java | 2 +-
.../component/sql/SqlProducerParametersCountTest.java | 4 ++--
.../component/sql/SqlProducerReuseParameterTest.java | 4 ++--
.../camel/component/sql/SqlProducerSeparatorTest.java | 2 +-
.../apache/camel/component/sql/SqlProducerToDTest.java | 4 ++--
.../sql/SqlProducerWhereIssueClasspathTest.java | 4 ++--
.../camel/component/sql/SqlProducerWhereIssueTest.java | 4 ++--
.../org/apache/camel/component/sql/SqlRouteTest.java | 2 +-
.../camel/component/sql/SqlTransactedRouteTest.java | 18 +++++++++---------
.../component/sql/stored/ProducerBatchInvalidTest.java | 2 +-
.../camel/component/sql/stored/ProducerBatchTest.java | 4 ++--
.../component/sql/stored/ProducerBodyArrayTest.java | 4 ++--
.../component/sql/stored/ProducerClasspathTest.java | 4 ++--
.../camel/component/sql/stored/ProducerInOutTest.java | 4 ++--
.../component/sql/stored/ProducerQueryTimeoutTest.java | 4 ++--
.../camel/component/sql/stored/ProducerTest.java | 4 ++--
.../stored/ProducerUseMessageBodyForTemplateTest.java | 4 ++--
.../sql/stored/SqlFunctionDataSourceTest.java | 4 ++--
.../component/sql/stored/SqlStoredDataSourceTest.java | 6 +++---
.../camel/component/sql/stored/TemplateCacheTest.java | 2 +-
.../jdbc/AbstractJdbcAggregationTestSupport.java | 4 ++--
.../jdbc/ClusteredJdbcAggregateRecoverTest.java | 6 +++---
.../jdbc/JdbcAggregateDiscardOnTimeoutTest.java | 4 ++--
.../jdbc/JdbcAggregateForceCompletionHeaderTest.java | 4 ++--
.../jdbc/JdbcAggregateLoadAndRecoverTest.java | 6 +++---
.../jdbc/JdbcAggregateLoadConcurrentTest.java | 4 ++--
.../aggregate/jdbc/JdbcAggregateLoadTest.java | 4 ++--
.../JdbcAggregateNotLostRemovedWhenConfirmedTest.java | 4 ++--
.../aggregate/jdbc/JdbcAggregateNotLostTest.java | 4 ++--
...dbcAggregateRecoverDeadLetterChannelFailedTest.java | 4 ++--
.../JdbcAggregateRecoverDeadLetterChannelTest.java | 4 ++--
.../aggregate/jdbc/JdbcAggregateRecoverTest.java | 6 +++---
.../JdbcAggregateRecoverWithRedeliveryPolicyTest.java | 6 +++---
.../jdbc/JdbcAggregateRecoverWithSedaTest.java | 6 +++---
.../jdbc/JdbcAggregateSerializedHeadersTest.java | 4 ++--
.../aggregate/jdbc/JdbcAggregateStoreAsText2Test.java | 6 +++---
.../aggregate/jdbc/JdbcAggregateStoreAsTextTest.java | 6 +++---
.../processor/aggregate/jdbc/JdbcAggregateTest.java | 4 ++--
.../JdbcAggregateTimeoutCompletionRestartTest.java | 4 ++--
.../JdbcAggregationRepositoryRecoverExistingTest.java | 2 +-
.../processor/aggregate/jdbc/JdbcGrowIssueTest.java | 2 +-
...SpringAggregateRecoverWithRedeliveryPolicyTest.java | 2 +-
.../idempotent/jdbc/JdbcMessageIdRepositoryTest.java | 4 ++--
89 files changed, 186 insertions(+), 186 deletions(-)
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlAggregateBatchTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlAggregateBatchTest.java
index 72d69a6..7ca36c0 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlAggregateBatchTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlAggregateBatchTest.java
@@ -84,7 +84,7 @@ public class SqlAggregateBatchTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDeleteBatchCompleteTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDeleteBatchCompleteTest.java
index 07fb055..7ab3533 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDeleteBatchCompleteTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDeleteBatchCompleteTest.java
@@ -79,10 +79,10 @@ public class SqlConsumerDeleteBatchCompleteTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
from("sql:select * from projects order by id?initialDelay=0&delay=50&consumer.onConsumeBatchComplete=delete from projects")
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDeleteFailedTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDeleteFailedTest.java
index a52c889..c6e418e 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDeleteFailedTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDeleteFailedTest.java
@@ -88,10 +88,10 @@ public class SqlConsumerDeleteFailedTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
from("sql:select * from projects where license <> 'BAD' order by id"
@@ -100,7 +100,7 @@ public class SqlConsumerDeleteFailedTest extends CamelTestSupport {
+ "&consumer.onConsumeFailed=update projects set license = 'BAD' where id = :#id")
.process(new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
Object project = exchange.getIn().getBody(Map.class).get("PROJECT");
if ("AMQ".equals(project)) {
throw new IllegalArgumentException("Cannot handled AMQ");
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDeleteTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDeleteTest.java
index ec6514a..b4e4ed3 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDeleteTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDeleteTest.java
@@ -93,10 +93,10 @@ public class SqlConsumerDeleteTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
from("sql:select * from projects order by id?initialDelay=0&delay=50&consumer.onConsume=delete from projects where id = :#id")
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDeleteTransformTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDeleteTransformTest.java
index ffc4673..4f62ad7 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDeleteTransformTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDeleteTransformTest.java
@@ -79,10 +79,10 @@ public class SqlConsumerDeleteTransformTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
// even if we transform the exchange we can still do onConsume as we have the original data at
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDynamicParameterTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDynamicParameterTest.java
index ea1b727..e7f8142 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDynamicParameterTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerDynamicParameterTest.java
@@ -83,10 +83,10 @@ public class SqlConsumerDynamicParameterTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
from("sql:select * from projects where id = :#${bean:myIdGenerator.nextId}?initialDelay=0&delay=50")
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerFromClasspathTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerFromClasspathTest.java
index a1d477c..4497442 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerFromClasspathTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerFromClasspathTest.java
@@ -24,10 +24,10 @@ import org.apache.camel.builder.RouteBuilder;
public class SqlConsumerFromClasspathTest extends SqlConsumerTest {
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
from("sql:classpath:sql/selectProjects.sql")
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerMaxMessagesPerPollTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerMaxMessagesPerPollTest.java
index b3bab1a..3a5a1fc 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerMaxMessagesPerPollTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerMaxMessagesPerPollTest.java
@@ -91,9 +91,9 @@ public class SqlConsumerMaxMessagesPerPollTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
getContext().setTracing(true);
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerOutputTypeSelectListTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerOutputTypeSelectListTest.java
index 5c9b1d8..3488671 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerOutputTypeSelectListTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerOutputTypeSelectListTest.java
@@ -85,10 +85,10 @@ public class SqlConsumerOutputTypeSelectListTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
from("sql:select * from projects order by id?outputType=SelectList&initialDelay=0&delay=50")
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerOutputTypeSelectListWithClassTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerOutputTypeSelectListWithClassTest.java
index dac1cca..597e5af 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerOutputTypeSelectListWithClassTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerOutputTypeSelectListWithClassTest.java
@@ -86,10 +86,10 @@ public class SqlConsumerOutputTypeSelectListWithClassTest extends CamelTestSuppo
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
from("sql:select * from projects order by id?outputType=SelectList&outputClass=org.apache.camel.component.sql.ProjectModel&initialDelay=0&delay=50")
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerOutputTypeSelectOneTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerOutputTypeSelectOneTest.java
index 986ec1e..34f0a28 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerOutputTypeSelectOneTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerOutputTypeSelectOneTest.java
@@ -42,7 +42,7 @@ public class SqlConsumerOutputTypeSelectOneTest {
private DefaultCamelContext camel1;
@BeforeEach
- public void setUp() throws Exception {
+ public void setUp() {
db = new EmbeddedDatabaseBuilder()
.setName(getClass().getSimpleName())
.setType(EmbeddedDatabaseType.DERBY)
@@ -54,7 +54,7 @@ public class SqlConsumerOutputTypeSelectOneTest {
}
@AfterEach
- public void tearDown() throws Exception {
+ public void tearDown() {
camel1.stop();
db.shutdown();
}
@@ -63,7 +63,7 @@ public class SqlConsumerOutputTypeSelectOneTest {
public void testSelectOneWithClass() throws Exception {
camel1.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("sql:select * from projects where id=3?outputType=SelectOne&outputClass=org.apache.camel.component.sql.ProjectModel&initialDelay=0&delay=50")
.to("mock:result");
}
@@ -87,7 +87,7 @@ public class SqlConsumerOutputTypeSelectOneTest {
public void testSelectOneWithoutClass() throws Exception {
camel1.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("sql:select * from projects where id=3?outputType=SelectOne&initialDelay=0&delay=50")
.to("mock:result");
}
@@ -111,7 +111,7 @@ public class SqlConsumerOutputTypeSelectOneTest {
public void testSelectOneSingleColumn() throws Exception {
camel1.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("sql:select project from projects where id=3?outputType=SelectOne&initialDelay=0&delay=50")
.to("mock:result");
}
@@ -133,7 +133,7 @@ public class SqlConsumerOutputTypeSelectOneTest {
public void testSelectOneSingleColumnCount() throws Exception {
camel1.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("sql:select count(*) from projects?outputType=SelectOne&initialDelay=0&delay=50")
.to("mock:result");
}
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerOutputTypeStreamListTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerOutputTypeStreamListTest.java
index 571a1a7..2abb198 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerOutputTypeStreamListTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerOutputTypeStreamListTest.java
@@ -97,7 +97,7 @@ public class SqlConsumerOutputTypeStreamListTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerTest.java
index 22202a4..18681da 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlConsumerTest.java
@@ -78,10 +78,10 @@ public class SqlConsumerTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
from("sql:select * from projects order by id?initialDelay=0&delay=50")
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlDataSourceRefTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlDataSourceRefTest.java
index acd727b..39560be 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlDataSourceRefTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlDataSourceRefTest.java
@@ -38,7 +38,7 @@ public class SqlDataSourceRefTest extends CamelTestSupport {
private EmbeddedDatabase db;
@Override
- protected Registry createCamelRegistry() throws Exception {
+ protected Registry createCamelRegistry() {
SimpleRegistry reg = new SimpleRegistry();
// START SNIPPET: e2
@@ -88,7 +88,7 @@ public class SqlDataSourceRefTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
// START SNIPPET: e1
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlDataSourceTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlDataSourceTest.java
index 977328d..4317b6e 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlDataSourceTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlDataSourceTest.java
@@ -38,7 +38,7 @@ public class SqlDataSourceTest extends CamelTestSupport {
private EmbeddedDatabase db;
@Override
- protected Registry createCamelRegistry() throws Exception {
+ protected Registry createCamelRegistry() {
Registry reg = new SimpleRegistry();
// this is the database we create with some initial data for our unit test
@@ -80,7 +80,7 @@ public class SqlDataSourceTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("direct:simple")
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlEndpointLikeTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlEndpointLikeTest.java
index 995aea2..e93727e 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlEndpointLikeTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlEndpointLikeTest.java
@@ -42,7 +42,7 @@ public class SqlEndpointLikeTest extends CamelTestSupport {
}
@Override
- protected Registry createCamelRegistry() throws Exception {
+ protected Registry createCamelRegistry() {
Registry reg = new SimpleRegistry();
// this is the database we create with some initial data for our unit test
db = new EmbeddedDatabaseBuilder()
@@ -61,9 +61,9 @@ public class SqlEndpointLikeTest 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")
.to("sql:select * from projects where license like 'A%25'?dataSource=#jdbc/myDataSource")
.split(body())
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlEndpointMisconfigureDataSourceTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlEndpointMisconfigureDataSourceTest.java
index c546139..75fc845 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlEndpointMisconfigureDataSourceTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlEndpointMisconfigureDataSourceTest.java
@@ -61,7 +61,7 @@ public class SqlEndpointMisconfigureDataSourceTest extends CamelTestSupport {
context.getRegistry().bind("myDataSource", db);
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to("sql:foo?dataSource=#myDataSource")
.to("mock:result");
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlEndpointTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlEndpointTest.java
index b93b86a..5c6872a 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlEndpointTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlEndpointTest.java
@@ -61,7 +61,7 @@ public class SqlEndpointTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() throws Exception {
SqlEndpoint sql = new SqlEndpoint();
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlGeneratedKeysTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlGeneratedKeysTest.java
index 1c645a4..1657b0c 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlGeneratedKeysTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlGeneratedKeysTest.java
@@ -61,10 +61,10 @@ public class SqlGeneratedKeysTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
from("direct:insert").to("sql:insert into projects (project, license, description) values (#, #, #)");
from("direct:batch").to("sql:insert into projects (project, license, description) values (#, #, #)?batch=true");
@@ -76,7 +76,7 @@ public class SqlGeneratedKeysTest extends CamelTestSupport {
@Test
@SuppressWarnings("unchecked")
- public void testRetrieveGeneratedKey() throws Exception {
+ public void testRetrieveGeneratedKey() {
// first we create our exchange using the endpoint
Endpoint endpoint = context.getEndpoint("direct:insert");
@@ -108,7 +108,7 @@ public class SqlGeneratedKeysTest extends CamelTestSupport {
@Test
@SuppressWarnings("unchecked")
- public void testRetrieveGeneratedKeys() throws Exception {
+ public void testRetrieveGeneratedKeys() {
// first we create our exchange using the endpoint
Endpoint endpoint = context.getEndpoint("direct:insert2");
@@ -141,7 +141,7 @@ public class SqlGeneratedKeysTest extends CamelTestSupport {
@Test
@SuppressWarnings("unchecked")
- public void testRetrieveGeneratedKeysForBatch() throws Exception {
+ public void testRetrieveGeneratedKeysForBatch() {
// first we create our exchange using the endpoint
Endpoint endpoint = context.getEndpoint("direct:batch");
@@ -181,7 +181,7 @@ public class SqlGeneratedKeysTest extends CamelTestSupport {
@Test
@SuppressWarnings("unchecked")
- public void testRetrieveGeneratedKeyWithStringGeneratedColumns() throws Exception {
+ public void testRetrieveGeneratedKeyWithStringGeneratedColumns() {
// first we create our exchange using the endpoint
Endpoint endpoint = context.getEndpoint("direct:insert");
@@ -213,7 +213,7 @@ public class SqlGeneratedKeysTest extends CamelTestSupport {
@Test
@SuppressWarnings("unchecked")
- public void testRetrieveGeneratedKeyWithIntGeneratedColumns() throws Exception {
+ public void testRetrieveGeneratedKeyWithIntGeneratedColumns() {
// first we create our exchange using the endpoint
Endpoint endpoint = context.getEndpoint("direct:insert");
@@ -243,7 +243,7 @@ public class SqlGeneratedKeysTest extends CamelTestSupport {
}
@Test
- public void testGivenAnInvalidGeneratedColumnsHeaderThenAnExceptionIsThrown() throws Exception {
+ public void testGivenAnInvalidGeneratedColumnsHeaderThenAnExceptionIsThrown() {
// first we create our exchange using the endpoint
Endpoint endpoint = context.getEndpoint("direct:insert");
@@ -263,7 +263,7 @@ public class SqlGeneratedKeysTest extends CamelTestSupport {
@Test
@SuppressWarnings("unchecked")
- public void testNoKeysForSelect() throws Exception {
+ public void testNoKeysForSelect() {
// first we create our exchange using the endpoint
Endpoint endpoint = context.getEndpoint("direct:select");
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlPreserveHeaderTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlPreserveHeaderTest.java
index 72920376..eb3dab4 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlPreserveHeaderTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlPreserveHeaderTest.java
@@ -61,7 +61,7 @@ public class SqlPreserveHeaderTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerAlwaysPopulateStatementFalseTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerAlwaysPopulateStatementFalseTest.java
index debfbc0..b846ded 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerAlwaysPopulateStatementFalseTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerAlwaysPopulateStatementFalseTest.java
@@ -93,7 +93,7 @@ public class SqlProducerAlwaysPopulateStatementFalseTest extends CamelTestSuppor
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerAlwaysPopulateStatementTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerAlwaysPopulateStatementTest.java
index 8219659..ec2ed45 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerAlwaysPopulateStatementTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerAlwaysPopulateStatementTest.java
@@ -92,7 +92,7 @@ public class SqlProducerAlwaysPopulateStatementTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerAndInTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerAndInTest.java
index 42628ee..d9dad67 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerAndInTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerAndInTest.java
@@ -111,10 +111,10 @@ public class SqlProducerAndInTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// required for the sql component
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerConcurrentTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerConcurrentTest.java
index cc55c8a..ac469f9 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerConcurrentTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerConcurrentTest.java
@@ -64,7 +64,7 @@ public class SqlProducerConcurrentTest extends CamelTestSupport {
for (int i = 0; i < files; i++) {
final int index = i;
Future<List<?>> out = executor.submit(new Callable<List<?>>() {
- public List<?> call() throws Exception {
+ public List<?> call() {
int id = (index % 3) + 1;
return template.requestBody("direct:simple", "" + id, List.class);
}
@@ -109,7 +109,7 @@ public class SqlProducerConcurrentTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerExpressionParameterTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerExpressionParameterTest.java
index 0ba1541..c8884d8 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerExpressionParameterTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerExpressionParameterTest.java
@@ -94,7 +94,7 @@ public class SqlProducerExpressionParameterTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInExpressionTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInExpressionTest.java
index 4c23ca7..ba49392 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInExpressionTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInExpressionTest.java
@@ -21,10 +21,10 @@ import org.apache.camel.builder.RouteBuilder;
public class SqlProducerInExpressionTest extends SqlProducerInTest {
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// required for the sql component
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInMultiExpressionTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInMultiExpressionTest.java
index 2eb2138..08efd00 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInMultiExpressionTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInMultiExpressionTest.java
@@ -21,10 +21,10 @@ import org.apache.camel.builder.RouteBuilder;
public class SqlProducerInMultiExpressionTest extends SqlProducerInMultiTest {
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// required for the sql component
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInMultiQueryEndpointTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInMultiQueryEndpointTest.java
index a626662..a3d4bb2 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInMultiQueryEndpointTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInMultiQueryEndpointTest.java
@@ -21,10 +21,10 @@ import org.apache.camel.builder.RouteBuilder;
public class SqlProducerInMultiQueryEndpointTest extends SqlProducerInMultiTest {
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// required for the sql component
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInMultiTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInMultiTest.java
index 1fd109a..d138873 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInMultiTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInMultiTest.java
@@ -160,10 +160,10 @@ public class SqlProducerInMultiTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// required for the sql component
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInQueryEndpointTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInQueryEndpointTest.java
index 5c64164..f710857 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInQueryEndpointTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInQueryEndpointTest.java
@@ -21,10 +21,10 @@ import org.apache.camel.builder.RouteBuilder;
public class SqlProducerInQueryEndpointTest extends SqlProducerInTest {
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// required for the sql component
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInSimpleExpressionTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInSimpleExpressionTest.java
index c97d55b..2db553f 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInSimpleExpressionTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInSimpleExpressionTest.java
@@ -21,10 +21,10 @@ import org.apache.camel.builder.RouteBuilder;
public class SqlProducerInSimpleExpressionTest extends SqlProducerInTest {
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// required for the sql component
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInTest.java
index 4d52884..3f93fa7 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInTest.java
@@ -111,10 +111,10 @@ public class SqlProducerInTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// required for the sql component
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInsertNullTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInsertNullTest.java
index f268fcb..535d94c 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInsertNullTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerInsertNullTest.java
@@ -82,7 +82,7 @@ public class SqlProducerInsertNullTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerJSONTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerJSONTest.java
index 6a6a680..bb9360d 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerJSONTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerJSONTest.java
@@ -72,7 +72,7 @@ public class SqlProducerJSONTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerNamedParameterNotExistTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerNamedParameterNotExistTest.java
index 89c3f68..20813aa 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerNamedParameterNotExistTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerNamedParameterNotExistTest.java
@@ -55,7 +55,7 @@ public class SqlProducerNamedParameterNotExistTest extends CamelTestSupport {
}
@Test
- public void testNamedParameterNotExistFromBody() throws Exception {
+ public void testNamedParameterNotExistFromBody() {
Map<String, Object> map = new HashMap<>();
map.put("foo", "ASF");
@@ -68,7 +68,7 @@ public class SqlProducerNamedParameterNotExistTest extends CamelTestSupport {
}
@Test
- public void testNamedParameterNotExistFromHeader() throws Exception {
+ public void testNamedParameterNotExistFromHeader() {
try {
template.sendBodyAndHeader("direct:start", "This is a dummy body", "foo", "ASF");
fail("Should have thrown exception");
@@ -78,7 +78,7 @@ public class SqlProducerNamedParameterNotExistTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerNamedParameterTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerNamedParameterTest.java
index cdee8e3..959a7c6 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerNamedParameterTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerNamedParameterTest.java
@@ -96,7 +96,7 @@ public class SqlProducerNamedParameterTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerNamedParametersTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerNamedParametersTest.java
index a9ee011..c1343cd 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerNamedParametersTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerNamedParametersTest.java
@@ -94,7 +94,7 @@ public class SqlProducerNamedParametersTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerNoopTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerNoopTest.java
index 56ab3d7..3d56141 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerNoopTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerNoopTest.java
@@ -98,10 +98,10 @@ public class SqlProducerNoopTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// required for the sql component
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerNullBodyHeaderTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerNullBodyHeaderTest.java
index baae638..1478cf4 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerNullBodyHeaderTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerNullBodyHeaderTest.java
@@ -74,7 +74,7 @@ public class SqlProducerNullBodyHeaderTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerNullBodyTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerNullBodyTest.java
index 29682ee..86726e6 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerNullBodyTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerNullBodyTest.java
@@ -74,7 +74,7 @@ public class SqlProducerNullBodyTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputHeaderTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputHeaderTest.java
index 6243fa1..db9d5fa 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputHeaderTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputHeaderTest.java
@@ -63,10 +63,10 @@ public class SqlProducerOutputHeaderTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// required for the sql component
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputHeaderWithQueryTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputHeaderWithQueryTest.java
index 4363b89..da35d4a 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputHeaderWithQueryTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputHeaderWithQueryTest.java
@@ -63,10 +63,10 @@ public class SqlProducerOutputHeaderWithQueryTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// required for the sql component
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputTypeSelectListTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputTypeSelectListTest.java
index 5faba86..d2c21ac 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputTypeSelectListTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputTypeSelectListTest.java
@@ -81,7 +81,7 @@ public class SqlProducerOutputTypeSelectListTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputTypeSelectListWithClassTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputTypeSelectListWithClassTest.java
index 3c6d27a..aada827 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputTypeSelectListWithClassTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputTypeSelectListWithClassTest.java
@@ -83,7 +83,7 @@ public class SqlProducerOutputTypeSelectListWithClassTest extends CamelTestSuppo
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputTypeSelectOneNoResultTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputTypeSelectOneNoResultTest.java
index 6f7d815..433aa8f 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputTypeSelectOneNoResultTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputTypeSelectOneNoResultTest.java
@@ -63,7 +63,7 @@ public class SqlProducerOutputTypeSelectOneNoResultTest extends CamelTestSupport
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputTypeSelectOneTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputTypeSelectOneTest.java
index 53d21ee..3ca8ce6 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputTypeSelectOneTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputTypeSelectOneTest.java
@@ -40,7 +40,7 @@ public class SqlProducerOutputTypeSelectOneTest {
private DefaultCamelContext camel1;
@BeforeEach
- public void setUp() throws Exception {
+ public void setUp() {
db = new EmbeddedDatabaseBuilder()
.setName(getClass().getSimpleName())
.setType(EmbeddedDatabaseType.DERBY)
@@ -52,7 +52,7 @@ public class SqlProducerOutputTypeSelectOneTest {
}
@AfterEach
- public void tearDown() throws Exception {
+ public void tearDown() {
camel1.stop();
db.shutdown();
}
@@ -61,7 +61,7 @@ public class SqlProducerOutputTypeSelectOneTest {
public void testSelectOneWithClass() throws Exception {
camel1.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to("sql:select * from projects where id=3?outputType=SelectOne&outputClass=org.apache.camel.component.sql.ProjectModel")
.to("mock:result");
@@ -91,7 +91,7 @@ public class SqlProducerOutputTypeSelectOneTest {
public void testSelectOneWithoutClass() throws Exception {
camel1.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to("sql:select * from projects where id=3?outputType=SelectOne")
.to("mock:result");
@@ -121,7 +121,7 @@ public class SqlProducerOutputTypeSelectOneTest {
public void testSelectOneSingleColumn() throws Exception {
camel1.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to("sql:select project from projects where id=3?outputType=SelectOne")
.to("mock:result");
@@ -149,7 +149,7 @@ public class SqlProducerOutputTypeSelectOneTest {
public void testSelectOneSingleColumnCount() throws Exception {
camel1.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to("sql:select count(*) from projects?outputType=SelectOne")
.to("mock:result");
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputTypeStreamListTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputTypeStreamListTest.java
index 76d85dc..e4f69b7 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputTypeStreamListTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerOutputTypeStreamListTest.java
@@ -108,7 +108,7 @@ public class SqlProducerOutputTypeStreamListTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerParametersCountTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerParametersCountTest.java
index de1bddb..4d1e08f 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerParametersCountTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerParametersCountTest.java
@@ -56,7 +56,7 @@ public class SqlProducerParametersCountTest extends CamelTestSupport {
}
@Test
- public void testExplicitParametersCount() throws Exception {
+ public void testExplicitParametersCount() {
MockEndpoint mock = getMockEndpoint("mock:result");
mock.expectedMessageCount(1);
@@ -72,7 +72,7 @@ public class SqlProducerParametersCountTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerReuseParameterTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerReuseParameterTest.java
index c152b93..0e246b5 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerReuseParameterTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerReuseParameterTest.java
@@ -56,7 +56,7 @@ public class SqlProducerReuseParameterTest extends CamelTestSupport {
}
@Test
- public void testReuseParameter() throws Exception {
+ public void testReuseParameter() {
MockEndpoint mock = getMockEndpoint("mock:result");
mock.expectedMessageCount(1);
@@ -72,7 +72,7 @@ public class SqlProducerReuseParameterTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerSeparatorTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerSeparatorTest.java
index 4145951..3244d6d 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerSeparatorTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerSeparatorTest.java
@@ -68,7 +68,7 @@ public class SqlProducerSeparatorTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerToDTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerToDTest.java
index 97b38f4..33a1a33 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerToDTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerToDTest.java
@@ -72,10 +72,10 @@ public class SqlProducerToDTest 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:query")
.setHeader("myQuery", constant("select * from projects where project = :#foo order by id"))
.toD("sql:${header.myQuery}?dataSource=#myDS")
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerWhereIssueClasspathTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerWhereIssueClasspathTest.java
index fa71db0..87cb423 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerWhereIssueClasspathTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerWhereIssueClasspathTest.java
@@ -21,10 +21,10 @@ import org.apache.camel.builder.RouteBuilder;
public class SqlProducerWhereIssueClasspathTest extends SqlProducerWhereIssueTest {
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// required for the sql component
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerWhereIssueTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerWhereIssueTest.java
index 9ef4aef..bd87501 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerWhereIssueTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlProducerWhereIssueTest.java
@@ -73,10 +73,10 @@ public class SqlProducerWhereIssueTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// required for the sql component
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlRouteTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlRouteTest.java
index 743fbe7..fd7ad34 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlRouteTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlRouteTest.java
@@ -274,7 +274,7 @@ public class SqlRouteTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
getContext().getComponent("sql", SqlComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlTransactedRouteTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlTransactedRouteTest.java
index b96b60c..81f06da 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlTransactedRouteTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/SqlTransactedRouteTest.java
@@ -56,7 +56,7 @@ public class SqlTransactedRouteTest extends CamelTestSupport {
}
@Override
- protected Registry createCamelRegistry() throws Exception {
+ protected Registry createCamelRegistry() {
Registry reg = new SimpleRegistry();
db = new EmbeddedDatabaseBuilder()
@@ -87,12 +87,12 @@ public class SqlTransactedRouteTest extends CamelTestSupport {
@Test
public void testCommit() throws Exception {
context.addRoutes(new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").routeId("commit")
.transacted("required")
.to(sqlEndpoint)
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setHeader(SqlConstants.SQL_QUERY,
"insert into customer values('cust2','muellerc')");
}
@@ -103,7 +103,7 @@ public class SqlTransactedRouteTest extends CamelTestSupport {
Exchange exchange = template.send(startEndpoint, new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setHeader(SqlConstants.SQL_QUERY, "insert into customer values('cust1','cmueller')");
}
});
@@ -127,12 +127,12 @@ public class SqlTransactedRouteTest extends CamelTestSupport {
@Test
public void testRollbackAfterExceptionInSecondStatement() throws Exception {
context.addRoutes(new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").routeId("rollback")
.transacted("required")
.to(sqlEndpoint)
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
// primary key violation
exchange.getIn().setHeader(SqlConstants.SQL_QUERY,
"insert into customer values('cust1','muellerc')");
@@ -144,7 +144,7 @@ public class SqlTransactedRouteTest extends CamelTestSupport {
Exchange exchange = template.send(startEndpoint, new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setHeader(SqlConstants.SQL_QUERY, "insert into customer values('cust1','cmueller')");
}
});
@@ -158,7 +158,7 @@ public class SqlTransactedRouteTest extends CamelTestSupport {
@Test
public void testRollbackAfterAnException() throws Exception {
context.addRoutes(new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").routeId("rollback2")
.transacted("required")
.to(sqlEndpoint)
@@ -173,7 +173,7 @@ public class SqlTransactedRouteTest extends CamelTestSupport {
Exchange exchange = template.send(startEndpoint, new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getIn().setHeader(SqlConstants.SQL_QUERY, "insert into customer values('cust1','cmueller')");
}
});
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerBatchInvalidTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerBatchInvalidTest.java
index 8d9dbc4..0ee6b45 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerBatchInvalidTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerBatchInvalidTest.java
@@ -63,7 +63,7 @@ public class ProducerBatchInvalidTest extends CamelTestSupport {
public void shouldInvalid() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// required for the sql component
getContext().getComponent("sql-stored", SqlStoredComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerBatchTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerBatchTest.java
index 5065414..9a4319d 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerBatchTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerBatchTest.java
@@ -86,10 +86,10 @@ public class ProducerBatchTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// required for the sql component
getContext().getComponent("sql-stored", SqlStoredComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerBodyArrayTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerBodyArrayTest.java
index f1f181f..0b82284 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerBodyArrayTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerBodyArrayTest.java
@@ -70,10 +70,10 @@ public class ProducerBodyArrayTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// required for the sql component
getContext().getComponent("sql-stored", SqlStoredComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerClasspathTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerClasspathTest.java
index f2b8ca0..a2637c4 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerClasspathTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerClasspathTest.java
@@ -21,10 +21,10 @@ import org.apache.camel.builder.RouteBuilder;
public class ProducerClasspathTest extends ProducerTest {
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// required for the sql component
getContext().getComponent("sql-stored", SqlStoredComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerInOutTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerInOutTest.java
index 807aae9..6070584 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerInOutTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerInOutTest.java
@@ -75,10 +75,10 @@ public class ProducerInOutTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// required for the sql component
getContext().getComponent("sql-stored", SqlStoredComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerQueryTimeoutTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerQueryTimeoutTest.java
index c7c899f..d2ee192 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerQueryTimeoutTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerQueryTimeoutTest.java
@@ -21,10 +21,10 @@ import org.apache.camel.builder.RouteBuilder;
public class ProducerQueryTimeoutTest extends ProducerTest {
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// required for the sql component
getContext().getComponent("sql-stored", SqlStoredComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerTest.java
index 93731b8..b782e6e 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerTest.java
@@ -73,10 +73,10 @@ public class ProducerTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// required for the sql component
getContext().getComponent("sql-stored", SqlStoredComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerUseMessageBodyForTemplateTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerUseMessageBodyForTemplateTest.java
index 792c4a0..420516f 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerUseMessageBodyForTemplateTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/ProducerUseMessageBodyForTemplateTest.java
@@ -73,10 +73,10 @@ public class ProducerUseMessageBodyForTemplateTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// required for the sql component
getContext().getComponent("sql-stored", SqlStoredComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/SqlFunctionDataSourceTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/SqlFunctionDataSourceTest.java
index ae2d6e6..82bf45d 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/SqlFunctionDataSourceTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/SqlFunctionDataSourceTest.java
@@ -71,10 +71,10 @@ public class SqlFunctionDataSourceTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// required for the sql component
getContext().getComponent("sql-stored", SqlStoredComponent.class).setDataSource(db);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/SqlStoredDataSourceTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/SqlStoredDataSourceTest.java
index 7f41f25..a000b15 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/SqlStoredDataSourceTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/SqlStoredDataSourceTest.java
@@ -35,7 +35,7 @@ public class SqlStoredDataSourceTest extends CamelTestSupport {
private EmbeddedDatabase db;
@Override
- protected Registry createCamelRegistry() throws Exception {
+ protected Registry createCamelRegistry() {
Registry reg = new SimpleRegistry();
// START SNIPPET: e2
@@ -72,10 +72,10 @@ public class SqlStoredDataSourceTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// required for the sql component
from("direct:query").to("sql-stored:NILADIC()?dataSource=#jdbc/myDataSource").to("mock:query");
diff --git a/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/TemplateCacheTest.java b/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/TemplateCacheTest.java
index 1da4671..fcc14de 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/TemplateCacheTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/component/sql/stored/TemplateCacheTest.java
@@ -50,7 +50,7 @@ public class TemplateCacheTest extends CamelTestSupport {
}
@Test
- public void shouldCacheTemplateFunctions() throws InterruptedException {
+ public void shouldCacheTemplateFunctions() {
JdbcTemplate jdbcTemplate = new JdbcTemplate(db);
CallableStatementWrapperFactory fac
= new CallableStatementWrapperFactory(jdbcTemplate, new TemplateParser(context.getClassResolver()), false);
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/AbstractJdbcAggregationTestSupport.java b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/AbstractJdbcAggregationTestSupport.java
index c82a883..b4bc1cc 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/AbstractJdbcAggregationTestSupport.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/AbstractJdbcAggregationTestSupport.java
@@ -38,11 +38,11 @@ public abstract class AbstractJdbcAggregationTestSupport extends CamelSpringTest
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
// START SNIPPET: e1
- public void configure() throws Exception {
+ public void configure() {
// here is the Camel route where we aggregate
from("direct:start")
.aggregate(header("id"), new MyAggregationStrategy())
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/ClusteredJdbcAggregateRecoverTest.java b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/ClusteredJdbcAggregateRecoverTest.java
index 4df1263..45bcd28 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/ClusteredJdbcAggregateRecoverTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/ClusteredJdbcAggregateRecoverTest.java
@@ -63,16 +63,16 @@ public class ClusteredJdbcAggregateRecoverTest extends AbstractClusteredJdbcAggr
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").aggregate(header("id"), new MyAggregationStrategy()).completionSize(5)
.aggregationRepository(repo)
.log("aggregated exchange id ${exchangeId} with ${body}").to("mock:aggregated").delay(1000)
// simulate errors the first two times
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
int count = counter.incrementAndGet();
if (count <= 2) {
throw new IllegalArgumentException("Damn");
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateDiscardOnTimeoutTest.java b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateDiscardOnTimeoutTest.java
index 65c5069..6e0b448 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateDiscardOnTimeoutTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateDiscardOnTimeoutTest.java
@@ -50,10 +50,10 @@ public class JdbcAggregateDiscardOnTimeoutTest extends AbstractJdbcAggregationTe
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.aggregate(header("id"), new MyAggregationStrategy())
.completionSize(3).aggregationRepository(repo)
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateForceCompletionHeaderTest.java b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateForceCompletionHeaderTest.java
index ecf1453..d3832b5 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateForceCompletionHeaderTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateForceCompletionHeaderTest.java
@@ -76,10 +76,10 @@ public class JdbcAggregateForceCompletionHeaderTest extends AbstractJdbcAggregat
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// here is the Camel route where we aggregate
from("direct:start")
.aggregate(header("id"), new MyAggregationStrategy())
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateLoadAndRecoverTest.java b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateLoadAndRecoverTest.java
index 09597fb..de14f1d 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateLoadAndRecoverTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateLoadAndRecoverTest.java
@@ -71,10 +71,10 @@ public class JdbcAggregateLoadAndRecoverTest extends AbstractJdbcAggregationTest
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
onException(IllegalStateException.class)
.maximumRedeliveries(3)
.redeliveryDelay(100L);
@@ -87,7 +87,7 @@ public class JdbcAggregateLoadAndRecoverTest extends AbstractJdbcAggregationTest
.to("log:output?showHeaders=true")
// have every 10th exchange fail which should then be recovered
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
//Avoid same message to be discarded twice
if (exchange.getIn().getHeader(Exchange.REDELIVERED) == null) {
int num = counter.incrementAndGet();
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateLoadConcurrentTest.java b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateLoadConcurrentTest.java
index adbaf17..bcef806 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateLoadConcurrentTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateLoadConcurrentTest.java
@@ -64,10 +64,10 @@ public class JdbcAggregateLoadConcurrentTest extends AbstractJdbcAggregationTest
}
@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("log:input?groupSize=500")
.aggregate(header("id"), new MyAggregationStrategy())
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateLoadTest.java b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateLoadTest.java
index b808f07..6a2f747 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateLoadTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateLoadTest.java
@@ -48,10 +48,10 @@ public class JdbcAggregateLoadTest extends AbstractJdbcAggregationTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("seda:start?size=" + SIZE)
.to("log:input?groupSize=500")
.aggregate(header("id"), new MyAggregationStrategy())
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateNotLostRemovedWhenConfirmedTest.java b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateNotLostRemovedWhenConfirmedTest.java
index 4d5151b..39a63b9 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateNotLostRemovedWhenConfirmedTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateNotLostRemovedWhenConfirmedTest.java
@@ -48,10 +48,10 @@ public class JdbcAggregateNotLostRemovedWhenConfirmedTest extends AbstractJdbcAg
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.aggregate(header("id"), new MyAggregationStrategy())
.completionSize(5).aggregationRepository(repo)
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateNotLostTest.java b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateNotLostTest.java
index dbf4167..4b02ee6 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateNotLostTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateNotLostTest.java
@@ -57,10 +57,10 @@ public class JdbcAggregateNotLostTest extends AbstractJdbcAggregationTestSupport
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.aggregate(header("id"), new MyAggregationStrategy())
.completionSize(5).aggregationRepository(repo)
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverDeadLetterChannelFailedTest.java b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverDeadLetterChannelFailedTest.java
index 3a49924..ee98a49 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverDeadLetterChannelFailedTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverDeadLetterChannelFailedTest.java
@@ -56,10 +56,10 @@ public class JdbcAggregateRecoverDeadLetterChannelFailedTest extends AbstractJdb
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").routeId("start")
.aggregate(header("id"), new MyAggregationStrategy())
.completionSize(5).aggregationRepository(repo)
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverDeadLetterChannelTest.java b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverDeadLetterChannelTest.java
index 37851b9..99076da 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverDeadLetterChannelTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverDeadLetterChannelTest.java
@@ -55,10 +55,10 @@ public class JdbcAggregateRecoverDeadLetterChannelTest extends AbstractJdbcAggre
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.aggregate(header("id"), new MyAggregationStrategy())
.completionSize(5).aggregationRepository(repo)
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverTest.java b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverTest.java
index 453622e..de4090f 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverTest.java
@@ -56,10 +56,10 @@ public class JdbcAggregateRecoverTest extends AbstractJdbcAggregationTestSupport
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.aggregate(header("id"), new MyAggregationStrategy())
.completionSize(5).aggregationRepository(repo)
@@ -68,7 +68,7 @@ public class JdbcAggregateRecoverTest extends AbstractJdbcAggregationTestSupport
.delay(1000)
// simulate errors the first two times
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
int count = counter.incrementAndGet();
if (count <= 2) {
throw new IllegalArgumentException("Damn");
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverWithRedeliveryPolicyTest.java b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverWithRedeliveryPolicyTest.java
index 9f9e921..8a2f2ce 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverWithRedeliveryPolicyTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverWithRedeliveryPolicyTest.java
@@ -59,10 +59,10 @@ public class JdbcAggregateRecoverWithRedeliveryPolicyTest extends AbstractJdbcAg
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.aggregate(header("id"), new MyAggregationStrategy())
.completionSize(5).aggregationRepository(repo)
@@ -71,7 +71,7 @@ public class JdbcAggregateRecoverWithRedeliveryPolicyTest extends AbstractJdbcAg
.to("mock:aggregated")
// simulate errors the first three times
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
int count = counter.incrementAndGet();
if (count <= 3) {
throw new IllegalArgumentException("Damn");
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverWithSedaTest.java b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverWithSedaTest.java
index 0affac8..64a9b7c 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverWithSedaTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateRecoverWithSedaTest.java
@@ -56,10 +56,10 @@ public class JdbcAggregateRecoverWithSedaTest extends AbstractJdbcAggregationTes
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.aggregate(header("id"), new MyAggregationStrategy())
.completionSize(5).aggregationRepository(repo)
@@ -74,7 +74,7 @@ public class JdbcAggregateRecoverWithSedaTest extends AbstractJdbcAggregationTes
.delay(1000)
// simulate errors the first two times
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
int count = counter.incrementAndGet();
if (count <= 2) {
throw new IllegalArgumentException("Damn");
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateSerializedHeadersTest.java b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateSerializedHeadersTest.java
index 9c32dad..4c52728 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateSerializedHeadersTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateSerializedHeadersTest.java
@@ -49,10 +49,10 @@ public class JdbcAggregateSerializedHeadersTest extends AbstractJdbcAggregationT
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
repo.setAllowSerializedHeaders(true);
from("seda:start?size=" + SIZE)
.to("log:input?groupSize=500")
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateStoreAsText2Test.java b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateStoreAsText2Test.java
index 0937cf1..d19578f 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateStoreAsText2Test.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateStoreAsText2Test.java
@@ -96,15 +96,15 @@ public class JdbcAggregateStoreAsText2Test extends CamelSpringTestSupport {
assertMockEndpointsSatisfied();
}
- public String getAggregationRepositoryBody(int id) throws Exception {
+ public String getAggregationRepositoryBody(int id) {
return getAggregationRepositoryColumn(id, "body");
}
- public String getAggregationRepositoryCompanyName(int id) throws Exception {
+ public String getAggregationRepositoryCompanyName(int id) {
return getAggregationRepositoryColumn(id, "companyName");
}
- public String getAggregationRepositoryAccountName(int id) throws Exception {
+ public String getAggregationRepositoryAccountName(int id) {
return getAggregationRepositoryColumn(id, "accountName");
}
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateStoreAsTextTest.java b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateStoreAsTextTest.java
index e55b5a1..c7643d6 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateStoreAsTextTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateStoreAsTextTest.java
@@ -134,15 +134,15 @@ public class JdbcAggregateStoreAsTextTest extends CamelSpringTestSupport {
assertMockEndpointsSatisfied();
}
- public String getAggregationRepositoryBody(int id) throws Exception {
+ public String getAggregationRepositoryBody(int id) {
return getAggregationRepositoryColumn(id, "body");
}
- public String getAggregationRepositoryCompanyName(int id) throws Exception {
+ public String getAggregationRepositoryCompanyName(int id) {
return getAggregationRepositoryColumn(id, "companyName");
}
- public String getAggregationRepositoryAccountName(int id) throws Exception {
+ public String getAggregationRepositoryAccountName(int id) {
return getAggregationRepositoryColumn(id, "accountName");
}
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateTest.java b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateTest.java
index 0cf3a03..d20fe00 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateTest.java
@@ -44,10 +44,10 @@ public class JdbcAggregateTest extends AbstractJdbcAggregationTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// here is the Camel route where we aggregate
from("direct:start")
.aggregate(header("id"), new MyAggregationStrategy())
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateTimeoutCompletionRestartTest.java b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateTimeoutCompletionRestartTest.java
index 2d0f1bb..a48a2ad 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateTimeoutCompletionRestartTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregateTimeoutCompletionRestartTest.java
@@ -48,10 +48,10 @@ public class JdbcAggregateTimeoutCompletionRestartTest extends AbstractJdbcAggre
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// here is the Camel route where we aggregate
from("direct:start")
.aggregate(header("id"), new MyAggregationStrategy())
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepositoryRecoverExistingTest.java b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepositoryRecoverExistingTest.java
index 86e940b..7154c5d 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepositoryRecoverExistingTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcAggregationRepositoryRecoverExistingTest.java
@@ -34,7 +34,7 @@ public class JdbcAggregationRepositoryRecoverExistingTest extends AbstractJdbcAg
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
// no routes added by default
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcGrowIssueTest.java b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcGrowIssueTest.java
index 922e947..013f296 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcGrowIssueTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcGrowIssueTest.java
@@ -32,7 +32,7 @@ public class JdbcGrowIssueTest extends AbstractJdbcAggregationTestSupport {
private static final int SIZE = 1024;
@Test
- public void testGrowIssue() throws Exception {
+ public void testGrowIssue() {
// a 1kb string for testing
StringBuilder sb = new StringBuilder(SIZE);
for (int i = 0; i < SIZE; i++) {
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcSpringAggregateRecoverWithRedeliveryPolicyTest.java b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcSpringAggregateRecoverWithRedeliveryPolicyTest.java
index d32add7..6009c7f 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcSpringAggregateRecoverWithRedeliveryPolicyTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/aggregate/jdbc/JdbcSpringAggregateRecoverWithRedeliveryPolicyTest.java
@@ -60,7 +60,7 @@ public class JdbcSpringAggregateRecoverWithRedeliveryPolicyTest extends CamelSpr
public static class MyFailProcessor implements Processor {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
int count = counter.incrementAndGet();
if (count <= 3) {
throw new IllegalArgumentException("Damn");
diff --git a/components/camel-sql/src/test/java/org/apache/camel/processor/idempotent/jdbc/JdbcMessageIdRepositoryTest.java b/components/camel-sql/src/test/java/org/apache/camel/processor/idempotent/jdbc/JdbcMessageIdRepositoryTest.java
index 51c0a49..a6adaea 100644
--- a/components/camel-sql/src/test/java/org/apache/camel/processor/idempotent/jdbc/JdbcMessageIdRepositoryTest.java
+++ b/components/camel-sql/src/test/java/org/apache/camel/processor/idempotent/jdbc/JdbcMessageIdRepositoryTest.java
@@ -90,10 +90,10 @@ public class JdbcMessageIdRepositoryTest extends CamelSpringTestSupport {
public void testFailedExchangesNotAdded() throws Exception {
RouteBuilder interceptor = new RouteBuilder(context) {
@Override
- public void configure() throws Exception {
+ public void configure() {
interceptSendToEndpoint("mock:result")
.process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
String id = exchange.getIn().getHeader("messageId", String.class);
if (id.equals("2")) {
throw new IllegalArgumentException("Damn I cannot handle id 2");