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/13 12:20:59 UTC
[camel] branch main updated: CAMEL-17763: cleaned up unused exceptions in camel-vertx
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
The following commit(s) were added to refs/heads/main by this push:
new ce355707222 CAMEL-17763: cleaned up unused exceptions in camel-vertx
ce355707222 is described below
commit ce35570722234f348b197aec5bf1240ff87e21f2
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Wed Apr 13 13:14:41 2022 +0200
CAMEL-17763: cleaned up unused exceptions in camel-vertx
---
.../component/vertx/http/VertxHttpAuthenticationTest.java | 4 ++--
.../component/vertx/http/VertxHttpCustomBindingTest.java | 12 +++++-------
.../vertx/http/VertxHttpCustomHeaderFilterTest.java | 4 ++--
.../camel/component/vertx/http/VertxHttpGzipTest.java | 8 ++++----
.../camel/component/vertx/http/VertxHttpMethodTest.java | 4 ++--
.../component/vertx/http/VertxHttpProducerLoadTest.java | 4 ++--
.../camel/component/vertx/http/VertxHttpProducerTest.java | 8 ++++----
.../component/vertx/http/VertxHttpProducerToDTest.java | 4 ++--
.../component/vertx/http/VertxHttpProxyServerTest.java | 4 ++--
.../component/vertx/http/VertxHttpQueryStringTest.java | 4 ++--
.../vertx/http/VertxHttpRequestWithPayloadTest.java | 6 +++---
.../vertx/http/VertxHttpSSLGlobalConfigurationTest.java | 8 ++++----
.../apache/camel/component/vertx/http/VertxHttpSSLTest.java | 8 ++++----
.../component/vertx/http/VertxHttpSendDynamicAwareTest.java | 6 +++---
.../component/vertx/http/VertxHttpSerializedBodyTest.java | 4 ++--
.../camel/component/vertx/http/VertxHttpSessionTest.java | 8 ++++----
.../vertx/http/VertxHttpStreamingResponseTest.java | 2 +-
.../vertx/http/VertxHttpThrowExceptionOnFailureTest.java | 6 +++---
.../camel/component/vertx/http/VertxHttpTimeoutTest.java | 4 ++--
.../vertx/http/VertxHttpTransferExceptionTest.java | 4 ++--
.../apache/camel/component/vertx/http/VertxHttpUriTest.java | 4 ++--
.../component/vertx/kafka/VertxKafkaComponentTest.java | 4 ++--
.../vertx/kafka/VertxKafkaConsumerBatchSizeTest.java | 4 ++--
.../component/vertx/kafka/VertxKafkaConsumerFullTest.java | 9 ++++-----
.../vertx/kafka/VertxKafkaConsumerManualCommitTest.java | 4 ++--
.../vertx/kafka/VertxKafkaConsumerSuspendResumeTest.java | 4 ++--
.../component/vertx/kafka/VertxKafkaProducerFullTest.java | 13 ++++++-------
.../camel/component/vertx/kafka/VertxKafkaToDTest.java | 6 +++---
.../websocket/VertxWebsocketEndpointConfigurationTest.java | 4 ++--
.../vertx/websocket/VertxWebsocketExternalServerTest.java | 4 ++--
.../vertx/websocket/VertxWebsocketMultiConsumerTest.java | 4 ++--
.../component/vertx/websocket/VertxWebsocketOriginTest.java | 4 ++--
.../component/vertx/websocket/VertxWebsocketRouterTest.java | 10 +++++-----
.../component/vertx/websocket/VertxWebsocketSSLTest.java | 6 +++---
.../camel/component/vertx/websocket/VertxWebsocketTest.java | 6 +++---
.../apache/camel/component/vertx/VertxBaseTestSupport.java | 2 +-
.../camel/component/vertx/VertxMultipleConsumerTest.java | 4 ++--
.../apache/camel/component/vertx/VertxRequestReplyTest.java | 4 ++--
.../apache/camel/component/vertx/VertxRoutePubSubTest.java | 4 ++--
.../org/apache/camel/component/vertx/VertxRouteTest.java | 4 ++--
40 files changed, 106 insertions(+), 110 deletions(-)
diff --git a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpAuthenticationTest.java b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpAuthenticationTest.java
index 6bc095ef575..3b35d4b2d57 100644
--- a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpAuthenticationTest.java
+++ b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpAuthenticationTest.java
@@ -39,10 +39,10 @@ public class VertxHttpAuthenticationTest extends VertxHttpTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(getTestServerUri() + "/basic")
.process(exchange -> {
// Decode the username & password from the Authorization header
diff --git a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpCustomBindingTest.java b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpCustomBindingTest.java
index 43c62bdba84..8fc483b48a6 100644
--- a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpCustomBindingTest.java
+++ b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpCustomBindingTest.java
@@ -46,7 +46,7 @@ public class VertxHttpCustomBindingTest extends VertxHttpTestSupport {
VertxHttpComponent component = new VertxHttpComponent();
component.setVertxHttpBinding(new VertxHttpBinding() {
@Override
- public HttpRequest<Buffer> prepareHttpRequest(VertxHttpEndpoint endpoint, Exchange exchange) throws Exception {
+ public HttpRequest<Buffer> prepareHttpRequest(VertxHttpEndpoint endpoint, Exchange exchange) {
VertxHttpConfiguration configuration = endpoint.getConfiguration();
URI httpURI = configuration.getHttpUri();
WebClient webClient = endpoint.getWebClient();
@@ -66,14 +66,12 @@ public class VertxHttpCustomBindingTest extends VertxHttpTestSupport {
@Override
public Object processResponseBody(
- VertxHttpEndpoint endpoint, Exchange exchange, HttpResponse<Buffer> result, boolean exceptionOnly)
- throws Exception {
+ VertxHttpEndpoint endpoint, Exchange exchange, HttpResponse<Buffer> result, boolean exceptionOnly) {
return null;
}
@Override
- public Throwable handleResponseFailure(VertxHttpEndpoint endpoint, Exchange exchange, HttpResponse<Buffer> result)
- throws Exception {
+ public Throwable handleResponseFailure(VertxHttpEndpoint endpoint, Exchange exchange, HttpResponse<Buffer> result) {
return null;
}
@@ -93,10 +91,10 @@ public class VertxHttpCustomBindingTest extends VertxHttpTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(getTestServerUri() + "/overridden")
.setBody(constant("Hello World"));
}
diff --git a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpCustomHeaderFilterTest.java b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpCustomHeaderFilterTest.java
index 0bb39f29a58..a5c024bd2dc 100644
--- a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpCustomHeaderFilterTest.java
+++ b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpCustomHeaderFilterTest.java
@@ -37,10 +37,10 @@ public class VertxHttpCustomHeaderFilterTest extends VertxHttpTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(getTestServerUri())
.setBody(constant("Hello World"));
}
diff --git a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpGzipTest.java b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpGzipTest.java
index 044419a18ac..a0949042687 100644
--- a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpGzipTest.java
+++ b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpGzipTest.java
@@ -35,7 +35,7 @@ public class VertxHttpGzipTest extends VertxHttpTestSupport {
private volatile String message;
@Test
- public void testCompressedResponse() throws InterruptedException {
+ public void testCompressedResponse() {
// Invoke the endpoint without compression support to get the raw gzipped response
String result = template.requestBodyAndHeader(getProducerUri(), null, "Accept-Encoding", "gzip,deflate", String.class);
// Result is compressed so the length should be less than the original message
@@ -49,10 +49,10 @@ public class VertxHttpGzipTest extends VertxHttpTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
getContext().getRegistry().bind("gzip", createGzipHandler());
from(getTestServerUri() + "?handlers=gzip")
@@ -73,7 +73,7 @@ public class VertxHttpGzipTest extends VertxHttpTestSupport {
.addEncodingHandler("gzip", new GzipEncodingProvider(), 50, Predicates.parse("max-content-size[5]")))
.setNext(new HttpHandler() {
@Override
- public void handleRequest(final HttpServerExchange exchange) throws Exception {
+ public void handleRequest(final HttpServerExchange exchange) {
exchange.getResponseHeaders().put(Headers.CONTENT_LENGTH, message.length() + "");
exchange.getResponseSender().send(message, IoCallback.END_EXCHANGE);
}
diff --git a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpMethodTest.java b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpMethodTest.java
index 35728c6932e..b2e5f6ad396 100644
--- a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpMethodTest.java
+++ b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpMethodTest.java
@@ -84,10 +84,10 @@ public class VertxHttpMethodTest extends VertxHttpTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(getTestServerUri())
.setBody(header(Exchange.HTTP_METHOD));
}
diff --git a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpProducerLoadTest.java b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpProducerLoadTest.java
index 18701e135d3..20ce9cd2b8f 100644
--- a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpProducerLoadTest.java
+++ b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpProducerLoadTest.java
@@ -36,10 +36,10 @@ public class VertxHttpProducerLoadTest extends VertxHttpTestSupport {
private static final Logger LOG = LoggerFactory.getLogger(VertxHttpProducerLoadTest.class);
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:echo")
.to(getProducerUri());
diff --git a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpProducerTest.java b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpProducerTest.java
index 9e3f4065e90..60c5741aaa9 100644
--- a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpProducerTest.java
+++ b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpProducerTest.java
@@ -54,7 +54,7 @@ public class VertxHttpProducerTest extends VertxHttpTestSupport {
Exchange exchange = template.request(getProducerUri() + "/content/type", new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getMessage().setHeader(Exchange.CONTENT_TYPE, "application/json; charset=iso-8859-4");
}
});
@@ -71,17 +71,17 @@ public class VertxHttpProducerTest extends VertxHttpTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(getTestServerUri())
.setBody(constant("Hello World"));
from(getTestServerUri() + "/content/type")
.process(new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
String contentType = ExchangeHelper.getContentType(exchange);
if (!contentType.startsWith("application/json")) {
throw new IllegalStateException("Unexpected Content-Type header");
diff --git a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpProducerToDTest.java b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpProducerToDTest.java
index 6e4feb95eda..9f1c95f2490 100644
--- a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpProducerToDTest.java
+++ b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpProducerToDTest.java
@@ -66,10 +66,10 @@ public class VertxHttpProducerToDTest extends VertxHttpTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:static")
.toD(getProducerUri() + "/hello");
diff --git a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpProxyServerTest.java b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpProxyServerTest.java
index 2feddb1c595..30e7f9d3c9a 100644
--- a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpProxyServerTest.java
+++ b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpProxyServerTest.java
@@ -57,10 +57,10 @@ public class VertxHttpProxyServerTest extends VertxHttpTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(getTestServerUri())
.setBody(constant("Hello Proxied World"));
diff --git a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpQueryStringTest.java b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpQueryStringTest.java
index 887241fa2b8..d1cd764a29f 100644
--- a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpQueryStringTest.java
+++ b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpQueryStringTest.java
@@ -56,10 +56,10 @@ public class VertxHttpQueryStringTest extends VertxHttpTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(getTestServerUri())
.setBody(header(Exchange.HTTP_QUERY));
diff --git a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpRequestWithPayloadTest.java b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpRequestWithPayloadTest.java
index 67561f7ddde..97fc2896a25 100644
--- a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpRequestWithPayloadTest.java
+++ b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpRequestWithPayloadTest.java
@@ -142,10 +142,10 @@ public class VertxHttpRequestWithPayloadTest extends VertxHttpTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(getTestServerUri())
.choice()
.when(simple("${body} == ''"))
@@ -156,7 +156,7 @@ public class VertxHttpRequestWithPayloadTest extends VertxHttpTestSupport {
from(getTestServerUri() + "/form")
.process(new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.toString();
}
})
diff --git a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpSSLGlobalConfigurationTest.java b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpSSLGlobalConfigurationTest.java
index be24fde4dea..3c627a06be9 100644
--- a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpSSLGlobalConfigurationTest.java
+++ b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpSSLGlobalConfigurationTest.java
@@ -31,7 +31,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class VertxHttpSSLGlobalConfigurationTest extends VertxHttpTestSupport {
@Test
- public void testGlobalSSLContextParameters() throws Exception {
+ public void testGlobalSSLContextParameters() {
String result = template.requestBody(getProducerUri(), null, String.class);
assertEquals("Hello World", result);
}
@@ -67,10 +67,10 @@ public class VertxHttpSSLGlobalConfigurationTest extends VertxHttpTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(getTestServerUri() + "?sslContextParameters=#serverSSLParameters")
.setBody(constant("Hello World"));
}
@@ -78,7 +78,7 @@ public class VertxHttpSSLGlobalConfigurationTest extends VertxHttpTestSupport {
}
@Override
- protected void bindToRegistry(Registry registry) throws Exception {
+ protected void bindToRegistry(Registry registry) {
SSLContextParameters serverSSLParameters = new SSLContextParameters();
KeyStoreParameters keystoreParameters = new KeyStoreParameters();
diff --git a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpSSLTest.java b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpSSLTest.java
index 81a94148fa1..fc39142916f 100644
--- a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpSSLTest.java
+++ b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpSSLTest.java
@@ -31,17 +31,17 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class VertxHttpSSLTest extends VertxHttpTestSupport {
@Test
- public void testSSLContextParametersFromRegistry() throws Exception {
+ public void testSSLContextParametersFromRegistry() {
String result
= template.requestBody(getProducerUri() + "?sslContextParameters=#clientSSLParameters", null, String.class);
assertEquals("Hello World", result);
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(getTestServerUri() + "?sslContextParameters=#serverSSLParameters")
.setBody(constant("Hello World"));
}
@@ -49,7 +49,7 @@ public class VertxHttpSSLTest extends VertxHttpTestSupport {
}
@Override
- protected void bindToRegistry(Registry registry) throws Exception {
+ protected void bindToRegistry(Registry registry) {
SSLContextParameters serverSSLParameters = new SSLContextParameters();
SSLContextParameters clientSSLParameters = new SSLContextParameters();
diff --git a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpSendDynamicAwareTest.java b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpSendDynamicAwareTest.java
index a040d98004a..065425d159b 100644
--- a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpSendDynamicAwareTest.java
+++ b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpSendDynamicAwareTest.java
@@ -26,7 +26,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
public class VertxHttpSendDynamicAwareTest extends VertxHttpTestSupport {
@Test
- public void testDynamicAware() throws Exception {
+ public void testDynamicAware() {
String out = fluentTemplate.to("direct:moes").withHeader("drink", "beer").request(String.class);
assertEquals("Drinking beer", out);
@@ -43,10 +43,10 @@ public class VertxHttpSendDynamicAwareTest extends VertxHttpTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:moes")
.toD("vertx-http:http://localhost:" + getPort()
+ "/moes?throwExceptionOnFailure=false&drink=${header.drink}");
diff --git a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpSerializedBodyTest.java b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpSerializedBodyTest.java
index ba1a9553647..1ec3f621e03 100644
--- a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpSerializedBodyTest.java
+++ b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpSerializedBodyTest.java
@@ -104,10 +104,10 @@ public class VertxHttpSerializedBodyTest extends VertxHttpTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(getTestServerUri() + "/serialized")
.process(new Processor() {
@Override
diff --git a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpSessionTest.java b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpSessionTest.java
index c930523c307..eb46b1b5650 100644
--- a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpSessionTest.java
+++ b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpSessionTest.java
@@ -76,15 +76,15 @@ public class VertxHttpSessionTest extends VertxHttpTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// Simulate session handling for an application with a 'secured' endpoint
from(getTestServerUri() + "/secure")
.process(new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
Message message = exchange.getMessage();
String cookie = message.getHeader("Cookie", String.class);
if (cookie != null && cookie.equals("sessionId=" + SESSION_ID)) {
@@ -98,7 +98,7 @@ public class VertxHttpSessionTest extends VertxHttpTestSupport {
from(getTestServerUri() + "/login")
.process(new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
Message message = exchange.getMessage();
String username = message.getHeader("username", String.class);
String password = message.getHeader("password", String.class);
diff --git a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpStreamingResponseTest.java b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpStreamingResponseTest.java
index 993bd2ba5f2..d187b096d63 100644
--- a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpStreamingResponseTest.java
+++ b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpStreamingResponseTest.java
@@ -62,7 +62,7 @@ public class VertxHttpStreamingResponseTest extends VertxHttpTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
diff --git a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpThrowExceptionOnFailureTest.java b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpThrowExceptionOnFailureTest.java
index 562232d35a0..6851c33d0a9 100644
--- a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpThrowExceptionOnFailureTest.java
+++ b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpThrowExceptionOnFailureTest.java
@@ -92,7 +92,7 @@ public class VertxHttpThrowExceptionOnFailureTest extends VertxHttpTestSupport {
public void testThrowExceptionOnFailureWithOverriddenUri() {
Exchange exchange = template.request(getProducerUri(), new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
exchange.getMessage().setHeader(Exchange.HTTP_URI, getTestServerUrl() + "/redirect");
}
});
@@ -115,10 +115,10 @@ public class VertxHttpThrowExceptionOnFailureTest extends VertxHttpTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(getTestServerUri())
.throwException(new Exception("Forced"));
diff --git a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpTimeoutTest.java b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpTimeoutTest.java
index 43f49e16fc4..243808facf8 100644
--- a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpTimeoutTest.java
+++ b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpTimeoutTest.java
@@ -39,10 +39,10 @@ public class VertxHttpTimeoutTest extends VertxHttpTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(getTestServerUri())
.delay(50)
.setBody(constant("Hello World"));
diff --git a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpTransferExceptionTest.java b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpTransferExceptionTest.java
index a9681c4a524..4f839ca939b 100644
--- a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpTransferExceptionTest.java
+++ b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpTransferExceptionTest.java
@@ -39,10 +39,10 @@ public class VertxHttpTransferExceptionTest extends VertxHttpTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(getTestServerUri() + "?transferException=true")
.throwException(new IllegalStateException("Forced Exception"));
}
diff --git a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpUriTest.java b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpUriTest.java
index 36a02e1f365..2b2cdf85f29 100644
--- a/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpUriTest.java
+++ b/components/camel-vertx/camel-vertx-http/src/test/java/org/apache/camel/component/vertx/http/VertxHttpUriTest.java
@@ -42,10 +42,10 @@ public class VertxHttpUriTest extends VertxHttpTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(getTestServerUri())
.setBody(constant("Hello World"));
diff --git a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaComponentTest.java b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaComponentTest.java
index 260735c3d77..a7d81e726a4 100644
--- a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaComponentTest.java
+++ b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaComponentTest.java
@@ -35,7 +35,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
class VertxKafkaComponentTest extends CamelTestSupport {
@Test
- void testPropertiesSet() throws Exception {
+ void testPropertiesSet() {
String uri = "vertx-kafka:mytopic?bootstrapServers=broker1:12345,broker2:12566&partitionerClass=com.class.Party";
VertxKafkaEndpoint endpoint = context.getEndpoint(uri, VertxKafkaEndpoint.class);
@@ -45,7 +45,7 @@ class VertxKafkaComponentTest extends CamelTestSupport {
}
@Test
- void testBrokersOnComponent() throws Exception {
+ void testBrokersOnComponent() {
VertxKafkaComponent kafka = context.getComponent("vertx-kafka", VertxKafkaComponent.class);
kafka.getConfiguration().setBootstrapServers("broker1:12345,broker2:12566");
diff --git a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaConsumerBatchSizeTest.java b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaConsumerBatchSizeTest.java
index cdcd2ba7895..2a7b3e96667 100644
--- a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaConsumerBatchSizeTest.java
+++ b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaConsumerBatchSizeTest.java
@@ -56,10 +56,10 @@ public class VertxKafkaConsumerBatchSizeTest extends BaseEmbeddedKafkaTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(from).routeId("foo").to(to).setId("First");
}
};
diff --git a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaConsumerFullTest.java b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaConsumerFullTest.java
index 7add12df242..686d365946e 100644
--- a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaConsumerFullTest.java
+++ b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaConsumerFullTest.java
@@ -16,7 +16,6 @@
*/
package org.apache.camel.component.vertx.kafka;
-import java.io.IOException;
import java.util.Collections;
import java.util.Map;
import java.util.Properties;
@@ -68,18 +67,18 @@ public class VertxKafkaConsumerFullTest extends BaseEmbeddedKafkaTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(from).routeId("foo").to(to);
}
};
}
@Test
- public void kafkaMessageIsConsumedByCamel() throws InterruptedException, IOException {
+ public void kafkaMessageIsConsumedByCamel() throws InterruptedException {
String propagatedHeaderKey = "PropagatedCustomHeader";
byte[] propagatedHeaderValue = "propagated header value".getBytes();
String skippedHeaderKey = "CamelSkippedHeader";
@@ -103,7 +102,7 @@ public class VertxKafkaConsumerFullTest extends BaseEmbeddedKafkaTest {
}
@Test
- public void kafkaRecordSpecificHeadersAreNotOverwritten() throws InterruptedException, IOException {
+ public void kafkaRecordSpecificHeadersAreNotOverwritten() throws InterruptedException {
String propagatedHeaderKey = VertxKafkaConstants.TOPIC;
byte[] propagatedHeaderValue = "propagated incorrect topic".getBytes();
to.expectedHeaderReceived(VertxKafkaConstants.TOPIC, TOPIC);
diff --git a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaConsumerManualCommitTest.java b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaConsumerManualCommitTest.java
index 04695d20cdb..9ba8af722dd 100644
--- a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaConsumerManualCommitTest.java
+++ b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaConsumerManualCommitTest.java
@@ -61,11 +61,11 @@ public class VertxKafkaConsumerManualCommitTest extends BaseEmbeddedKafkaTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(from).routeId("foo").to(to).process(e -> {
VertxKafkaManualCommit manual
= e.getIn().getHeader(VertxKafkaConstants.MANUAL_COMMIT, VertxKafkaManualCommit.class);
diff --git a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaConsumerSuspendResumeTest.java b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaConsumerSuspendResumeTest.java
index 42358fa069a..e22f989a737 100644
--- a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaConsumerSuspendResumeTest.java
+++ b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaConsumerSuspendResumeTest.java
@@ -60,11 +60,11 @@ public class VertxKafkaConsumerSuspendResumeTest extends BaseEmbeddedKafkaTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(from).routeId("foo").to(to);
}
};
diff --git a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaProducerFullTest.java b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaProducerFullTest.java
index 765258d0ca2..7adcfc51b40 100644
--- a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaProducerFullTest.java
+++ b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaProducerFullTest.java
@@ -16,7 +16,6 @@
*/
package org.apache.camel.component.vertx.kafka;
-import java.io.IOException;
import java.nio.ByteBuffer;
import java.time.Duration;
import java.util.ArrayList;
@@ -122,10 +121,10 @@ public class VertxKafkaProducerFullTest extends BaseEmbeddedKafkaTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:startStrings").to(toStrings).to(mockEndpoint);
from("direct:startStrings2").to(toStrings2).to(mockEndpoint);
@@ -140,7 +139,7 @@ public class VertxKafkaProducerFullTest extends BaseEmbeddedKafkaTest {
}
@Test
- public void producedStringMessageIsReceivedByKafka() throws InterruptedException, IOException {
+ public void producedStringMessageIsReceivedByKafka() throws InterruptedException {
int messageInTopic = 10;
int messageInOtherTopic = 5;
@@ -170,7 +169,7 @@ public class VertxKafkaProducerFullTest extends BaseEmbeddedKafkaTest {
}
@Test
- public void producedString2MessageIsReceivedByKafka() throws InterruptedException, IOException {
+ public void producedString2MessageIsReceivedByKafka() throws InterruptedException {
int messageInTopic = 10;
int messageInOtherTopic = 5;
@@ -200,7 +199,7 @@ public class VertxKafkaProducerFullTest extends BaseEmbeddedKafkaTest {
}
@Test
- public void producedStringCollectionMessageIsReceivedByKafka() throws InterruptedException, IOException {
+ public void producedStringCollectionMessageIsReceivedByKafka() throws InterruptedException {
int messageInTopic = 10;
int messageInOtherTopic = 5;
@@ -244,7 +243,7 @@ public class VertxKafkaProducerFullTest extends BaseEmbeddedKafkaTest {
}
@Test
- public void producedBytesMessageIsReceivedByKafka() throws InterruptedException, IOException {
+ public void producedBytesMessageIsReceivedByKafka() throws InterruptedException {
int messageInTopic = 10;
int messageInOtherTopic = 5;
diff --git a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaToDTest.java b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaToDTest.java
index 970a8684faa..1ecb464b8fb 100644
--- a/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaToDTest.java
+++ b/components/camel-vertx/camel-vertx-kafka/camel-vertx-kafka-component/src/test/java/org/apache/camel/component/vertx/kafka/VertxKafkaToDTest.java
@@ -24,7 +24,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class VertxKafkaToDTest extends BaseEmbeddedKafkaTest {
@Test
- public void testToD() throws Exception {
+ public void testToD() {
template.sendBodyAndHeader("direct:start", "Hello bar", "where", "bar");
template.sendBodyAndHeader("direct:start", "Hello beer", "where", "beer");
@@ -34,10 +34,10 @@ public class VertxKafkaToDTest extends BaseEmbeddedKafkaTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// route message dynamic using toD
from("direct:start").toD("vertx-kafka:${header.where}");
}
diff --git a/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketEndpointConfigurationTest.java b/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketEndpointConfigurationTest.java
index 39f7e9494dd..1abfd6d3c71 100644
--- a/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketEndpointConfigurationTest.java
+++ b/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketEndpointConfigurationTest.java
@@ -66,10 +66,10 @@ public class VertxWebsocketEndpointConfigurationTest extends VertxWebSocketTestS
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("vertx-websocket:///default/configuration")
.to("mock:defaultConfiguration");
}
diff --git a/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketExternalServerTest.java b/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketExternalServerTest.java
index 196bd129c14..b1d6dc653ff 100644
--- a/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketExternalServerTest.java
+++ b/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketExternalServerTest.java
@@ -104,7 +104,7 @@ public class VertxWebsocketExternalServerTest extends VertxWebSocketTestSupport
CamelContext context = new DefaultCamelContext();
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.toD("vertx-websocket:localhost:${header.port}/ws?clientSubProtocols=foo,bar,cheese");
@@ -131,6 +131,6 @@ public class VertxWebsocketExternalServerTest extends VertxWebSocketTestSupport
}
@Override
- protected void startCamelContext() throws Exception {
+ protected void startCamelContext() {
}
}
diff --git a/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketMultiConsumerTest.java b/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketMultiConsumerTest.java
index 86730e13c7a..77563066829 100644
--- a/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketMultiConsumerTest.java
+++ b/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketMultiConsumerTest.java
@@ -38,10 +38,10 @@ public class VertxWebsocketMultiConsumerTest extends VertxWebSocketTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
fromF("vertx-websocket:localhost:%d/test/a", port)
.setBody(simple("Hello ${body}"))
.to("mock:result");
diff --git a/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketOriginTest.java b/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketOriginTest.java
index ae3153a4049..7379b42febe 100644
--- a/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketOriginTest.java
+++ b/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketOriginTest.java
@@ -65,10 +65,10 @@ public class VertxWebsocketOriginTest extends VertxWebSocketTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
fromF("vertx-websocket:localhost:%d/test?allowedOriginPattern=.*localhost.*", port)
.setBody(simple("Hello ${body}"))
.to("mock:result");
diff --git a/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketRouterTest.java b/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketRouterTest.java
index 720ea6db11e..b6c04ebadb0 100644
--- a/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketRouterTest.java
+++ b/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketRouterTest.java
@@ -39,7 +39,7 @@ public class VertxWebsocketRouterTest extends VertxWebSocketTestSupport {
CamelContext context = new DefaultCamelContext();
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
fromF("vertx-websocket:localhost:%d/test?router=#customRouter", port)
.to("mock:result");
}
@@ -80,7 +80,7 @@ public class VertxWebsocketRouterTest extends VertxWebSocketTestSupport {
context.addComponent("vertx-websocket", component);
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
fromF("vertx-websocket:localhost:%d/test", port)
.to("mock:result");
}
@@ -117,7 +117,7 @@ public class VertxWebsocketRouterTest extends VertxWebSocketTestSupport {
context.addComponent("vertx-websocket", component);
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
fromF("vertx-websocket:localhost:%d/test?router=#customRouter", port)
.to("mock:result");
}
@@ -157,7 +157,7 @@ public class VertxWebsocketRouterTest extends VertxWebSocketTestSupport {
CamelContext context = new DefaultCamelContext();
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
fromF("vertx-websocket:localhost:%d/test", port)
.to("mock:result");
}
@@ -187,6 +187,6 @@ public class VertxWebsocketRouterTest extends VertxWebSocketTestSupport {
}
@Override
- protected void startCamelContext() throws Exception {
+ protected void startCamelContext() {
}
}
diff --git a/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketSSLTest.java b/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketSSLTest.java
index 9aa919c3099..35813fc4b67 100644
--- a/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketSSLTest.java
+++ b/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketSSLTest.java
@@ -75,7 +75,7 @@ public class VertxWebsocketSSLTest extends VertxWebSocketTestSupport {
CamelContext context = new DefaultCamelContext();
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.toF("vertx-websocket:localhost:%d/echo?sslContextParameters=#clientSSLParameters", port);
@@ -107,7 +107,7 @@ public class VertxWebsocketSSLTest extends VertxWebSocketTestSupport {
CamelContext context = new DefaultCamelContext();
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.toF("vertx-websocket:localhost:%d/echo?sslContextParameters=#clientSSLParameters", port);
@@ -138,6 +138,6 @@ public class VertxWebsocketSSLTest extends VertxWebSocketTestSupport {
}
@Override
- protected void startCamelContext() throws Exception {
+ protected void startCamelContext() {
}
}
diff --git a/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketTest.java b/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketTest.java
index 589795825e9..07692527a3e 100644
--- a/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketTest.java
+++ b/components/camel-vertx/camel-vertx-websocket/src/test/java/org/apache/camel/component/vertx/websocket/VertxWebsocketTest.java
@@ -268,10 +268,10 @@ public class VertxWebsocketTest extends VertxWebSocketTestSupport {
}
@Override
- protected RoutesBuilder createRouteBuilder() throws Exception {
+ protected RoutesBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.toF("vertx-websocket:localhost:%d/test", port);
@@ -286,7 +286,7 @@ public class VertxWebsocketTest extends VertxWebSocketTestSupport {
.setBody(simple("Hello ${body}"))
.process(new Processor() {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
int serverPort = getVertxServerRandomPort();
exchange.getMessage().setHeader("port", serverPort);
}
diff --git a/components/camel-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxBaseTestSupport.java b/components/camel-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxBaseTestSupport.java
index 571232d85fb..99f26bf7351 100644
--- a/components/camel-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxBaseTestSupport.java
+++ b/components/camel-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxBaseTestSupport.java
@@ -29,7 +29,7 @@ public class VertxBaseTestSupport extends CamelTestSupport {
protected final Logger log = LoggerFactory.getLogger(getClass());
@BeforeAll
- public static void initPort() throws Exception {
+ public static void initPort() {
port = AvailablePortFinder.getNextAvailable();
}
diff --git a/components/camel-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxMultipleConsumerTest.java b/components/camel-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxMultipleConsumerTest.java
index 2832e40ec3a..a69b845f16f 100644
--- a/components/camel-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxMultipleConsumerTest.java
+++ b/components/camel-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxMultipleConsumerTest.java
@@ -38,9 +38,9 @@ public class VertxMultipleConsumerTest extends VertxBaseTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(startUri).to(resultUri);
from(startUri).to(resultUri);
}
diff --git a/components/camel-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxRequestReplyTest.java b/components/camel-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxRequestReplyTest.java
index f2223da7b01..37aea2453aa 100644
--- a/components/camel-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxRequestReplyTest.java
+++ b/components/camel-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxRequestReplyTest.java
@@ -47,9 +47,9 @@ public class VertxRequestReplyTest extends VertxBaseTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(startUri).to(middleUri).to(resultUri);
from(middleUri)
diff --git a/components/camel-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxRoutePubSubTest.java b/components/camel-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxRoutePubSubTest.java
index 16b1e0c64d2..aec7a5157e2 100644
--- a/components/camel-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxRoutePubSubTest.java
+++ b/components/camel-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxRoutePubSubTest.java
@@ -50,9 +50,9 @@ public class VertxRoutePubSubTest extends VertxBaseTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(startUri).to(middleUri);
from(middleUri).to(resultUri);
}
diff --git a/components/camel-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxRouteTest.java b/components/camel-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxRouteTest.java
index e537a79286d..646666ecd44 100644
--- a/components/camel-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxRouteTest.java
+++ b/components/camel-vertx/camel-vertx/src/test/java/org/apache/camel/component/vertx/VertxRouteTest.java
@@ -50,9 +50,9 @@ public class VertxRouteTest extends VertxBaseTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(startUri).to(middleUri);
from(middleUri).to(resultUri);
}