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 6ed996c3bcc916fe818b28b8db6a1f9b13707463
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Tue Apr 12 18:25:11 2022 +0200
CAMEL-17763: cleaned up unused exceptions in camel-rxjava
---
.../engine/RxJavaStreamsServiceBackpressureTest.java | 6 +++---
.../rxjava/engine/RxJavaStreamsServiceEventTypeTest.java | 10 +++++-----
.../rxjava/engine/RxJavaStreamsServiceSubscriberTest.java | 6 +++---
.../component/rxjava/engine/RxJavaStreamsServiceTest.java | 14 +++++++-------
.../rxjava/engine/RxJavaStreamsServiceTestSupport.java | 2 +-
5 files changed, 19 insertions(+), 19 deletions(-)
diff --git
a/components/camel-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceBackpressureTest.java
b/components/camel-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceBackpressureTest.java
index e4312caca11..28e1882e389 100644
---
a/components/camel-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceBackpressureTest.java
+++
b/components/camel-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceBackpressureTest.java
@@ -38,7 +38,7 @@ public class RxJavaStreamsServiceBackpressureTest extends
RxJavaStreamsServiceTe
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)
@@ -73,7 +73,7 @@ public class RxJavaStreamsServiceBackpressureTest extends
RxJavaStreamsServiceTe
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)
@@ -120,7 +120,7 @@ public class RxJavaStreamsServiceBackpressureTest extends
RxJavaStreamsServiceTe
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-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceEventTypeTest.java
b/components/camel-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceEventTypeTest.java
index fcf446bbf8c..16dfa514b6a 100644
---
a/components/camel-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceEventTypeTest.java
+++
b/components/camel-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceEventTypeTest.java
@@ -32,7 +32,7 @@ public class RxJavaStreamsServiceEventTypeTest extends
RxJavaStreamsServiceTestS
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");
}
@@ -55,7 +55,7 @@ public class RxJavaStreamsServiceEventTypeTest extends
RxJavaStreamsServiceTestS
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");
}
@@ -76,7 +76,7 @@ public class RxJavaStreamsServiceEventTypeTest extends
RxJavaStreamsServiceTestS
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");
}
@@ -101,7 +101,7 @@ public class RxJavaStreamsServiceEventTypeTest extends
RxJavaStreamsServiceTestS
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");
}
@@ -135,7 +135,7 @@ public class RxJavaStreamsServiceEventTypeTest extends
RxJavaStreamsServiceTestS
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-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceSubscriberTest.java
b/components/camel-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceSubscriberTest.java
index f9e014fc039..a81c5f70e92 100644
---
a/components/camel-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceSubscriberTest.java
+++
b/components/camel-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceSubscriberTest.java
@@ -34,7 +34,7 @@ public class RxJavaStreamsServiceSubscriberTest extends
RxJavaStreamsServiceTest
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")
@@ -84,7 +84,7 @@ public class RxJavaStreamsServiceSubscriberTest extends
RxJavaStreamsServiceTest
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()))
@@ -120,7 +120,7 @@ public class RxJavaStreamsServiceSubscriberTest extends
RxJavaStreamsServiceTest
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-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceTest.java
b/components/camel-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceTest.java
index c5e8cecdc35..98ccf5af5be 100644
---
a/components/camel-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceTest.java
+++
b/components/camel-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceTest.java
@@ -79,7 +79,7 @@ public class RxJavaStreamsServiceTest extends
RxJavaStreamsServiceTestSupport {
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).to("reactive-streams:tick");
}
});
@@ -104,7 +104,7 @@ public class RxJavaStreamsServiceTest extends
RxJavaStreamsServiceTestSupport {
context.start();
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:reactive").to("reactive-streams:direct");
}
});
@@ -126,7 +126,7 @@ public class RxJavaStreamsServiceTest extends
RxJavaStreamsServiceTestSupport {
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");
}
});
@@ -185,7 +185,7 @@ public class RxJavaStreamsServiceTest extends
RxJavaStreamsServiceTestSupport {
context.start();
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:source").to("direct:stream").setBody().simple("after stream:
${body}");
}
});
@@ -207,7 +207,7 @@ public class RxJavaStreamsServiceTest extends
RxJavaStreamsServiceTestSupport {
context.start();
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:source").to("direct:stream").setBody().simple("after stream:
${body}");
}
});
@@ -310,7 +310,7 @@ public class RxJavaStreamsServiceTest extends
RxJavaStreamsServiceTestSupport {
context.start();
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:reactor").to("mock:result");
}
});
@@ -335,7 +335,7 @@ public class RxJavaStreamsServiceTest extends
RxJavaStreamsServiceTestSupport {
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").to("reactive-streams:stream");
}
diff --git
a/components/camel-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceTestSupport.java
b/components/camel-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceTestSupport.java
index 81d854972fe..28b25825075 100644
---
a/components/camel-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceTestSupport.java
+++
b/components/camel-rxjava/src/test/java/org/apache/camel/component/rxjava/engine/RxJavaStreamsServiceTestSupport.java
@@ -44,7 +44,7 @@ class RxJavaStreamsServiceTestSupport extends
CamelTestSupport {
}
@Override
- protected void doPostSetup() throws Exception {
+ protected void doPostSetup() {
this.crs = CamelReactiveStreams.get(context);
}
