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 17:51:10 UTC
[camel] 09/09: CAMEL-17763: cleaned up unused exceptions in camel-resilience4j
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 026a215a2bd972154cd5d6c9eab12db2da5be4ce
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Apr 12 18:22:36 2022 +0200
CAMEL-17763: cleaned up unused exceptions in camel-resilience4j
---
.../resilience4j/ResilienceExistingCircuitBreakerTest.java | 4 ++--
.../resilience4j/ResilienceInheritErrorHandlerTest.java | 4 ++--
.../camel/component/resilience4j/ResilienceManagementTest.java | 4 ++--
.../resilience4j/ResilienceRouteBulkheadFallbackTest.java | 4 ++--
.../component/resilience4j/ResilienceRouteBulkheadOkTest.java | 4 ++--
.../component/resilience4j/ResilienceRouteFallbackTest.java | 4 ++--
.../resilience4j/ResilienceRouteFallbackViaNetworkTest.java | 4 ++--
.../camel/component/resilience4j/ResilienceRouteOkTest.java | 4 ++--
.../component/resilience4j/ResilienceRouteRejectedTest.java | 4 ++--
.../camel/component/resilience4j/ResilienceTimeoutTest.java | 10 +++++-----
.../resilience4j/ResilienceTimeoutThreadPoolTest.java | 10 +++++-----
.../resilience4j/ResilienceTimeoutWithFallbackTest.java | 8 ++++----
12 files changed, 32 insertions(+), 32 deletions(-)
diff --git a/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceExistingCircuitBreakerTest.java b/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceExistingCircuitBreakerTest.java
index 14972f6906c..cd288644e60 100644
--- a/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceExistingCircuitBreakerTest.java
+++ b/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceExistingCircuitBreakerTest.java
@@ -60,10 +60,10 @@ public class ResilienceExistingCircuitBreakerTest 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:start").circuitBreaker().resilience4jConfiguration()
.circuitBreaker("myCircuitBreaker").end()
.throwException(new IllegalArgumentException("Forced")).onFallback().transform()
diff --git a/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceInheritErrorHandlerTest.java b/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceInheritErrorHandlerTest.java
index 5c97e918ccd..72e643ea9d2 100644
--- a/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceInheritErrorHandlerTest.java
+++ b/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceInheritErrorHandlerTest.java
@@ -43,10 +43,10 @@ public class ResilienceInheritErrorHandlerTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
errorHandler(deadLetterChannel("mock:dead").maximumRedeliveries(3).redeliveryDelay(0));
from("direct:start").to("log:start")
diff --git a/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceManagementTest.java b/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceManagementTest.java
index 51a33284859..4a5220bd51f 100644
--- a/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceManagementTest.java
+++ b/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceManagementTest.java
@@ -86,10 +86,10 @@ public class ResilienceManagementTest 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").routeId("start").circuitBreaker().id("myResilience").to("direct:foo").onFallback()
.transform().constant("Fallback message").end()
.to("mock:result");
diff --git a/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceRouteBulkheadFallbackTest.java b/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceRouteBulkheadFallbackTest.java
index e75abdb4c63..15246aaf5ca 100644
--- a/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceRouteBulkheadFallbackTest.java
+++ b/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceRouteBulkheadFallbackTest.java
@@ -44,10 +44,10 @@ public class ResilienceRouteBulkheadFallbackTest 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:start").circuitBreaker().resilience4jConfiguration().bulkheadEnabled(true).end()
.throwException(new IllegalArgumentException("Forced"))
.onFallback().transform().constant("Fallback message").end().to("log:result").to("mock:result");
diff --git a/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceRouteBulkheadOkTest.java b/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceRouteBulkheadOkTest.java
index 831e58f6125..01e10d6864e 100644
--- a/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceRouteBulkheadOkTest.java
+++ b/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceRouteBulkheadOkTest.java
@@ -44,10 +44,10 @@ public class ResilienceRouteBulkheadOkTest 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").circuitBreaker().resilience4jConfiguration().bulkheadEnabled(true).end().to("direct:foo")
.to("log:foo").onFallback().transform()
.constant("Fallback message").end().to("log:result").to("mock:result");
diff --git a/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceRouteFallbackTest.java b/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceRouteFallbackTest.java
index 9434fe3ff1c..ae4e0c991a2 100644
--- a/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceRouteFallbackTest.java
+++ b/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceRouteFallbackTest.java
@@ -46,10 +46,10 @@ public class ResilienceRouteFallbackTest 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:start").circuitBreaker().throwException(new IllegalArgumentException("Forced"))
.onFallback().transform().constant("Fallback message")
.end().to("log:result").to("mock:result");
diff --git a/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceRouteFallbackViaNetworkTest.java b/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceRouteFallbackViaNetworkTest.java
index e5260d7ffc9..a8aac3e5904 100644
--- a/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceRouteFallbackViaNetworkTest.java
+++ b/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceRouteFallbackViaNetworkTest.java
@@ -43,10 +43,10 @@ public class ResilienceRouteFallbackViaNetworkTest 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:start").circuitBreaker().throwException(new IllegalArgumentException("Forced"))
.onFallbackViaNetwork().transform()
.constant("Fallback message").end().to("log:result").to("mock:result");
diff --git a/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceRouteOkTest.java b/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceRouteOkTest.java
index 45a7ea7392b..b7a7e28cbbb 100644
--- a/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceRouteOkTest.java
+++ b/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceRouteOkTest.java
@@ -72,10 +72,10 @@ public class ResilienceRouteOkTest 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").circuitBreaker().to("direct:foo").to("log:foo").onFallback().transform()
.constant("Fallback message").end().to("log:result").to("mock:result");
diff --git a/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceRouteRejectedTest.java b/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceRouteRejectedTest.java
index d6e29c4e9a1..eb27a8ae1a8 100644
--- a/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceRouteRejectedTest.java
+++ b/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceRouteRejectedTest.java
@@ -71,10 +71,10 @@ public class ResilienceRouteRejectedTest 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").circuitBreaker().id("myResilience").to("direct:foo").to("log:foo").end().to("log:result")
.to("mock:result");
diff --git a/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceTimeoutTest.java b/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceTimeoutTest.java
index 8806ea2c365..e9742634940 100644
--- a/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceTimeoutTest.java
+++ b/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceTimeoutTest.java
@@ -38,14 +38,14 @@ public class ResilienceTimeoutTest extends CamelTestSupport {
protected Logger log = LoggerFactory.getLogger(getClass());
@Test
- public void testFast() throws Exception {
+ public void testFast() {
// this calls the fast route and therefore we get a response
Object out = template.requestBody("direct:start", "fast");
assertEquals("Fast response", out);
}
@Test
- public void testSlow() throws Exception {
+ public void testSlow() {
// this calls the slow route and therefore causes a timeout which
// triggers an exception
Exception exception = assertThrows(Exception.class,
@@ -56,7 +56,7 @@ public class ResilienceTimeoutTest extends CamelTestSupport {
@Test
@Disabled("manual testing")
- public void testSlowLoop() throws Exception {
+ public void testSlowLoop() {
// this calls the slow route and therefore causes a timeout which
// triggers an exception
for (int i = 0; i < 10; i++) {
@@ -69,10 +69,10 @@ public class ResilienceTimeoutTest extends CamelTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").circuitBreaker()
// enable and use 2 second timeout
.resilience4jConfiguration().timeoutEnabled(true).timeoutDuration(2000).end()
diff --git a/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceTimeoutThreadPoolTest.java b/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceTimeoutThreadPoolTest.java
index 6b02a409cec..781ab8acf69 100644
--- a/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceTimeoutThreadPoolTest.java
+++ b/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceTimeoutThreadPoolTest.java
@@ -49,7 +49,7 @@ public class ResilienceTimeoutThreadPoolTest extends CamelTestSupport {
}
@Test
- public void testFast() throws Exception {
+ public void testFast() {
// this calls the fast route and therefore we get a response
Object out = template.requestBody("direct:start", "fast");
assertEquals("Fast response", out);
@@ -63,7 +63,7 @@ public class ResilienceTimeoutThreadPoolTest extends CamelTestSupport {
}
@Test
- public void testSlow() throws Exception {
+ public void testSlow() {
// this calls the slow route and therefore causes a timeout which
// triggers an exception
Exception exception = assertThrows(Exception.class,
@@ -85,7 +85,7 @@ public class ResilienceTimeoutThreadPoolTest extends CamelTestSupport {
@Test
@Disabled("manual testing")
- public void testSlowLoop() throws Exception {
+ public void testSlowLoop() {
// this calls the slow route and therefore causes a timeout which
// triggers an exception
for (int i = 0; i < 10; i++) {
@@ -98,10 +98,10 @@ public class ResilienceTimeoutThreadPoolTest extends CamelTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").circuitBreaker()
// enable and use 2 second timeout
.resilience4jConfiguration().timeoutEnabled(true).timeoutDuration(2000)
diff --git a/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceTimeoutWithFallbackTest.java b/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceTimeoutWithFallbackTest.java
index bf83f4f76c3..0ed462c95d5 100644
--- a/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceTimeoutWithFallbackTest.java
+++ b/components/camel-resilience4j/src/test/java/org/apache/camel/component/resilience4j/ResilienceTimeoutWithFallbackTest.java
@@ -29,14 +29,14 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class ResilienceTimeoutWithFallbackTest extends CamelTestSupport {
@Test
- public void testFast() throws Exception {
+ public void testFast() {
// this calls the fast route and therefore we get a response
Object out = template.requestBody("direct:start", "fast");
assertEquals("LAST CHANGE", out);
}
@Test
- public void testSlow() throws Exception {
+ public void testSlow() {
// this calls the slow route and therefore causes a timeout which
// triggers the fallback
Object out = template.requestBody("direct:start", "slow");
@@ -44,10 +44,10 @@ public class ResilienceTimeoutWithFallbackTest extends CamelTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").circuitBreaker()
// enable and use 2 second timeout
.resilience4jConfiguration().timeoutEnabled(true).timeoutDuration(2000).end()