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 <angusyo...@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);
}
