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:24 UTC
[camel] 02/09: CAMEL-17763: cleaned up unused exceptions in camel-reactive-streams
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() {