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/04/12 19:13:22 UTC
[camel] branch main updated (026a215a2bd -> a634746e7f8)
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
from 026a215a2bd CAMEL-17763: cleaned up unused exceptions in camel-resilience4j
new 2f68a771483 CAMEL-17763: cleaned up unused exceptions in camel-reactor
new 9b98c6ab880 CAMEL-17763: cleaned up unused exceptions in camel-reactive-streams
new d0b9caafa6e CAMEL-17763: cleaned up unused exceptions in camel-reactive-executor-vertx
new 7dc30b55000 CAMEL-17763: cleaned up unused exceptions in camel-quickfix
new 3de0b70999c CAMEL-17763: cleaned up unused exceptions in camel-quartz
new 3481438341e CAMEL-17763: cleaned up unused exceptions in camel-pubnub
new e7037617c0d CAMEL-17763: cleaned up unused exceptions in camel-protobuf
new f7c1ee08832 CAMEL-17763: cleaned up unused exceptions in camel-printer
new a634746e7f8 CAMEL-17763: cleaned up unused exceptions in camel-pgevent
The 9 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/camel/pgevent/PgEventHelperTest.java | 2 +-
.../camel/pgevent/integration/PgEventPubSubIT.java | 4 ++--
.../integration/PgEventWithDefinedDatasourceIT.java | 6 +++---
.../camel/component/printer/PrinterPrintTest.java | 10 +++++-----
.../protobuf/ProtobufMarshalAndUnmarshalJsonTest.java | 4 ++--
.../protobuf/ProtobufMarshalAndUnmarshalMapTest.java | 4 ++--
.../ProtobufMarshalAndUnmarshalSpringTest.java | 4 ++--
.../protobuf/ProtobufMarshalAndUnmarshalTest.java | 8 ++++----
.../component/pubnub/PubNubConfigurationTest.java | 2 +-
.../apache/camel/component/pubnub/PubNubFireTest.java | 2 +-
.../camel/component/pubnub/PubNubOperationsTest.java | 10 +++++-----
.../camel/component/pubnub/PubNubPresenceTest.java | 2 +-
.../camel/component/pubnub/PubNubPublishTest.java | 4 ++--
.../camel/component/pubnub/PubNubSubscriberTest.java | 2 +-
.../apache/camel/component/pubnub/PubNubTestBase.java | 4 ++--
.../pubnub/example/PubNubGeoLocationExample.java | 2 +-
.../pubnub/example/PubNubPresenseExample.java | 2 +-
.../pubnub/example/PubNubSensor2Example.java | 4 ++--
.../component/pubnub/example/PubNubSensorExample.java | 2 +-
.../component/pubnub/example/PubNubStateExample.java | 2 +-
.../component/quartz/DelegateEndpointQuartzTest.java | 2 +-
.../component/quartz/QuartzAddDynamicRouteTest.java | 2 +-
.../QuartzAddRoutesAfterCamelContextStartedTest.java | 2 +-
.../camel/component/quartz/QuartzAutoStartTest.java | 4 ++--
...tzComponentCamelContextSchedulerIsolationTest.java | 3 +--
...uartzComponentCamelContextSharedSchedulerTest.java | 6 +++---
.../camel/component/quartz/QuartzComponentTest.java | 2 +-
.../component/quartz/QuartzCronRouteFireNowTest.java | 3 +--
.../quartz/QuartzCronRouteWithSmallCacheTest.java | 2 +-
.../quartz/QuartzCustomCalendarFireTest.java | 2 +-
.../quartz/QuartzCustomCalendarNoFireTest.java | 2 +-
.../component/quartz/QuartzEndpointConfigureTest.java | 4 ++--
.../camel/component/quartz/QuartzManagementTest.java | 4 ++--
.../component/quartz/QuartzNameCollisionTest.java | 18 +++++++++---------
.../quartz/QuartzOneCamelContextRestartTest.java | 4 ++--
.../QuartzOneCamelContextSuspendResumeTest.java | 4 ++--
.../camel/component/quartz/QuartzPropertiesTest.java | 2 +-
.../component/quartz/QuartzTriggerParametersTest.java | 4 ++--
.../quartz/QuartzTwoCamelContextRestartTest.java | 6 +++---
.../QuartzTwoCamelContextSameNameClashTest.java | 6 +++---
.../QuartzTwoCamelContextSuspendResumeTest.java | 6 +++---
.../component/quartz/QuartzTwoCamelContextTest.java | 8 ++++----
...ingQuartzConsumerTwoAppsClusteredRecoveryTest.java | 2 +-
.../component/quartz/StatefulQuartzRouteTest.java | 2 +-
.../component/quartz/cron/QuartzCronMappingTest.java | 4 ++--
.../FileConsumerQuartzSchedulerRestartTest.java | 4 ++--
.../quartz/FileConsumerQuartzSchedulerTest.java | 4 ++--
.../quartz/MultiplePoliciesOnRouteTest.java | 2 +-
.../RouteAutoStopFalseCronScheduledPolicyTest.java | 2 +-
.../component/quickfixj/QuickfixjComponentTest.java | 11 +++++------
.../component/quickfixj/QuickfixjEngineTest.java | 4 ++--
.../quickfixj/examples/AuthenticationExample.java | 2 +-
.../quickfixj/examples/RestartRouteExample.java | 2 +-
.../quickfixj/examples/trading/TradeExecutor.java | 19 ++++++++-----------
.../examples/trading/TradeExecutorComponent.java | 10 +++++-----
.../transform/QuickfixjEventJsonTransformer.java | 3 +--
.../transform/QuickfixjMessageJsonTransformer.java | 4 +---
.../camel/reactive/SimpleMockLookupVertxTest.java | 4 ++--
.../org/apache/camel/reactive/SimpleMockTest.java | 4 ++--
.../reactive/streams/BasicSubscriberTest.java | 4 ++--
.../reactive/streams/CamelReactiveStreamsTest.java | 8 ++++----
.../reactive/streams/ConcurrentConsumersTest.java | 2 +-
.../reactive/streams/DelayedMonoPublisherTest.java | 8 ++++----
.../reactive/streams/ExchangeRequestTest.java | 8 ++++----
.../reactive/streams/PublisherTypeConversionTest.java | 2 +-
.../reactive/streams/ReactiveStreamsJMXTest.java | 2 +-
.../component/reactive/streams/RequestRefillTest.java | 2 +-
.../engine/ReactorStreamsServiceBackpressureTest.java | 6 +++---
.../engine/ReactorStreamsServiceEventTypeTest.java | 10 +++++-----
.../engine/ReactorStreamsServiceSubscriberTest.java | 6 +++---
.../reactor/engine/ReactorStreamsServiceTest.java | 14 +++++++-------
.../engine/ReactorStreamsServiceTestSupport.java | 2 +-
72 files changed, 162 insertions(+), 171 deletions(-)
[camel] 07/09: CAMEL-17763: cleaned up unused exceptions in camel-protobuf
Posted by or...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit e7037617c0d74f5d61092ab1fdf8e25afec6ba04
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Apr 12 18:17:04 2022 +0200
CAMEL-17763: cleaned up unused exceptions in camel-protobuf
---
.../dataformat/protobuf/ProtobufMarshalAndUnmarshalJsonTest.java | 4 ++--
.../dataformat/protobuf/ProtobufMarshalAndUnmarshalMapTest.java | 4 ++--
.../protobuf/ProtobufMarshalAndUnmarshalSpringTest.java | 4 ++--
.../dataformat/protobuf/ProtobufMarshalAndUnmarshalTest.java | 8 ++++----
4 files changed, 10 insertions(+), 10 deletions(-)
diff --git a/components/camel-protobuf/src/test/java/org/apache/camel/dataformat/protobuf/ProtobufMarshalAndUnmarshalJsonTest.java b/components/camel-protobuf/src/test/java/org/apache/camel/dataformat/protobuf/ProtobufMarshalAndUnmarshalJsonTest.java
index ceb0612202b..523ba599e94 100644
--- a/components/camel-protobuf/src/test/java/org/apache/camel/dataformat/protobuf/ProtobufMarshalAndUnmarshalJsonTest.java
+++ b/components/camel-protobuf/src/test/java/org/apache/camel/dataformat/protobuf/ProtobufMarshalAndUnmarshalJsonTest.java
@@ -57,10 +57,10 @@ public class ProtobufMarshalAndUnmarshalJsonTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
ProtobufDataFormat format
= new ProtobufDataFormat(Person.getDefaultInstance(), ProtobufDataFormat.CONTENT_TYPE_FORMAT_JSON);
diff --git a/components/camel-protobuf/src/test/java/org/apache/camel/dataformat/protobuf/ProtobufMarshalAndUnmarshalMapTest.java b/components/camel-protobuf/src/test/java/org/apache/camel/dataformat/protobuf/ProtobufMarshalAndUnmarshalMapTest.java
index c99e5e168bf..6a236e3c7b7 100644
--- a/components/camel-protobuf/src/test/java/org/apache/camel/dataformat/protobuf/ProtobufMarshalAndUnmarshalMapTest.java
+++ b/components/camel-protobuf/src/test/java/org/apache/camel/dataformat/protobuf/ProtobufMarshalAndUnmarshalMapTest.java
@@ -71,10 +71,10 @@ public class ProtobufMarshalAndUnmarshalMapTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
ProtobufDataFormat format = new ProtobufDataFormat(Person.getDefaultInstance());
from("direct:in").marshal(format);
diff --git a/components/camel-protobuf/src/test/java/org/apache/camel/dataformat/protobuf/ProtobufMarshalAndUnmarshalSpringTest.java b/components/camel-protobuf/src/test/java/org/apache/camel/dataformat/protobuf/ProtobufMarshalAndUnmarshalSpringTest.java
index a2ceff8fe40..cf805318941 100644
--- a/components/camel-protobuf/src/test/java/org/apache/camel/dataformat/protobuf/ProtobufMarshalAndUnmarshalSpringTest.java
+++ b/components/camel-protobuf/src/test/java/org/apache/camel/dataformat/protobuf/ProtobufMarshalAndUnmarshalSpringTest.java
@@ -53,11 +53,11 @@ public class ProtobufMarshalAndUnmarshalSpringTest extends CamelSpringTestSuppor
}
@Test
- public void testMarshalAndUnmarshalWithDSL3() throws Exception {
+ public void testMarshalAndUnmarshalWithDSL3() {
try {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:unmarshalC").unmarshal().protobuf(new CamelException("wrong instance")).to("mock:reverse");
}
});
diff --git a/components/camel-protobuf/src/test/java/org/apache/camel/dataformat/protobuf/ProtobufMarshalAndUnmarshalTest.java b/components/camel-protobuf/src/test/java/org/apache/camel/dataformat/protobuf/ProtobufMarshalAndUnmarshalTest.java
index 22e112cf2cb..2b0380d41a7 100644
--- a/components/camel-protobuf/src/test/java/org/apache/camel/dataformat/protobuf/ProtobufMarshalAndUnmarshalTest.java
+++ b/components/camel-protobuf/src/test/java/org/apache/camel/dataformat/protobuf/ProtobufMarshalAndUnmarshalTest.java
@@ -47,11 +47,11 @@ public class ProtobufMarshalAndUnmarshalTest extends CamelTestSupport {
}
@Test
- public void testMarshalAndUnmarshalWithDSL3() throws Exception {
+ public void testMarshalAndUnmarshalWithDSL3() {
try {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:unmarshalC").unmarshal().protobuf(new CamelException("wrong instance")).to("mock:reverse");
}
});
@@ -80,10 +80,10 @@ public class ProtobufMarshalAndUnmarshalTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
ProtobufDataFormat format = new ProtobufDataFormat(Person.getDefaultInstance());
from("direct:in").marshal(format);
[camel] 09/09: CAMEL-17763: cleaned up unused exceptions in camel-pgevent
Posted by or...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit a634746e7f88f81240fab116a80fd1e5cc55da22
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Apr 12 18:16:45 2022 +0200
CAMEL-17763: cleaned up unused exceptions in camel-pgevent
---
.../src/test/java/org/apache/camel/pgevent/PgEventHelperTest.java | 2 +-
.../java/org/apache/camel/pgevent/integration/PgEventPubSubIT.java | 4 ++--
.../camel/pgevent/integration/PgEventWithDefinedDatasourceIT.java | 6 +++---
3 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/components/camel-pgevent/src/test/java/org/apache/camel/pgevent/PgEventHelperTest.java b/components/camel-pgevent/src/test/java/org/apache/camel/pgevent/PgEventHelperTest.java
index 3961d317a56..3e1df152970 100644
--- a/components/camel-pgevent/src/test/java/org/apache/camel/pgevent/PgEventHelperTest.java
+++ b/components/camel-pgevent/src/test/java/org/apache/camel/pgevent/PgEventHelperTest.java
@@ -33,7 +33,7 @@ import static org.mockito.Mockito.when;
public class PgEventHelperTest {
@Test
- public void testToPGConnectionWithNullConnection() throws Exception {
+ public void testToPGConnectionWithNullConnection() {
assertThrows(IllegalArgumentException.class,
() -> PgEventHelper.toPGConnection(null));
}
diff --git a/components/camel-pgevent/src/test/java/org/apache/camel/pgevent/integration/PgEventPubSubIT.java b/components/camel-pgevent/src/test/java/org/apache/camel/pgevent/integration/PgEventPubSubIT.java
index ff13f0d50bb..6d984e11aac 100644
--- a/components/camel-pgevent/src/test/java/org/apache/camel/pgevent/integration/PgEventPubSubIT.java
+++ b/components/camel-pgevent/src/test/java/org/apache/camel/pgevent/integration/PgEventPubSubIT.java
@@ -38,10 +38,10 @@ public class PgEventPubSubIT extends PgEventITSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(timerEndpoint)
.setBody(constant(TEST_MESSAGE_BODY))
.to(String.format(
diff --git a/components/camel-pgevent/src/test/java/org/apache/camel/pgevent/integration/PgEventWithDefinedDatasourceIT.java b/components/camel-pgevent/src/test/java/org/apache/camel/pgevent/integration/PgEventWithDefinedDatasourceIT.java
index 50d0fbc4774..21a9b08db77 100644
--- a/components/camel-pgevent/src/test/java/org/apache/camel/pgevent/integration/PgEventWithDefinedDatasourceIT.java
+++ b/components/camel-pgevent/src/test/java/org/apache/camel/pgevent/integration/PgEventWithDefinedDatasourceIT.java
@@ -40,7 +40,7 @@ public class PgEventWithDefinedDatasourceIT extends PgEventITSupport {
private MockEndpoint mockEndpoint;
@BindToRegistry("pgDataSource")
- public PGDataSource loadDataSource() throws Exception {
+ public PGDataSource loadDataSource() {
PGDataSource dataSource = new PGDataSource();
dataSource.setHost(getHost());
dataSource.setPort(getMappedPort());
@@ -58,10 +58,10 @@ public class PgEventWithDefinedDatasourceIT extends PgEventITSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(timerEndpoint)
.setBody(constant(TEST_MESSAGE_BODY))
.to(notifyEndpoint);
[camel] 03/09: CAMEL-17763: cleaned up unused exceptions in camel-reactive-executor-vertx
Posted by or...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit d0b9caafa6ec2a474c33c249837c7719e0763daf
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Apr 12 18:21:05 2022 +0200
CAMEL-17763: cleaned up unused exceptions in camel-reactive-executor-vertx
---
.../java/org/apache/camel/reactive/SimpleMockLookupVertxTest.java | 4 ++--
.../src/test/java/org/apache/camel/reactive/SimpleMockTest.java | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/components/camel-reactive-executor-vertx/src/test/java/org/apache/camel/reactive/SimpleMockLookupVertxTest.java b/components/camel-reactive-executor-vertx/src/test/java/org/apache/camel/reactive/SimpleMockLookupVertxTest.java
index 583c16ead2b..d767572972c 100644
--- a/components/camel-reactive-executor-vertx/src/test/java/org/apache/camel/reactive/SimpleMockLookupVertxTest.java
+++ b/components/camel-reactive-executor-vertx/src/test/java/org/apache/camel/reactive/SimpleMockLookupVertxTest.java
@@ -56,10 +56,10 @@ public class SimpleMockLookupVertxTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").to("log:foo").to("log:bar").to("mock:result");
}
};
diff --git a/components/camel-reactive-executor-vertx/src/test/java/org/apache/camel/reactive/SimpleMockTest.java b/components/camel-reactive-executor-vertx/src/test/java/org/apache/camel/reactive/SimpleMockTest.java
index 3730dbbc6eb..3e5234df3c2 100644
--- a/components/camel-reactive-executor-vertx/src/test/java/org/apache/camel/reactive/SimpleMockTest.java
+++ b/components/camel-reactive-executor-vertx/src/test/java/org/apache/camel/reactive/SimpleMockTest.java
@@ -61,10 +61,10 @@ public class SimpleMockTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").to("log:foo").to("log:bar").to("mock:result");
}
};
[camel] 06/09: CAMEL-17763: cleaned up unused exceptions in camel-pubnub
Posted by or...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 3481438341eeec3f81f1145170143b23c99c1570
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Apr 12 18:17:14 2022 +0200
CAMEL-17763: cleaned up unused exceptions in camel-pubnub
---
.../apache/camel/component/pubnub/PubNubConfigurationTest.java | 2 +-
.../java/org/apache/camel/component/pubnub/PubNubFireTest.java | 2 +-
.../apache/camel/component/pubnub/PubNubOperationsTest.java | 10 +++++-----
.../org/apache/camel/component/pubnub/PubNubPresenceTest.java | 2 +-
.../org/apache/camel/component/pubnub/PubNubPublishTest.java | 4 ++--
.../apache/camel/component/pubnub/PubNubSubscriberTest.java | 2 +-
.../java/org/apache/camel/component/pubnub/PubNubTestBase.java | 4 ++--
.../component/pubnub/example/PubNubGeoLocationExample.java | 2 +-
.../camel/component/pubnub/example/PubNubPresenseExample.java | 2 +-
.../camel/component/pubnub/example/PubNubSensor2Example.java | 4 ++--
.../camel/component/pubnub/example/PubNubSensorExample.java | 2 +-
.../camel/component/pubnub/example/PubNubStateExample.java | 2 +-
12 files changed, 19 insertions(+), 19 deletions(-)
diff --git a/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubConfigurationTest.java b/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubConfigurationTest.java
index 27dc5a68144..1588fab9441 100644
--- a/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubConfigurationTest.java
+++ b/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubConfigurationTest.java
@@ -27,7 +27,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
public class PubNubConfigurationTest extends CamelTestSupport {
@Test
- public void createEndpointWithIllegalArguments() throws Exception {
+ public void createEndpointWithIllegalArguments() {
PubNubComponent component = context.getComponent("pubnub", PubNubComponent.class);
assertThrows(IllegalArgumentException.class,
() -> component.createEndpoint("pubnub"));
diff --git a/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubFireTest.java b/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubFireTest.java
index 09854043aa5..a00f4d14924 100644
--- a/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubFireTest.java
+++ b/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubFireTest.java
@@ -45,7 +45,7 @@ public class PubNubFireTest extends PubNubTestBase {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("direct:publish").to(endpoint).to("mock:result");
diff --git a/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubOperationsTest.java b/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubOperationsTest.java
index 657ced97d09..ab2ea048fcf 100644
--- a/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubOperationsTest.java
+++ b/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubOperationsTest.java
@@ -39,7 +39,7 @@ import static org.junit.jupiter.api.Assertions.assertNotNull;
public class PubNubOperationsTest extends PubNubTestBase {
@Test
- public void testWhereNow() throws Exception {
+ public void testWhereNow() {
stubFor(get(urlPathEqualTo("/v2/presence/sub-key/mySubscribeKey/uuid/myUUID"))
.willReturn(aResponse().withBody(
"{\"status\": 200, \"message\": \"OK\", \"payload\": {\"channels\": [\"channel-a\",\"channel-b\"]}, \"service\": \"Presence\"}")));
@@ -55,7 +55,7 @@ public class PubNubOperationsTest extends PubNubTestBase {
}
@Test
- public void testHereNow() throws Exception {
+ public void testHereNow() {
stubFor(get(urlPathEqualTo("/v2/presence/sub_key/mySubscribeKey/channel/myChannel")).willReturn(aResponse()
.withBody(
"{\"status\" : 200, \"message\" : \"OK\", \"service\" : \"Presence\", \"uuids\" : [{\"uuid\" : \"myUUID0\"}, {\"state\" : {\"abcd\" : {\"age\" : 15}}, "
@@ -106,7 +106,7 @@ public class PubNubOperationsTest extends PubNubTestBase {
}
@Test
- public void testGetState() throws Exception {
+ public void testGetState() {
stubFor(get(urlPathEqualTo("/v2/presence/sub-key/mySubscribeKey/channel/myChannel/uuid/myuuid")).willReturn(aResponse()
.withBody("{ \"status\": 200, \"message\": \"OK\", \"payload\": "
+ "{ \"myChannel\": { \"age\" : 20, \"status\" : \"online\"}, \"ch2\": { \"age\": 100, \"status\": \"offline\" } }, \"service\": \"Presence\"}")));
@@ -118,7 +118,7 @@ public class PubNubOperationsTest extends PubNubTestBase {
}
@Test
- public void testSetState() throws Exception {
+ public void testSetState() {
stubFor(get(urlPathEqualTo("/v2/presence/sub-key/mySubscribeKey/channel/myChannel/uuid/myuuid/data"))
.willReturn(aResponse().withBody(
"{ \"status\": 200, \"message\": \"OK\", \"payload\": { \"age\" : 20, \"status\" : \"online\" }, \"service\": \"Presence\"}")));
@@ -133,7 +133,7 @@ public class PubNubOperationsTest extends PubNubTestBase {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("direct:publish").to("pubnub://myChannel?uuid=myuuid&pubnub=#pubnub")
diff --git a/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubPresenceTest.java b/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubPresenceTest.java
index 11446453af5..aa148d4a071 100644
--- a/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubPresenceTest.java
+++ b/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubPresenceTest.java
@@ -74,7 +74,7 @@ public class PubNubPresenceTest extends PubNubTestBase {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("pubnub:mychannel?pubnub=#pubnub&withPresence=true").id("presence-route")
diff --git a/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubPublishTest.java b/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubPublishTest.java
index d2c2a4637e4..cbee4213404 100644
--- a/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubPublishTest.java
+++ b/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubPublishTest.java
@@ -47,7 +47,7 @@ public class PubNubPublishTest extends PubNubTestBase {
}
@Test
- public void testPublishEmptyBody() throws Exception {
+ public void testPublishEmptyBody() {
assertThrows(CamelExecutionException.class,
() -> template.sendBody("direct:publish", null));
}
@@ -64,7 +64,7 @@ public class PubNubPublishTest extends PubNubTestBase {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("direct:publish").to(endpoint).to("mock:result");
diff --git a/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubSubscriberTest.java b/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubSubscriberTest.java
index 21740a3d453..94d295adff1 100644
--- a/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubSubscriberTest.java
+++ b/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubSubscriberTest.java
@@ -48,7 +48,7 @@ public class PubNubSubscriberTest extends PubNubTestBase {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("pubnub:mychannel?pubnub=#pubnub").id("subroute").autoStartup(false)
diff --git a/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubTestBase.java b/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubTestBase.java
index 6aae396da50..469621f89d0 100644
--- a/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubTestBase.java
+++ b/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/PubNubTestBase.java
@@ -37,12 +37,12 @@ public class PubNubTestBase extends CamelTestSupport {
private WireMockServer wireMockServer = new WireMockServer(options().port(port));
- protected void setupResources() throws Exception {
+ protected void setupResources() {
wireMockServer.start();
WireMock.configureFor("localhost", wireMockServer.port());
}
- protected void cleanupResources() throws Exception {
+ protected void cleanupResources() {
wireMockServer.stop();
pubnub.destroy();
}
diff --git a/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/example/PubNubGeoLocationExample.java b/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/example/PubNubGeoLocationExample.java
index 10b46de2f57..ed4c767210a 100644
--- a/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/example/PubNubGeoLocationExample.java
+++ b/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/example/PubNubGeoLocationExample.java
@@ -39,7 +39,7 @@ public final class PubNubGeoLocationExample {
static class GeoLocationRoute extends RouteBuilder {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("timer:geotimer")
.process(exchange -> exchange.getIn().setBody(new Foo("bar", "TEXT")))
.to("pubnub:eon-maps-geolocation-input?operation=fire&publishKey=" + PUBNUB_PUBLISH_KEY + "&subscribeKey="
diff --git a/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/example/PubNubPresenseExample.java b/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/example/PubNubPresenseExample.java
index c03762f9da4..cda1d0ccfc2 100644
--- a/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/example/PubNubPresenseExample.java
+++ b/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/example/PubNubPresenseExample.java
@@ -34,7 +34,7 @@ public final class PubNubPresenseExample {
static class PresensRoute extends RouteBuilder {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("pubnub:iot?withPresence=true&subscribeKey=" + PUBNUB_SUBSCRIBE_KEY)
.log("${body}")
.to("mock:result");
diff --git a/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/example/PubNubSensor2Example.java b/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/example/PubNubSensor2Example.java
index 22123ee5ad6..4825efb0100 100644
--- a/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/example/PubNubSensor2Example.java
+++ b/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/example/PubNubSensor2Example.java
@@ -52,7 +52,7 @@ public final class PubNubSensor2Example {
+ "&subscribeKey=" + PUBNUB_SUBSCRIBE_KEY;
@Override
- public void configure() throws Exception {
+ public void configure() {
from("timer:device2").routeId("device-event-route")
.bean(PubNubSensor2Example.EventGeneratorBean.class, "getRandomEvent('device2')")
.to(deviceEP);
@@ -69,7 +69,7 @@ public final class PubNubSensor2Example {
private static Map<String, String> devices = new ConcurrentHashMap<>();
@Override
- public void configure() throws Exception {
+ public void configure() {
from(masterEP)
.routeId("master-route")
.bean(PubNubSensor2Example.PubsubRoute.DataProcessorBean.class, "doSomethingInteresting(${body})")
diff --git a/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/example/PubNubSensorExample.java b/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/example/PubNubSensorExample.java
index aebf4866e7a..d65210966e7 100644
--- a/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/example/PubNubSensorExample.java
+++ b/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/example/PubNubSensorExample.java
@@ -32,7 +32,7 @@ public final class PubNubSensorExample {
static class SensorRoute extends RouteBuilder {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("pubnub:pubnub-sensor-network?subscribeKey=sub-c-5f1b7c8e-fbee-11e3-aa40-02ee2ddab7fe").log("${body}")
.to("mock:result");
}
diff --git a/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/example/PubNubStateExample.java b/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/example/PubNubStateExample.java
index 1f848c9ac98..267be1bedb1 100644
--- a/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/example/PubNubStateExample.java
+++ b/components/camel-pubnub/src/test/java/org/apache/camel/component/pubnub/example/PubNubStateExample.java
@@ -59,7 +59,7 @@ public class PubNubStateExample extends CamelTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
from("direct:publish")
[camel] 08/09: CAMEL-17763: cleaned up unused exceptions in camel-printer
Posted by or...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit f7c1ee0883240706dc733a14b4226cdab2f13f62
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Apr 12 18:16:54 2022 +0200
CAMEL-17763: cleaned up unused exceptions in camel-printer
---
.../org/apache/camel/component/printer/PrinterPrintTest.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/components/camel-printer/src/test/java/org/apache/camel/component/printer/PrinterPrintTest.java b/components/camel-printer/src/test/java/org/apache/camel/component/printer/PrinterPrintTest.java
index b4b28e18583..9a455c1c326 100644
--- a/components/camel-printer/src/test/java/org/apache/camel/component/printer/PrinterPrintTest.java
+++ b/components/camel-printer/src/test/java/org/apache/camel/component/printer/PrinterPrintTest.java
@@ -83,7 +83,7 @@ public class PrinterPrintTest extends CamelTestSupport {
return Boolean.getBoolean("java.awt.headless");
}
- private void sendFile() throws Exception {
+ private void sendFile() {
template.send("direct:start", new Processor() {
public void process(Exchange exchange) throws Exception {
// Read from an input stream
@@ -104,7 +104,7 @@ public class PrinterPrintTest extends CamelTestSupport {
});
}
- private void sendGIF() throws Exception {
+ private void sendGIF() {
template.send("direct:start", new Processor() {
public void process(Exchange exchange) throws Exception {
// Read from an input stream
@@ -125,7 +125,7 @@ public class PrinterPrintTest extends CamelTestSupport {
});
}
- private void sendJPEG() throws Exception {
+ private void sendJPEG() {
template.send("direct:start", new Processor() {
public void process(Exchange exchange) throws Exception {
// Read from an input stream
@@ -359,7 +359,7 @@ public class PrinterPrintTest extends CamelTestSupport {
}
@Test
- public void printToMiddleTray() throws Exception {
+ public void printToMiddleTray() {
PrinterEndpoint endpoint = new PrinterEndpoint();
PrinterConfiguration configuration = new PrinterConfiguration();
configuration.setHostname("localhost");
@@ -383,7 +383,7 @@ public class PrinterPrintTest extends CamelTestSupport {
}
@Test
- public void printsWithLandscapeOrientation() throws Exception {
+ public void printsWithLandscapeOrientation() {
PrinterEndpoint endpoint = new PrinterEndpoint();
PrinterConfiguration configuration = new PrinterConfiguration();
configuration.setHostname("localhost");
[camel] 05/09: CAMEL-17763: cleaned up unused exceptions in camel-quartz
Posted by or...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 3de0b70999c453f0a7a6dd3a7714f5d749e1846c
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Apr 12 18:17:37 2022 +0200
CAMEL-17763: cleaned up unused exceptions in camel-quartz
---
.../component/quartz/DelegateEndpointQuartzTest.java | 2 +-
.../component/quartz/QuartzAddDynamicRouteTest.java | 2 +-
.../QuartzAddRoutesAfterCamelContextStartedTest.java | 2 +-
.../camel/component/quartz/QuartzAutoStartTest.java | 4 ++--
...rtzComponentCamelContextSchedulerIsolationTest.java | 3 +--
...QuartzComponentCamelContextSharedSchedulerTest.java | 6 +++---
.../camel/component/quartz/QuartzComponentTest.java | 2 +-
.../component/quartz/QuartzCronRouteFireNowTest.java | 3 +--
.../quartz/QuartzCronRouteWithSmallCacheTest.java | 2 +-
.../component/quartz/QuartzCustomCalendarFireTest.java | 2 +-
.../quartz/QuartzCustomCalendarNoFireTest.java | 2 +-
.../component/quartz/QuartzEndpointConfigureTest.java | 4 ++--
.../camel/component/quartz/QuartzManagementTest.java | 4 ++--
.../component/quartz/QuartzNameCollisionTest.java | 18 +++++++++---------
.../quartz/QuartzOneCamelContextRestartTest.java | 4 ++--
.../quartz/QuartzOneCamelContextSuspendResumeTest.java | 4 ++--
.../camel/component/quartz/QuartzPropertiesTest.java | 2 +-
.../component/quartz/QuartzTriggerParametersTest.java | 4 ++--
.../quartz/QuartzTwoCamelContextRestartTest.java | 6 +++---
.../quartz/QuartzTwoCamelContextSameNameClashTest.java | 6 +++---
.../quartz/QuartzTwoCamelContextSuspendResumeTest.java | 6 +++---
.../component/quartz/QuartzTwoCamelContextTest.java | 8 ++++----
...ringQuartzConsumerTwoAppsClusteredRecoveryTest.java | 2 +-
.../component/quartz/StatefulQuartzRouteTest.java | 2 +-
.../component/quartz/cron/QuartzCronMappingTest.java | 4 ++--
.../quartz/FileConsumerQuartzSchedulerRestartTest.java | 4 ++--
.../quartz/FileConsumerQuartzSchedulerTest.java | 4 ++--
.../quartz/MultiplePoliciesOnRouteTest.java | 2 +-
.../RouteAutoStopFalseCronScheduledPolicyTest.java | 2 +-
29 files changed, 57 insertions(+), 59 deletions(-)
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/DelegateEndpointQuartzTest.java b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/DelegateEndpointQuartzTest.java
index 3234140c217..bc56c6a16fc 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/DelegateEndpointQuartzTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/DelegateEndpointQuartzTest.java
@@ -62,7 +62,7 @@ public class DelegateEndpointQuartzTest extends CamelTestSupport {
}
@Override
- protected void bindToRegistry(Registry registry) throws Exception {
+ protected void bindToRegistry(Registry registry) {
registry.bind("my", new MyComponent());
}
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzAddDynamicRouteTest.java b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzAddDynamicRouteTest.java
index 130ebe5b11e..881f92acdbd 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzAddDynamicRouteTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzAddDynamicRouteTest.java
@@ -38,7 +38,7 @@ public class QuartzAddDynamicRouteTest extends BaseQuartzTest {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("quartz://myGroup/myTimerName?trigger.repeatInterval=2&trigger.repeatCount=1").routeId("myRoute")
.to("direct:foo");
}
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzAddRoutesAfterCamelContextStartedTest.java b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzAddRoutesAfterCamelContextStartedTest.java
index 796ed9c754d..869bc769ae9 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzAddRoutesAfterCamelContextStartedTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzAddRoutesAfterCamelContextStartedTest.java
@@ -35,7 +35,7 @@ public class QuartzAddRoutesAfterCamelContextStartedTest extends BaseQuartzTest
// add the quartz router after CamelContext has been started
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("quartz://myGroup/myTimerName?trigger.repeatInterval=100&trigger.repeatCount=1").to("mock:result");
}
});
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzAutoStartTest.java b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzAutoStartTest.java
index 1ea3b7f7098..7f77cfbe254 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzAutoStartTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzAutoStartTest.java
@@ -47,10 +47,10 @@ public class QuartzAutoStartTest extends BaseQuartzTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("quartz://myGroup/myTimerName?cron=0/1+*+*+*+*+?&autoStartScheduler=false").to("mock:one");
}
};
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzComponentCamelContextSchedulerIsolationTest.java b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzComponentCamelContextSchedulerIsolationTest.java
index 97b38e22aa1..e465fe3cbf2 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzComponentCamelContextSchedulerIsolationTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzComponentCamelContextSchedulerIsolationTest.java
@@ -21,7 +21,6 @@ import org.apache.camel.impl.DefaultCamelContext;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.Test;
import org.quartz.Scheduler;
-import org.quartz.SchedulerException;
import static org.junit.jupiter.api.Assertions.assertNotEquals;
import static org.junit.jupiter.api.Assertions.assertNotSame;
@@ -72,7 +71,7 @@ public class QuartzComponentCamelContextSchedulerIsolationTest {
/**
* Get the default scheduler for the provided camel context.
*/
- private Scheduler getDefaultScheduler(CamelContext context) throws SchedulerException {
+ private Scheduler getDefaultScheduler(CamelContext context) {
return getQuartzComponent(context).getScheduler();
}
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzComponentCamelContextSharedSchedulerTest.java b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzComponentCamelContextSharedSchedulerTest.java
index e87c76e5b9c..b622e3a5bc8 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzComponentCamelContextSharedSchedulerTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzComponentCamelContextSharedSchedulerTest.java
@@ -38,7 +38,7 @@ public class QuartzComponentCamelContextSharedSchedulerTest {
camel1 = new DefaultCamelContext();
camel1.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("quartz://myGroup/myTimerName?cron=0/2+*+*+*+*+?").to("mock:one");
}
});
@@ -52,7 +52,7 @@ public class QuartzComponentCamelContextSharedSchedulerTest {
camel2.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("quartz://myOtherGroup/myOtherTimerName?cron=0/1+*+*+*+*+?").to("mock:two");
}
});
@@ -61,7 +61,7 @@ public class QuartzComponentCamelContextSharedSchedulerTest {
}
@AfterEach
- public void tearDown() throws Exception {
+ public void tearDown() {
camel1.stop();
camel2.stop();
}
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzComponentTest.java b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzComponentTest.java
index 88443a4c81c..fc727be3bac 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzComponentTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzComponentTest.java
@@ -43,7 +43,7 @@ public class QuartzComponentTest extends BaseQuartzTest {
}
@Test
- public void testQuartzComponent() throws Exception {
+ public void testQuartzComponent() {
QuartzComponent comp = new QuartzComponent(context);
comp.start();
comp.stop();
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzCronRouteFireNowTest.java b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzCronRouteFireNowTest.java
index 45f24da00a0..0f26b736bef 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzCronRouteFireNowTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzCronRouteFireNowTest.java
@@ -21,7 +21,6 @@ import java.util.concurrent.TimeUnit;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.junit.jupiter.api.Test;
-import org.quartz.SchedulerException;
public class QuartzCronRouteFireNowTest extends BaseQuartzTest {
@@ -40,7 +39,7 @@ public class QuartzCronRouteFireNowTest extends BaseQuartzTest {
@Override
protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws SchedulerException {
+ public void configure() {
// daily trigger started a day ago
from("quartz://daily?triggerStartDelay=" + TimeUnit.DAYS.toMillis(-1L) + "&cron=0+0+0+*+*+?")
.to("log:quartz")
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzCronRouteWithSmallCacheTest.java b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzCronRouteWithSmallCacheTest.java
index ad36d113c5a..cd3f65f2c75 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzCronRouteWithSmallCacheTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzCronRouteWithSmallCacheTest.java
@@ -59,7 +59,7 @@ public class QuartzCronRouteWithSmallCacheTest extends BaseQuartzTest {
from("quartz://myGroup/myTimerName?cron=0/2+*+*+*+*+?").process(new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
latch.countDown();
template.sendBody("direct:foo", "Quartz triggered");
}
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzCustomCalendarFireTest.java b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzCustomCalendarFireTest.java
index c691fb987df..156be780ec4 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzCustomCalendarFireTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzCustomCalendarFireTest.java
@@ -52,7 +52,7 @@ public class QuartzCustomCalendarFireTest extends BaseQuartzTest {
}
@BindToRegistry("calendar")
- public HolidayCalendar loadCalendar() throws Exception {
+ public HolidayCalendar loadCalendar() {
HolidayCalendar cal = new HolidayCalendar();
java.util.Calendar tomorrow = java.util.Calendar.getInstance();
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzCustomCalendarNoFireTest.java b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzCustomCalendarNoFireTest.java
index 8a97836175a..67b418ffe4d 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzCustomCalendarNoFireTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzCustomCalendarNoFireTest.java
@@ -52,7 +52,7 @@ public class QuartzCustomCalendarNoFireTest extends BaseQuartzTest {
}
@BindToRegistry("calendar")
- public HolidayCalendar loadCalendar() throws Exception {
+ public HolidayCalendar loadCalendar() {
HolidayCalendar cal = new HolidayCalendar();
cal.addExcludedDate(new Date());
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzEndpointConfigureTest.java b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzEndpointConfigureTest.java
index 17e947963e4..e368b87c492 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzEndpointConfigureTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzEndpointConfigureTest.java
@@ -122,7 +122,7 @@ public class QuartzEndpointConfigureTest extends BaseQuartzTest {
}
@Test
- public void testConfigureNoDoubleSlashNoCron() throws Exception {
+ public void testConfigureNoDoubleSlashNoCron() {
QuartzEndpoint endpoint = resolveMandatoryEndpoint("quartz:myGroup/myTimerName");
TriggerKey triggerKey = endpoint.getTriggerKey();
@@ -150,7 +150,7 @@ public class QuartzEndpointConfigureTest extends BaseQuartzTest {
}
@Test
- public void testConfigureDeleteJob() throws Exception {
+ public void testConfigureDeleteJob() {
QuartzEndpoint endpoint = resolveMandatoryEndpoint("quartz:myGroup/myTimerName?cron=0+0+*+*+*+?");
assertEquals("0 0 * * * ?", endpoint.getCron(), "cron expression");
assertTrue(endpoint.isDeleteJob(), "deleteJob");
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzManagementTest.java b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzManagementTest.java
index 2fad655c887..19f566fc28a 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzManagementTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzManagementTest.java
@@ -55,10 +55,10 @@ public class QuartzManagementTest extends BaseQuartzTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("quartz://myGroup/myTimerName?trigger.repeatInterval=2&trigger.repeatCount=1").routeId("myRoute")
.to("mock:result");
}
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzNameCollisionTest.java b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzNameCollisionTest.java
index cd42d98509a..813adc39c4a 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzNameCollisionTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzNameCollisionTest.java
@@ -42,7 +42,7 @@ public class QuartzNameCollisionTest {
camel1 = new DefaultCamelContext();
camel1.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("quartz://myGroup/myTimerName?cron=0/1+*+*+*+*+?").to("log:one", "mock:one");
}
});
@@ -65,7 +65,7 @@ public class QuartzNameCollisionTest {
camel1 = new DefaultCamelContext();
camel1.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("quartz://myGroup/myTimerName?cron=0/1+*+*+*+*+?").to("log:one", "mock:one");
}
});
@@ -74,7 +74,7 @@ public class QuartzNameCollisionTest {
camel2 = new DefaultCamelContext();
camel2.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("quartz://myGroup/myTimerName=0/2+*+*+*+*+?").to("log:two", "mock:two");
}
});
@@ -89,7 +89,7 @@ public class QuartzNameCollisionTest {
camel1 = new DefaultCamelContext();
camel1.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("quartz://myGroup/myTimerName?stateful=true&cron=0/1+*+*+*+*+?").to("log:one", "mock:one");
}
});
@@ -98,7 +98,7 @@ public class QuartzNameCollisionTest {
camel2 = new DefaultCamelContext();
camel2.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("quartz://myGroup/myTimerName?stateful=true").to("log:two", "mock:two");
}
});
@@ -115,7 +115,7 @@ public class QuartzNameCollisionTest {
camel.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("quartz://myGroup/myTimerName?cron=0/1+*+*+*+*+?").to("log:one", "mock:one");
}
});
@@ -142,14 +142,14 @@ public class QuartzNameCollisionTest {
camel1 = new DefaultCamelContext();
camel1.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("quartz://myGroup/myTimerName?cron=0/1+*+*+*+*+?").id("route-1").to("log:one", "mock:one");
}
});
camel1.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("quartz://myGroup2/myTimerName?cron=0/1+*+*+*+*+?").id("route-2").to("log:one", "mock:one");
}
});
@@ -170,7 +170,7 @@ public class QuartzNameCollisionTest {
}
@AfterEach
- public void cleanUp() throws Exception {
+ public void cleanUp() {
if (camel1 != null) {
camel1.stop();
camel1 = null;
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzOneCamelContextRestartTest.java b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzOneCamelContextRestartTest.java
index 5d56015e065..ab08df00cef 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzOneCamelContextRestartTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzOneCamelContextRestartTest.java
@@ -32,7 +32,7 @@ public class QuartzOneCamelContextRestartTest {
camel1 = new DefaultCamelContext();
camel1.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("quartz://myGroup/myTimerName?cron=0/1+*+*+*+*+?").to("log:one", "mock:one");
}
});
@@ -40,7 +40,7 @@ public class QuartzOneCamelContextRestartTest {
}
@AfterEach
- public void tearDown() throws Exception {
+ public void tearDown() {
camel1.stop();
}
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzOneCamelContextSuspendResumeTest.java b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzOneCamelContextSuspendResumeTest.java
index 0265b8c1200..59659e5547d 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzOneCamelContextSuspendResumeTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzOneCamelContextSuspendResumeTest.java
@@ -32,7 +32,7 @@ public class QuartzOneCamelContextSuspendResumeTest {
camel1 = new DefaultCamelContext();
camel1.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("quartz://myGroup/myTimerName?cron=0/1+*+*+*+*+?").to("mock:one");
}
});
@@ -40,7 +40,7 @@ public class QuartzOneCamelContextSuspendResumeTest {
}
@AfterEach
- public void tearDown() throws Exception {
+ public void tearDown() {
camel1.stop();
}
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzPropertiesTest.java b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzPropertiesTest.java
index afb08d0697e..5073fad055f 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzPropertiesTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzPropertiesTest.java
@@ -54,7 +54,7 @@ public class QuartzPropertiesTest extends BaseQuartzTest {
}
@Test
- public void testQuartzPropertiesFileNotFound() throws Exception {
+ public void testQuartzPropertiesFileNotFound() {
quartz = context.getComponent("quartz", QuartzComponent.class);
quartz.setPropertiesFile("doesnotexist.properties");
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzTriggerParametersTest.java b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzTriggerParametersTest.java
index 9f793ea4262..b7e84390142 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzTriggerParametersTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzTriggerParametersTest.java
@@ -32,10 +32,10 @@ public class QuartzTriggerParametersTest extends BaseQuartzTest {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
String cron = String.format("quartz://job?cron=0+%s+%s+?+*+*&trigger.timeZone=%s&trigger.misfireInstruction=2",
59, 23, "Europe/Berlin");
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzTwoCamelContextRestartTest.java b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzTwoCamelContextRestartTest.java
index 1844a9cc50f..06ffc06385c 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzTwoCamelContextRestartTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzTwoCamelContextRestartTest.java
@@ -33,7 +33,7 @@ public class QuartzTwoCamelContextRestartTest {
camel1 = new DefaultCamelContext();
camel1.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("quartz://myGroup/myTimerName?cron=0/1+*+*+*+*+?").to("log:one", "mock:one");
}
});
@@ -43,7 +43,7 @@ public class QuartzTwoCamelContextRestartTest {
camel2.getComponent("quartz", QuartzComponent.class).setEnableJmx(false);
camel2.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("quartz://myOtherGroup/myOtherTimerName?cron=0/1+*+*+*+*+?").to("log:two", "mock:two");
}
});
@@ -51,7 +51,7 @@ public class QuartzTwoCamelContextRestartTest {
}
@AfterEach
- public void tearDown() throws Exception {
+ public void tearDown() {
camel1.stop();
camel2.stop();
}
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzTwoCamelContextSameNameClashTest.java b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzTwoCamelContextSameNameClashTest.java
index 57d78270ea3..a184f4f4380 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzTwoCamelContextSameNameClashTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzTwoCamelContextSameNameClashTest.java
@@ -36,7 +36,7 @@ public class QuartzTwoCamelContextSameNameClashTest {
camel1.setName("myCamel");
camel1.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("quartz://myGroup/myTimerName?cron=0/1+*+*+*+*+?")
.log("Fired one")
.to("mock:one");
@@ -48,7 +48,7 @@ public class QuartzTwoCamelContextSameNameClashTest {
camel2.setName("myCamel");
camel2.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("quartz://myOtherGroup/myOtherTimerName?cron=0/1+*+*+*+*+?")
.log("Fired two")
.to("mock:two");
@@ -58,7 +58,7 @@ public class QuartzTwoCamelContextSameNameClashTest {
}
@AfterEach
- public void tearDown() throws Exception {
+ public void tearDown() {
camel1.stop();
camel2.stop();
}
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzTwoCamelContextSuspendResumeTest.java b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzTwoCamelContextSuspendResumeTest.java
index 0616203df81..5399b0460e9 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzTwoCamelContextSuspendResumeTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzTwoCamelContextSuspendResumeTest.java
@@ -33,7 +33,7 @@ public class QuartzTwoCamelContextSuspendResumeTest {
camel1 = new DefaultCamelContext();
camel1.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("quartz://myGroup/myTimerName?cron=0/1+*+*+*+*+?").to("mock:one");
}
});
@@ -42,7 +42,7 @@ public class QuartzTwoCamelContextSuspendResumeTest {
camel2 = new DefaultCamelContext();
camel2.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("quartz://myOtherGroup/myOtherTimerName?cron=0/1+*+*+*+*+?").to("mock:two");
}
});
@@ -50,7 +50,7 @@ public class QuartzTwoCamelContextSuspendResumeTest {
}
@AfterEach
- public void tearDown() throws Exception {
+ public void tearDown() {
camel1.stop();
camel2.stop();
}
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzTwoCamelContextTest.java b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzTwoCamelContextTest.java
index 2f24d4cc0d9..1916908c431 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzTwoCamelContextTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/QuartzTwoCamelContextTest.java
@@ -33,7 +33,7 @@ public class QuartzTwoCamelContextTest {
camel1 = new DefaultCamelContext();
camel1.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("quartz://myGroup/myTimerName?cron=0/1+*+*+*+*+?").to("mock:one");
}
});
@@ -42,7 +42,7 @@ public class QuartzTwoCamelContextTest {
camel2 = new DefaultCamelContext();
camel2.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("quartz://myOtherGroup/myOtherTimerName?cron=0/1+*+*+*+*+?").to("mock:two");
}
});
@@ -50,7 +50,7 @@ public class QuartzTwoCamelContextTest {
}
@AfterEach
- public void tearDown() throws Exception {
+ public void tearDown() {
camel1.stop();
camel2.stop();
}
@@ -80,7 +80,7 @@ public class QuartzTwoCamelContextTest {
DefaultCamelContext camel3 = new DefaultCamelContext();
camel3.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("quartz://myThirdGroup/myThirdTimerName?cron=0/1+*+*+*+*+?").to("mock:three");
}
});
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/SpringQuartzConsumerTwoAppsClusteredRecoveryTest.java b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/SpringQuartzConsumerTwoAppsClusteredRecoveryTest.java
index 8e6f7f50562..b7e9bc3c39f 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/SpringQuartzConsumerTwoAppsClusteredRecoveryTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/SpringQuartzConsumerTwoAppsClusteredRecoveryTest.java
@@ -106,7 +106,7 @@ public class SpringQuartzConsumerTwoAppsClusteredRecoveryTest {
ApplicationContext applicationContext;
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
// shutdown the application context;
((AbstractXmlApplicationContext) applicationContext).close();
}
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/StatefulQuartzRouteTest.java b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/StatefulQuartzRouteTest.java
index a9265fdc3ef..3832b94a11a 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/StatefulQuartzRouteTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/StatefulQuartzRouteTest.java
@@ -50,7 +50,7 @@ public class StatefulQuartzRouteTest extends BaseQuartzTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/cron/QuartzCronMappingTest.java b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/cron/QuartzCronMappingTest.java
index ab88f301fa7..c533be2ca2a 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/cron/QuartzCronMappingTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/cron/QuartzCronMappingTest.java
@@ -32,7 +32,7 @@ public class QuartzCronMappingTest extends BaseQuartzTest {
public void test5PartsCronPattern() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("cron://myName?schedule=* * * * ?")
.id("cron")
.to("mock:result");
@@ -46,7 +46,7 @@ public class QuartzCronMappingTest extends BaseQuartzTest {
public void test6PartsCronPattern() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("cron://myName?schedule=0/2 * * * * ?")
.id("cron")
.to("mock:result");
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/pollconsumer/quartz/FileConsumerQuartzSchedulerRestartTest.java b/components/camel-quartz/src/test/java/org/apache/camel/pollconsumer/quartz/FileConsumerQuartzSchedulerRestartTest.java
index e7c9de239db..1c03ccfff67 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/pollconsumer/quartz/FileConsumerQuartzSchedulerRestartTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/pollconsumer/quartz/FileConsumerQuartzSchedulerRestartTest.java
@@ -40,10 +40,10 @@ public class FileConsumerQuartzSchedulerRestartTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(fileUri(
"?scheduler=quartz&scheduler.cron=0/2+*+*+*+*+?&scheduler.triggerGroup=myGroup&scheduler.triggerId=myId"))
.routeId("foo").noAutoStartup()
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/pollconsumer/quartz/FileConsumerQuartzSchedulerTest.java b/components/camel-quartz/src/test/java/org/apache/camel/pollconsumer/quartz/FileConsumerQuartzSchedulerTest.java
index dd7a1ee57b0..82a9d73ee7e 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/pollconsumer/quartz/FileConsumerQuartzSchedulerTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/pollconsumer/quartz/FileConsumerQuartzSchedulerTest.java
@@ -35,10 +35,10 @@ public class FileConsumerQuartzSchedulerTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(fileUri("?scheduler=quartz&scheduler.cron=0/2+*+*+*+*+?")).routeId("foo").noAutoStartup()
.to("mock:result");
}
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/MultiplePoliciesOnRouteTest.java b/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/MultiplePoliciesOnRouteTest.java
index dc19a27643e..2911a0e8b9b 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/MultiplePoliciesOnRouteTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/MultiplePoliciesOnRouteTest.java
@@ -35,7 +35,7 @@ public class MultiplePoliciesOnRouteTest extends CamelTestSupport {
private int size = 100;
@Override
- protected void bindToRegistry(Registry registry) throws Exception {
+ protected void bindToRegistry(Registry registry) {
registry.bind("startPolicy", createRouteStartPolicy());
registry.bind("throttlePolicy", createThrottlePolicy());
}
diff --git a/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/RouteAutoStopFalseCronScheduledPolicyTest.java b/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/RouteAutoStopFalseCronScheduledPolicyTest.java
index 1df8dadf665..2dd63d51ab8 100644
--- a/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/RouteAutoStopFalseCronScheduledPolicyTest.java
+++ b/components/camel-quartz/src/test/java/org/apache/camel/routepolicy/quartz/RouteAutoStopFalseCronScheduledPolicyTest.java
@@ -36,7 +36,7 @@ public class RouteAutoStopFalseCronScheduledPolicyTest extends CamelTestSupport
policy.setRouteStartTime("*/5 * * * * ?");
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("seda:foo").routeId("foo").noAutoStartup()
.routePolicy(policy)
.to("mock:foo");
[camel] 02/09: CAMEL-17763: cleaned up unused exceptions in camel-reactive-streams
Posted by or...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 9b98c6ab880e558b645376af13fc7368a83d9cfe
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Apr 12 18:21:42 2022 +0200
CAMEL-17763: cleaned up unused exceptions in camel-reactive-streams
---
.../camel/component/reactive/streams/BasicSubscriberTest.java | 4 ++--
.../component/reactive/streams/CamelReactiveStreamsTest.java | 8 ++++----
.../camel/component/reactive/streams/ConcurrentConsumersTest.java | 2 +-
.../component/reactive/streams/DelayedMonoPublisherTest.java | 8 ++++----
.../camel/component/reactive/streams/ExchangeRequestTest.java | 8 ++++----
.../component/reactive/streams/PublisherTypeConversionTest.java | 2 +-
.../camel/component/reactive/streams/ReactiveStreamsJMXTest.java | 2 +-
.../camel/component/reactive/streams/RequestRefillTest.java | 2 +-
8 files changed, 18 insertions(+), 18 deletions(-)
diff --git a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/BasicSubscriberTest.java b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/BasicSubscriberTest.java
index a8f7ec7969d..1d567c60d2a 100644
--- a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/BasicSubscriberTest.java
+++ b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/BasicSubscriberTest.java
@@ -54,7 +54,7 @@ public class BasicSubscriberTest extends BaseReactiveTest {
}
@Override
- protected void doPostSetup() throws Exception {
+ protected void doPostSetup() {
Subscriber<Integer> sub = CamelReactiveStreams.get(context()).streamSubscriber("sub", Integer.class);
Subscriber<Integer> sub2 = CamelReactiveStreams.get(context()).streamSubscriber("sub2", Integer.class);
@@ -65,7 +65,7 @@ public class BasicSubscriberTest extends BaseReactiveTest {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
diff --git a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/CamelReactiveStreamsTest.java b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/CamelReactiveStreamsTest.java
index b325e6eb08d..97f1cf25a6c 100644
--- a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/CamelReactiveStreamsTest.java
+++ b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/CamelReactiveStreamsTest.java
@@ -30,7 +30,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
public class CamelReactiveStreamsTest {
@Test
- public void testDefaultService() throws Exception {
+ public void testDefaultService() {
DefaultCamelContext context = new DefaultCamelContext();
try {
context.start();
@@ -43,7 +43,7 @@ public class CamelReactiveStreamsTest {
}
@Test
- public void testSameDefaultServiceReturned() throws Exception {
+ public void testSameDefaultServiceReturned() {
DefaultCamelContext context = new DefaultCamelContext();
try {
context.start();
@@ -59,7 +59,7 @@ public class CamelReactiveStreamsTest {
}
@Test
- public void testSameServiceReturnedFromRegistry() throws Exception {
+ public void testSameServiceReturnedFromRegistry() {
ReactiveStreamsComponent component = new ReactiveStreamsComponent();
SimpleRegistry registry = new SimpleRegistry();
@@ -83,7 +83,7 @@ public class CamelReactiveStreamsTest {
}
@Test
- public void testNamedServiceResolvedUsingFactory() throws Exception {
+ public void testNamedServiceResolvedUsingFactory() {
ReactiveStreamsComponent component = new ReactiveStreamsComponent();
component.setServiceType("test-service");
diff --git a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/ConcurrentConsumersTest.java b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/ConcurrentConsumersTest.java
index ec65a299ab6..6fb6a2da56b 100644
--- a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/ConcurrentConsumersTest.java
+++ b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/ConcurrentConsumersTest.java
@@ -84,7 +84,7 @@ public class ConcurrentConsumersTest extends BaseReactiveTest {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
diff --git a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/DelayedMonoPublisherTest.java b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/DelayedMonoPublisherTest.java
index 050c11eb650..f34ee0e7e40 100644
--- a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/DelayedMonoPublisherTest.java
+++ b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/DelayedMonoPublisherTest.java
@@ -259,7 +259,7 @@ public class DelayedMonoPublisherTest {
}
@Test
- public void testDataOrExceptionAllowed() throws Exception {
+ public void testDataOrExceptionAllowed() {
DelayedMonoPublisher<Integer> pub = new DelayedMonoPublisher<>(service);
Exception ex = new RuntimeCamelException("An exception");
pub.setException(ex);
@@ -268,7 +268,7 @@ public class DelayedMonoPublisherTest {
}
@Test
- public void testDataOrExceptionAllowed2() throws Exception {
+ public void testDataOrExceptionAllowed2() {
DelayedMonoPublisher<Integer> pub = new DelayedMonoPublisher<>(service);
pub.setData(1);
Exception ex = new RuntimeCamelException("An exception");
@@ -277,7 +277,7 @@ public class DelayedMonoPublisherTest {
}
@Test
- public void testOnlyOneDataAllowed() throws Exception {
+ public void testOnlyOneDataAllowed() {
DelayedMonoPublisher<Integer> pub = new DelayedMonoPublisher<>(service);
pub.setData(1);
assertThrows(IllegalStateException.class,
@@ -285,7 +285,7 @@ public class DelayedMonoPublisherTest {
}
@Test
- public void testOnlyOneExceptionAllowed() throws Exception {
+ public void testOnlyOneExceptionAllowed() {
DelayedMonoPublisher<Integer> pub = new DelayedMonoPublisher<>(service);
final RuntimeCamelException runtimeException = new RuntimeCamelException("An exception");
pub.setException(runtimeException);
diff --git a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/ExchangeRequestTest.java b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/ExchangeRequestTest.java
index 8fc299008a5..ff75a0fa9c1 100644
--- a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/ExchangeRequestTest.java
+++ b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/ExchangeRequestTest.java
@@ -32,7 +32,7 @@ import static org.junit.jupiter.api.Assertions.assertNotNull;
public class ExchangeRequestTest extends BaseReactiveTest {
@Test
- public void testStreamRequest() throws Exception {
+ public void testStreamRequest() {
CamelReactiveStreamsService camel = CamelReactiveStreams.get(context);
@@ -48,7 +48,7 @@ public class ExchangeRequestTest extends BaseReactiveTest {
}
@Test
- public void testInteraction() throws Exception {
+ public void testInteraction() {
CamelReactiveStreamsService camel = CamelReactiveStreams.get(context);
@@ -60,7 +60,7 @@ public class ExchangeRequestTest extends BaseReactiveTest {
}
@Test
- public void testMultipleInteractions() throws Exception {
+ public void testMultipleInteractions() {
CamelReactiveStreamsService camel = CamelReactiveStreams.get(context);
Integer sum = Flowable.just(1, 2, 3)
@@ -73,7 +73,7 @@ public class ExchangeRequestTest extends BaseReactiveTest {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
diff --git a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/PublisherTypeConversionTest.java b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/PublisherTypeConversionTest.java
index eadd5a6d68f..213c9334410 100644
--- a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/PublisherTypeConversionTest.java
+++ b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/PublisherTypeConversionTest.java
@@ -69,7 +69,7 @@ public class PublisherTypeConversionTest extends BaseReactiveTest {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
diff --git a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/ReactiveStreamsJMXTest.java b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/ReactiveStreamsJMXTest.java
index e351b8275b1..41b827897eb 100644
--- a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/ReactiveStreamsJMXTest.java
+++ b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/ReactiveStreamsJMXTest.java
@@ -112,7 +112,7 @@ public class ReactiveStreamsJMXTest extends BaseReactiveTest {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
diff --git a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/RequestRefillTest.java b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/RequestRefillTest.java
index 440ffa3599d..04a1b147cf0 100644
--- a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/RequestRefillTest.java
+++ b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/RequestRefillTest.java
@@ -97,7 +97,7 @@ public class RequestRefillTest extends BaseReactiveTest {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
[camel] 04/09: CAMEL-17763: cleaned up unused exceptions in camel-quickfix
Posted by or...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 7dc30b5500026ede4ffcaa93ec7841e5f33106f8
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Apr 12 18:17:54 2022 +0200
CAMEL-17763: cleaned up unused exceptions in camel-quickfix
---
.../component/quickfixj/QuickfixjComponentTest.java | 11 +++++------
.../component/quickfixj/QuickfixjEngineTest.java | 4 ++--
.../quickfixj/examples/AuthenticationExample.java | 2 +-
.../quickfixj/examples/RestartRouteExample.java | 2 +-
.../quickfixj/examples/trading/TradeExecutor.java | 19 ++++++++-----------
.../examples/trading/TradeExecutorComponent.java | 10 +++++-----
.../transform/QuickfixjEventJsonTransformer.java | 3 +--
.../transform/QuickfixjMessageJsonTransformer.java | 4 +---
8 files changed, 24 insertions(+), 31 deletions(-)
diff --git a/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjComponentTest.java b/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjComponentTest.java
index 97659c45609..ceaa80eb2c5 100644
--- a/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjComponentTest.java
+++ b/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjComponentTest.java
@@ -20,7 +20,6 @@ import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.lang.reflect.Method;
-import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLClassLoader;
import java.util.concurrent.CountDownLatch;
@@ -119,11 +118,11 @@ public class QuickfixjComponentTest {
Thread.currentThread().setContextClassLoader(testClassLoader);
}
- private void setUpComponent() throws IOException, MalformedURLException, NoSuchMethodException {
+ private void setUpComponent() throws IOException, NoSuchMethodException {
setUpComponent(false);
}
- private void setUpComponent(boolean injectQfjPlugins) throws IOException, MalformedURLException, NoSuchMethodException {
+ private void setUpComponent(boolean injectQfjPlugins) throws NoSuchMethodException {
camelContext = new DefaultCamelContext();
component = new QuickfixjComponent();
component.setCamelContext(camelContext);
@@ -147,7 +146,7 @@ public class QuickfixjComponentTest {
}
@AfterEach
- public void tearDown() throws Exception {
+ public void tearDown() {
Thread.currentThread().setContextClassLoader(contextClassLoader);
if (component != null) {
component.stop();
@@ -335,7 +334,7 @@ public class QuickfixjComponentTest {
Consumer consumer = endpoint.createConsumer(new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
QuickfixjEventCategory eventCategory
= (QuickfixjEventCategory) exchange.getIn().getHeader(QuickfixjEndpoint.EVENT_CATEGORY_KEY);
if (eventCategory == QuickfixjEventCategory.SessionCreated) {
@@ -394,7 +393,7 @@ public class QuickfixjComponentTest {
Consumer consumer = endpoint.createConsumer(new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
QuickfixjEventCategory eventCategory
= (QuickfixjEventCategory) exchange.getIn().getHeader(QuickfixjEndpoint.EVENT_CATEGORY_KEY);
if (eventCategory == QuickfixjEventCategory.SessionLogon) {
diff --git a/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjEngineTest.java b/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjEngineTest.java
index 460be6b79b2..e3c0db207db 100644
--- a/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjEngineTest.java
+++ b/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjEngineTest.java
@@ -112,7 +112,7 @@ public class QuickfixjEngineTest {
}
@AfterEach
- public void tearDown() throws Exception {
+ public void tearDown() {
Thread.currentThread().setContextClassLoader(contextClassLoader);
if (quickfixjEngine != null) {
quickfixjEngine.stop();
@@ -120,7 +120,7 @@ public class QuickfixjEngineTest {
}
@Test
- public void missingSettingsResource() throws Exception {
+ public void missingSettingsResource() {
assertThrows(FileNotFoundException.class,
() -> new QuickfixjEngine(camelContext, "quickfix:test", "bogus.cfg"));
}
diff --git a/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/AuthenticationExample.java b/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/AuthenticationExample.java
index bfb1f47b156..0ba181a813d 100644
--- a/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/AuthenticationExample.java
+++ b/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/AuthenticationExample.java
@@ -54,7 +54,7 @@ public class AuthenticationExample {
RouteBuilder routes = new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// Modify the outgoing logon message to add a password
// The modified message will be sent from the FIX engine when the message exchange completes
from("quickfix:examples/inprocess.cfg?sessionID=FIX.4.2:TRADER->MARKET").filter(PredicateBuilder.and(
diff --git a/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/RestartRouteExample.java b/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/RestartRouteExample.java
index 62b6db0c270..84ca802e02f 100644
--- a/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/RestartRouteExample.java
+++ b/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/RestartRouteExample.java
@@ -49,7 +49,7 @@ public class RestartRouteExample {
RouteBuilder routes = new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("quickfix:examples/inprocess.cfg?sessionID=FIX.4.2:MARKET->TRADER").routeId("foo")
.filter(header(QuickfixjEndpoint.MESSAGE_TYPE_KEY).isEqualTo(MsgType.EMAIL))
.bean(new CountDownLatchDecrementer("message", receivedMessageLatch));
diff --git a/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/trading/TradeExecutor.java b/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/trading/TradeExecutor.java
index ae24095977a..0cefd2c2da0 100644
--- a/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/trading/TradeExecutor.java
+++ b/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/trading/TradeExecutor.java
@@ -26,10 +26,8 @@ import java.util.concurrent.CopyOnWriteArrayList;
import org.apache.camel.RuntimeCamelException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import quickfix.ConfigError;
import quickfix.DataDictionary;
import quickfix.DataDictionaryProvider;
-import quickfix.FieldConvertError;
import quickfix.FieldNotFound;
import quickfix.FixVersions;
import quickfix.IncorrectTagValue;
@@ -39,7 +37,6 @@ import quickfix.MessageUtils;
import quickfix.Session;
import quickfix.SessionID;
import quickfix.SessionNotFound;
-import quickfix.UnsupportedMessageType;
import quickfix.field.ApplVerID;
import quickfix.field.AvgPx;
import quickfix.field.CumQty;
@@ -73,7 +70,7 @@ public class TradeExecutor {
private int orderID;
private int execID;
- public TradeExecutor() throws ConfigError, FieldConvertError {
+ public TradeExecutor() {
setAlwaysFillLimitOrders(true);
Set<String> validOrderTypes = new HashSet<>();
@@ -108,7 +105,7 @@ public class TradeExecutor {
listeners.remove(listener);
}
- public void execute(final Message message) throws FieldNotFound, UnsupportedMessageType, IncorrectTagValue {
+ public void execute(final Message message) {
final SessionID sessionID = MessageUtils.getSessionID(message);
try {
@@ -131,7 +128,7 @@ public class TradeExecutor {
}
private void onMessage(quickfix.fix40.NewOrderSingle order, SessionID sessionID)
- throws FieldNotFound, UnsupportedMessageType, IncorrectTagValue {
+ throws FieldNotFound, IncorrectTagValue {
try {
validateOrder(order);
@@ -240,7 +237,7 @@ public class TradeExecutor {
}
private void onMessage(quickfix.fix41.NewOrderSingle order, SessionID sessionID)
- throws FieldNotFound, UnsupportedMessageType, IncorrectTagValue {
+ throws FieldNotFound, IncorrectTagValue {
try {
validateOrder(order);
@@ -280,7 +277,7 @@ public class TradeExecutor {
}
private void onMessage(quickfix.fix42.NewOrderSingle order, SessionID sessionID)
- throws FieldNotFound, UnsupportedMessageType, IncorrectTagValue {
+ throws FieldNotFound, IncorrectTagValue {
try {
validateOrder(order);
@@ -328,7 +325,7 @@ public class TradeExecutor {
}
private void onMessage(quickfix.fix43.NewOrderSingle order, SessionID sessionID)
- throws FieldNotFound, UnsupportedMessageType, IncorrectTagValue {
+ throws FieldNotFound, IncorrectTagValue {
try {
validateOrder(order);
@@ -363,7 +360,7 @@ public class TradeExecutor {
}
private void onMessage(quickfix.fix44.NewOrderSingle order, SessionID sessionID)
- throws FieldNotFound, UnsupportedMessageType, IncorrectTagValue {
+ throws FieldNotFound, IncorrectTagValue {
try {
validateOrder(order);
@@ -398,7 +395,7 @@ public class TradeExecutor {
}
private void onMessage(quickfix.fix50.NewOrderSingle order, SessionID sessionID)
- throws FieldNotFound, UnsupportedMessageType, IncorrectTagValue {
+ throws FieldNotFound, IncorrectTagValue {
try {
validateOrder(order);
diff --git a/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/trading/TradeExecutorComponent.java b/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/trading/TradeExecutorComponent.java
index 5b03354383c..c12b4e078e0 100644
--- a/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/trading/TradeExecutorComponent.java
+++ b/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/trading/TradeExecutorComponent.java
@@ -126,10 +126,10 @@ public class TradeExecutorComponent extends DefaultComponent {
}
@Override
- public Producer createProducer() throws Exception {
+ public Producer createProducer() {
return new DefaultProducer(this) {
@Override
- public void process(final Exchange exchange) throws Exception {
+ public void process(final Exchange exchange) {
executor.execute(new Runnable() {
@Override
public void run() {
@@ -145,15 +145,15 @@ public class TradeExecutorComponent extends DefaultComponent {
}
@Override
- public Consumer createConsumer(Processor processor) throws Exception {
+ public Consumer createConsumer(Processor processor) {
return new DefaultConsumer(this, processor) {
@Override
- protected void doStart() throws Exception {
+ protected void doStart() {
processors.add(getProcessor());
}
@Override
- protected void doStop() throws Exception {
+ protected void doStop() {
processors.remove(getProcessor());
}
};
diff --git a/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/transform/QuickfixjEventJsonTransformer.java b/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/transform/QuickfixjEventJsonTransformer.java
index 4c235ee059c..a78ebe86be3 100644
--- a/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/transform/QuickfixjEventJsonTransformer.java
+++ b/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/transform/QuickfixjEventJsonTransformer.java
@@ -18,7 +18,6 @@ package org.apache.camel.component.quickfixj.examples.transform;
import org.apache.camel.Exchange;
import org.apache.camel.component.quickfixj.QuickfixjEndpoint;
-import quickfix.ConfigError;
import quickfix.DataDictionary;
import quickfix.Message;
import quickfix.Session;
@@ -27,7 +26,7 @@ import quickfix.SessionID;
public class QuickfixjEventJsonTransformer {
private final QuickfixjMessageJsonTransformer renderer;
- public QuickfixjEventJsonTransformer() throws ConfigError {
+ public QuickfixjEventJsonTransformer() {
renderer = new QuickfixjMessageJsonTransformer();
}
diff --git a/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/transform/QuickfixjMessageJsonTransformer.java b/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/transform/QuickfixjMessageJsonTransformer.java
index ba0820b2da9..4a0ee3aac3f 100644
--- a/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/transform/QuickfixjMessageJsonTransformer.java
+++ b/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/transform/QuickfixjMessageJsonTransformer.java
@@ -18,11 +18,9 @@ package org.apache.camel.component.quickfixj.examples.transform;
import java.util.Iterator;
-import quickfix.ConfigError;
import quickfix.DataDictionary;
import quickfix.Field;
import quickfix.FieldMap;
-import quickfix.FieldNotFound;
import quickfix.FieldType;
import quickfix.Group;
import quickfix.Message;
@@ -32,7 +30,7 @@ import quickfix.SessionID;
public class QuickfixjMessageJsonTransformer {
- public String transform(Message message) throws FieldNotFound, ConfigError {
+ public String transform(Message message) {
SessionID sessionID = MessageUtils.getSessionID(message);
Session session = Session.lookupSession(sessionID);
DataDictionary dataDictionary = session.getDataDictionary();
[camel] 01/09: CAMEL-17763: cleaned up unused exceptions in camel-reactor
Posted by or...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 2f68a771483f0cb0df6097e7995cd03c58c00c6f
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Apr 12 18:22:24 2022 +0200
CAMEL-17763: cleaned up unused exceptions in camel-reactor
---
.../engine/ReactorStreamsServiceBackpressureTest.java | 6 +++---
.../reactor/engine/ReactorStreamsServiceEventTypeTest.java | 10 +++++-----
.../engine/ReactorStreamsServiceSubscriberTest.java | 6 +++---
.../reactor/engine/ReactorStreamsServiceTest.java | 14 +++++++-------
.../reactor/engine/ReactorStreamsServiceTestSupport.java | 2 +-
5 files changed, 19 insertions(+), 19 deletions(-)
diff --git a/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceBackpressureTest.java b/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceBackpressureTest.java
index d0e43cf0b55..6391af2ac63 100644
--- a/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceBackpressureTest.java
+++ b/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceBackpressureTest.java
@@ -39,7 +39,7 @@ public class ReactorStreamsServiceBackpressureTest extends ReactorStreamsService
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("timer:gen?period=20&repeatCount=20")
.setBody()
.header(Exchange.TIMER_COUNTER)
@@ -74,7 +74,7 @@ public class ReactorStreamsServiceBackpressureTest extends ReactorStreamsService
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("timer:gen?period=20&repeatCount=20")
.setBody()
.header(Exchange.TIMER_COUNTER)
@@ -121,7 +121,7 @@ public class ReactorStreamsServiceBackpressureTest extends ReactorStreamsService
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("timer:gen?period=20&repeatCount=20")
.setBody()
.header(Exchange.TIMER_COUNTER)
diff --git a/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceEventTypeTest.java b/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceEventTypeTest.java
index 76273a32859..8379702ef6b 100644
--- a/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceEventTypeTest.java
+++ b/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceEventTypeTest.java
@@ -33,7 +33,7 @@ public class ReactorStreamsServiceEventTypeTest extends ReactorStreamsServiceTes
public void testOnCompleteHeaderForwarded() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("reactive-streams:numbers?forwardOnComplete=true")
.to("mock:endpoint");
}
@@ -56,7 +56,7 @@ public class ReactorStreamsServiceEventTypeTest extends ReactorStreamsServiceTes
public void testOnCompleteHeaderNotForwarded() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("reactive-streams:numbers")
.to("mock:endpoint");
}
@@ -77,7 +77,7 @@ public class ReactorStreamsServiceEventTypeTest extends ReactorStreamsServiceTes
public void testOnNextHeaderForwarded() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("reactive-streams:numbers")
.to("mock:endpoint");
}
@@ -102,7 +102,7 @@ public class ReactorStreamsServiceEventTypeTest extends ReactorStreamsServiceTes
public void testOnErrorHeaderForwarded() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("reactive-streams:numbers?forwardOnError=true")
.to("mock:endpoint");
}
@@ -136,7 +136,7 @@ public class ReactorStreamsServiceEventTypeTest extends ReactorStreamsServiceTes
public void testOnErrorHeaderNotForwarded() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("reactive-streams:numbers")
.to("mock:endpoint");
}
diff --git a/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceSubscriberTest.java b/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceSubscriberTest.java
index fc1e42f977f..5a03823fa14 100644
--- a/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceSubscriberTest.java
+++ b/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceSubscriberTest.java
@@ -33,7 +33,7 @@ public class ReactorStreamsServiceSubscriberTest extends ReactorStreamsServiceTe
public void testSubscriber() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("reactive-streams:sub1")
.to("mock:sub1");
from("reactive-streams:sub2")
@@ -83,7 +83,7 @@ public class ReactorStreamsServiceSubscriberTest extends ReactorStreamsServiceTe
public void testSingleConsumer() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("reactive-streams:singleConsumer")
.process()
.message(m -> m.setHeader("thread", Thread.currentThread().getId()))
@@ -119,7 +119,7 @@ public class ReactorStreamsServiceSubscriberTest extends ReactorStreamsServiceTe
public void testMultipleConsumers() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("reactive-streams:multipleConsumers?concurrentConsumers=3")
.process()
.message(m -> m.setHeader("thread", Thread.currentThread().getId()))
diff --git a/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceTest.java b/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceTest.java
index af386f6f416..0cf0d2dffd3 100644
--- a/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceTest.java
+++ b/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceTest.java
@@ -88,7 +88,7 @@ public class ReactorStreamsServiceTest extends ReactorStreamsServiceTestSupport
public void testFromStreamTimer() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("timer:tick?period=5&repeatCount=30")
.setBody()
.header(Exchange.TIMER_COUNTER)
@@ -117,7 +117,7 @@ public class ReactorStreamsServiceTest extends ReactorStreamsServiceTestSupport
context.start();
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:reactive")
.to("reactive-streams:direct");
}
@@ -144,7 +144,7 @@ public class ReactorStreamsServiceTest extends ReactorStreamsServiceTestSupport
public void testMultipleSubscriptionsWithTimer() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("timer:tick?period=50")
.setBody().header(Exchange.TIMER_COUNTER)
.to("reactive-streams:tick");
@@ -205,7 +205,7 @@ public class ReactorStreamsServiceTest extends ReactorStreamsServiceTestSupport
context.start();
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:source")
.to("direct:stream")
.setBody()
@@ -234,7 +234,7 @@ public class ReactorStreamsServiceTest extends ReactorStreamsServiceTestSupport
context.start();
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:source")
.to("direct:stream")
.setBody()
@@ -362,7 +362,7 @@ public class ReactorStreamsServiceTest extends ReactorStreamsServiceTestSupport
context.start();
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:reactor")
.to("mock:result");
}
@@ -389,7 +389,7 @@ public class ReactorStreamsServiceTest extends ReactorStreamsServiceTestSupport
public void testOnlyOneCamelProducerPerPublisher() throws Exception {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:one")
.to("reactive-streams:stream");
from("direct:two")
diff --git a/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceTestSupport.java b/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceTestSupport.java
index f8723b30442..045c8133a6a 100644
--- a/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceTestSupport.java
+++ b/components/camel-reactor/src/test/java/org/apache/camel/component/reactor/engine/ReactorStreamsServiceTestSupport.java
@@ -44,7 +44,7 @@ class ReactorStreamsServiceTestSupport extends CamelTestSupport {
}
@Override
- protected void doPostSetup() throws Exception {
+ protected void doPostSetup() {
this.crs = CamelReactiveStreams.get(context);
}