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 a27765e8094c7f3dea240a92ad11d1f0a2e11bf7
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Tue Apr 12 17:20:33 2022 +0200
CAMEL-17763: cleaned up unused exceptions in camel-mina
---
.../org/apache/camel/component/mina/BaseMinaTest.java | 2 +-
.../camel/component/mina/MessageIOSessionTest.java | 4 ++--
.../mina/MinaClientModeTcpTextlineDelimiterTest.java | 4 ++--
.../camel/component/mina/MinaClientServerTest.java | 8 ++++----
.../apache/camel/component/mina/MinaConsumerTest.java | 8 ++++----
.../camel/component/mina/MinaCustomCodecTest.java | 12 ++++++------
.../mina/MinaDisconnectRaceConditionTest.java | 4 ++--
.../camel/component/mina/MinaDisconnectTest.java | 8 ++++----
.../apache/camel/component/mina/MinaEncodingTest.java | 2 +-
.../apache/camel/component/mina/MinaFiltersTest.java | 6 +++---
.../camel/component/mina/MinaInOnlyRouteTest.java | 4 ++--
.../mina/MinaInOutCloseSessionWhenCompleteTest.java | 6 +++---
.../camel/component/mina/MinaInOutRouteTest.java | 4 ++--
.../mina/MinaInOutRouteTextLineDelimiterTest.java | 4 ++--
.../mina/MinaInOutWithForcedNoResponseTest.java | 6 +++---
.../camel/component/mina/MinaMaxLineLengthTest.java | 6 +++---
.../camel/component/mina/MinaNoDefaultCodecTest.java | 2 +-
.../component/mina/MinaNoResponseFromServerTest.java | 18 +++++++++---------
.../mina/MinaProducerAnotherConcurrentTest.java | 8 ++++----
.../component/mina/MinaProducerConcurrentTest.java | 6 +++---
.../camel/component/mina/MinaReverserServer.java | 2 +-
.../camel/component/mina/MinaSendToProcessorTest.java | 4 ++--
.../camel/component/mina/MinaTcpWithInOutTest.java | 4 ++--
.../component/mina/MinaTransferExchangeOptionTest.java | 2 +-
.../camel/component/mina/MinaUdpNoCamelTest.java | 10 +++++-----
.../camel/component/mina/MinaUdpUsingTemplateTest.java | 2 +-
.../camel/component/mina/MinaVMCustomCodecTest.java | 10 +++++-----
27 files changed, 78 insertions(+), 78 deletions(-)
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/BaseMinaTest.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/BaseMinaTest.java
index e8ea673cff7..12992520881 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/BaseMinaTest.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/BaseMinaTest.java
@@ -37,7 +37,7 @@ public abstract class BaseMinaTest extends CamelTestSupport {
private static volatile int port;
@BeforeAll
- public static void initPort() throws Exception {
+ public static void initPort() {
port = AvailablePortFinder.getNextAvailable();
}
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MessageIOSessionTest.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MessageIOSessionTest.java
index e26e5178aae..50f1b3a44a8 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MessageIOSessionTest.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MessageIOSessionTest.java
@@ -59,11 +59,11 @@ public class MessageIOSessionTest extends BaseMinaTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(String.format("mina:tcp://localhost:%1$s?textline=true",
getPort()))
.to("log://mytest")
.to("mock:result");
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaClientModeTcpTextlineDelimiterTest.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaClientModeTcpTextlineDelimiterTest.java
index 779c7ed4ddd..3eca02f27ae 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaClientModeTcpTextlineDelimiterTest.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaClientModeTcpTextlineDelimiterTest.java
@@ -79,7 +79,7 @@ public class MinaClientModeTcpTextlineDelimiterTest extends
BaseMinaTest {
acceptor.bind(new InetSocketAddress("127.0.0.1", port));
}
- public void shutdown() throws Exception {
+ public void shutdown() {
acceptor.unbind();
acceptor.dispose();
}
@@ -87,7 +87,7 @@ public class MinaClientModeTcpTextlineDelimiterTest extends
BaseMinaTest {
private class ServerHandler extends IoHandlerAdapter {
@Override
- public void sessionOpened(IoSession session) throws Exception {
+ public void sessionOpened(IoSession session) {
session.write("Hello there!\n");
session.closeNow();
}
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaClientServerTest.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaClientServerTest.java
index e875ee10e7d..82d73a39115 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaClientServerTest.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaClientServerTest.java
@@ -26,7 +26,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class MinaClientServerTest extends BaseMinaTest {
@Test
- public void testSendToServer() throws InterruptedException {
+ public void testSendToServer() {
// START SNIPPET: e3
String out = (String)
template.requestBody(String.format("mina:tcp://localhost:%1$s?textline=true",
getPort()), "Chad");
assertEquals("Hello Chad", out);
@@ -34,11 +34,11 @@ public class MinaClientServerTest extends BaseMinaTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// START SNIPPET: e1
// lets setup a server on port %1$s
// and we let the request-reply be processed in the
MyServerProcessor
@@ -52,7 +52,7 @@ public class MinaClientServerTest extends BaseMinaTest {
private static class MyServerProcessor implements Processor {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
// get the input from the IN body
String name = exchange.getIn().getBody(String.class);
// send back a response on the OUT body
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaConsumerTest.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaConsumerTest.java
index 56c991178df..eaaf1928cf6 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaConsumerTest.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaConsumerTest.java
@@ -45,7 +45,7 @@ public class MinaConsumerTest extends BaseMinaTest {
}
@Test
- public void testSendTextlineSyncText() throws Exception {
+ public void testSendTextlineSyncText() {
// START SNIPPET: e4
String response = (String)
template.requestBody("mina:tcp://localhost:" + port2 +
"?textline=true&sync=true", "World");
assertEquals("Bye World", response);
@@ -53,10 +53,10 @@ public class MinaConsumerTest extends BaseMinaTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
port1 = getPort();
port2 = getNextPort();
@@ -67,7 +67,7 @@ public class MinaConsumerTest extends BaseMinaTest {
// START SNIPPET: e3
from("mina:tcp://localhost:" + port2 +
"?textline=true&sync=true").process(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
String body = exchange.getIn().getBody(String.class);
exchange.getMessage().setBody("Bye " + body);
}
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaCustomCodecTest.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaCustomCodecTest.java
index 41bfa455504..20dfcca9c86 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaCustomCodecTest.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaCustomCodecTest.java
@@ -62,7 +62,7 @@ public class MinaCustomCodecTest extends BaseMinaTest {
}
@Test
- public void testProducerFailInDecodingResponse() throws Exception {
+ public void testProducerFailInDecodingResponse() {
MockEndpoint mock = getMockEndpoint("mock:result");
mock.expectedMessageCount(1);
@@ -115,11 +115,11 @@ public class MinaCustomCodecTest extends BaseMinaTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from(String.format("mina:tcp://localhost:%1$s?sync=true&codec=#myCodec",
getPort()))
.transform(constant("Bye World")).to("mock:result");
}
@@ -139,7 +139,7 @@ public class MinaCustomCodecTest extends BaseMinaTest {
}
@Override
- public ProtocolEncoder getEncoder(IoSession session) throws Exception {
+ public ProtocolEncoder getEncoder(IoSession session) {
return new ProtocolEncoder() {
@Override
@@ -152,7 +152,7 @@ public class MinaCustomCodecTest extends BaseMinaTest {
}
@Override
- public void dispose(IoSession ioSession) throws Exception {
+ public void dispose(IoSession ioSession) {
// do nothing
}
};
@@ -160,7 +160,7 @@ public class MinaCustomCodecTest extends BaseMinaTest {
}
@Override
- public ProtocolDecoder getDecoder(IoSession session) throws Exception {
+ public ProtocolDecoder getDecoder(IoSession session) {
return new CumulativeProtocolDecoder() {
@Override
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaDisconnectRaceConditionTest.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaDisconnectRaceConditionTest.java
index 875dc4c531f..d0330a72351 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaDisconnectRaceConditionTest.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaDisconnectRaceConditionTest.java
@@ -56,10 +56,10 @@ public class MinaDisconnectRaceConditionTest extends
BaseMinaTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(String.format("mina:tcp://localhost:%1$s?sync=true&textline=true",
getPort())).process(exchange -> {
String body = exchange.getIn().getBody(String.class);
exchange.getMessage().setBody("Bye " + body);
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaDisconnectTest.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaDisconnectTest.java
index 0e8cb4d92a1..662c4b44f31 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaDisconnectTest.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaDisconnectTest.java
@@ -29,21 +29,21 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class MinaDisconnectTest extends BaseMinaTest {
@Test
- public void testCloseSessionWhenComplete() throws Exception {
+ public void testCloseSessionWhenComplete() {
Object out = template.requestBody(
String.format("mina:tcp://localhost:%1$s?sync=true&textline=true&disconnect=true",
getPort()), "Chad");
assertEquals("Bye Chad", out);
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(String.format("mina:tcp://localhost:%1$s?sync=true&textline=true&disconnect=true",
getPort()))
.process(new Processor() {
- public void process(Exchange exchange) throws
Exception {
+ public void process(Exchange exchange) {
String body =
exchange.getIn().getBody(String.class);
exchange.getMessage().setBody("Bye " + body);
}
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaEncodingTest.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaEncodingTest.java
index 981bfd8f14f..937162436d9 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaEncodingTest.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaEncodingTest.java
@@ -181,7 +181,7 @@ public class MinaEncodingTest extends BaseMinaTest {
}
@Test
- public void testInvalidEncoding() throws Exception {
+ public void testInvalidEncoding() {
final String uri =
String.format("mina:tcp://localhost:%1$s?textline=true&encoding=XXX&sync=false",
getPort());
try {
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaFiltersTest.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaFiltersTest.java
index 22433ce21aa..01abedbd872 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaFiltersTest.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaFiltersTest.java
@@ -60,7 +60,7 @@ public class MinaFiltersTest extends BaseMinaTest {
private void testFilter(final String uri) throws Exception {
context.addRoutes(new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(uri).to("mock:result");
}
});
@@ -85,7 +85,7 @@ public class MinaFiltersTest extends BaseMinaTest {
}
@Override
- protected void bindToRegistry(Registry registry) throws Exception {
+ protected void bindToRegistry(Registry registry) {
IoFilter myFilter = new TestFilter();
List<IoFilter> myFilters = new ArrayList<>();
myFilters.add(myFilter);
@@ -99,7 +99,7 @@ public class MinaFiltersTest extends BaseMinaTest {
public static volatile int called;
@Override
- public void sessionCreated(NextFilter nextFilter, IoSession session)
throws Exception {
+ public void sessionCreated(NextFilter nextFilter, IoSession session) {
incCalled();
nextFilter.sessionCreated(session);
}
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOnlyRouteTest.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOnlyRouteTest.java
index 8679928b2ab..361a7dbb8ff 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOnlyRouteTest.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOnlyRouteTest.java
@@ -36,10 +36,10 @@ public class MinaInOnlyRouteTest extends BaseMinaTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(String.format("mina:tcp://localhost:%1$s?sync=true",
getPort())).process(exchange -> {
String body = exchange.getIn().getBody(String.class);
exchange.getMessage().setBody("Bye " + body);
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutCloseSessionWhenCompleteTest.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutCloseSessionWhenCompleteTest.java
index 372b8aa4c64..4506951c3ad 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutCloseSessionWhenCompleteTest.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutCloseSessionWhenCompleteTest.java
@@ -27,17 +27,17 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class MinaInOutCloseSessionWhenCompleteTest extends BaseMinaTest {
@Test
- public void testCloseSessionWhenComplete() throws Exception {
+ public void testCloseSessionWhenComplete() {
Object out
=
template.requestBody(String.format("mina:tcp://localhost:%1$s?sync=true&textline=true",
getPort()), "Chad");
assertEquals("Bye Chad", out);
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(String.format("mina:tcp://localhost:%1$s?sync=true&textline=true",
getPort())).process(exchange -> {
String body = exchange.getIn().getBody(String.class);
exchange.getMessage().setBody("Bye " + body);
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutRouteTest.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutRouteTest.java
index 80373f6940e..0ba02fb241f 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutRouteTest.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutRouteTest.java
@@ -43,10 +43,10 @@ public class MinaInOutRouteTest extends BaseMinaTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(String.format("mina:tcp://localhost:%1$s?sync=true",
getPort())).process(exchange -> {
String body = exchange.getIn().getBody(String.class);
exchange.getMessage().setBody("Bye " + body);
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutRouteTextLineDelimiterTest.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutRouteTextLineDelimiterTest.java
index b88bccea16c..98d1c88a178 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutRouteTextLineDelimiterTest.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutRouteTextLineDelimiterTest.java
@@ -43,10 +43,10 @@ public class MinaInOutRouteTextLineDelimiterTest extends
BaseMinaTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(String.format("mina:tcp://localhost:%1$s?sync=true&textline=true&textlineDelimiter=MAC",
getPort()))
.process(exchange -> {
String body =
exchange.getIn().getBody(String.class);
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutWithForcedNoResponseTest.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutWithForcedNoResponseTest.java
index c560c36050a..259412bf828 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutWithForcedNoResponseTest.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutWithForcedNoResponseTest.java
@@ -34,7 +34,7 @@ public class MinaInOutWithForcedNoResponseTest extends
BaseMinaTest {
int port2;
@Test
- public void testResponse() throws Exception {
+ public void testResponse() {
Object out = template.requestBody("mina:tcp://localhost:" + port1 +
"?sync=true", "Woodbine");
assertEquals("Hello Chad", out);
}
@@ -48,10 +48,10 @@ public class MinaInOutWithForcedNoResponseTest extends
BaseMinaTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
port1 = getPort();
port2 = getNextPort();
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaMaxLineLengthTest.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaMaxLineLengthTest.java
index 538c5e10681..2c98a9f0d7f 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaMaxLineLengthTest.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaMaxLineLengthTest.java
@@ -41,11 +41,11 @@ public class MinaMaxLineLengthTest extends BaseMinaTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
// START SNIPPET: e1
// lets setup a server on port %1$s
// we set the sync option so we will send a reply
@@ -62,7 +62,7 @@ public class MinaMaxLineLengthTest extends BaseMinaTest {
private static class MyServerProcessor implements Processor {
@Override
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
// get the input from the IN body
String request = exchange.getIn().getBody(String.class);
// echo back the response on the OUT body
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaNoDefaultCodecTest.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaNoDefaultCodecTest.java
index 51503fb2781..8c5d88ae511 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaNoDefaultCodecTest.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaNoDefaultCodecTest.java
@@ -42,7 +42,7 @@ public class MinaNoDefaultCodecTest extends BaseMinaTest {
context.addRoutes(new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(uri1).to("mock:result");
from(uri2).to("mock:result");
}
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaNoResponseFromServerTest.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaNoResponseFromServerTest.java
index 54b18307f41..68e0561def3 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaNoResponseFromServerTest.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaNoResponseFromServerTest.java
@@ -56,10 +56,10 @@ public class MinaNoResponseFromServerTest extends
BaseMinaTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(String.format("mina:tcp://localhost:%1$s?sync=true&codec=#myCodec",
getPort()))
.transform(constant("Bye World")).to("mock:result");
}
@@ -69,15 +69,15 @@ public class MinaNoResponseFromServerTest extends
BaseMinaTest {
private static class MyCodec implements ProtocolCodecFactory {
@Override
- public ProtocolEncoder getEncoder(IoSession session) throws Exception {
+ public ProtocolEncoder getEncoder(IoSession session) {
return new ProtocolEncoder() {
- public void encode(IoSession ioSession, Object message,
ProtocolEncoderOutput out) throws Exception {
+ public void encode(IoSession ioSession, Object message,
ProtocolEncoderOutput out) {
// close session instead of returning a reply
ioSession.closeNow();
}
- public void dispose(IoSession ioSession) throws Exception {
+ public void dispose(IoSession ioSession) {
// do nothing
}
};
@@ -85,19 +85,19 @@ public class MinaNoResponseFromServerTest extends
BaseMinaTest {
}
@Override
- public ProtocolDecoder getDecoder(IoSession session) throws Exception {
+ public ProtocolDecoder getDecoder(IoSession session) {
return new ProtocolDecoder() {
- public void decode(IoSession ioSession, IoBuffer in,
ProtocolDecoderOutput out) throws Exception {
+ public void decode(IoSession ioSession, IoBuffer in,
ProtocolDecoderOutput out) {
// close session instead of returning a reply
ioSession.closeNow();
}
- public void finishDecode(IoSession ioSession,
ProtocolDecoderOutput protocolDecoderOutput) throws Exception {
+ public void finishDecode(IoSession ioSession,
ProtocolDecoderOutput protocolDecoderOutput) {
// do nothing
}
- public void dispose(IoSession ioSession) throws Exception {
+ public void dispose(IoSession ioSession) {
// do nothing
}
};
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaProducerAnotherConcurrentTest.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaProducerAnotherConcurrentTest.java
index 2f82d8bd977..174ed833a2d 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaProducerAnotherConcurrentTest.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaProducerAnotherConcurrentTest.java
@@ -33,7 +33,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
public class MinaProducerAnotherConcurrentTest extends BaseMinaTest {
@Test
- public void testSimple() throws Exception {
+ public void testSimple() {
String out = template.requestBody("direct:start", "A", String.class);
assertEquals("Bye A", out);
}
@@ -58,7 +58,7 @@ public class MinaProducerAnotherConcurrentTest extends
BaseMinaTest {
for (int i = 0; i < files; i++) {
final int index = i;
Future<String> out = executor.submit(new Callable<String>() {
- public String call() throws Exception {
+ public String call() {
return template.requestBody("direct:start", index,
String.class);
}
});
@@ -76,10 +76,10 @@ public class MinaProducerAnotherConcurrentTest extends
BaseMinaTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").to(String.format("mina:tcp://localhost:%1$s?sync=true",
getPort()));
from(String.format("mina:tcp://localhost:%1$s?sync=true",
getPort())).process(exchange -> {
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaProducerConcurrentTest.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaProducerConcurrentTest.java
index 2631cda4727..17813f6c451 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaProducerConcurrentTest.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaProducerConcurrentTest.java
@@ -52,7 +52,7 @@ public class MinaProducerConcurrentTest extends BaseMinaTest {
for (int i = 0; i < files; i++) {
final int index = i;
Future<String> out = executor.submit(new Callable<String>() {
- public String call() throws Exception {
+ public String call() {
return
template.requestBody(String.format("mina:tcp://localhost:%1$s?sync=true",
getPort()), index,
String.class);
}
@@ -75,10 +75,10 @@ public class MinaProducerConcurrentTest extends
BaseMinaTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(String.format("mina:tcp://localhost:%1$s?sync=true",
getPort())).process(exchange -> {
String body = exchange.getIn().getBody(String.class);
exchange.getMessage().setBody("Bye " + body);
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaReverserServer.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaReverserServer.java
index a89cae39c58..4554c9dd7de 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaReverserServer.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaReverserServer.java
@@ -49,7 +49,7 @@ public class MinaReverserServer {
acceptor.bind(new InetSocketAddress(port));
}
- public void stop() throws Exception {
+ public void stop() {
acceptor.unbind();
}
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaSendToProcessorTest.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaSendToProcessorTest.java
index 2f40922b3e5..95c4bdf4064 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaSendToProcessorTest.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaSendToProcessorTest.java
@@ -28,7 +28,7 @@ public class MinaSendToProcessorTest extends BaseMinaTest {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start")
.to(String.format("mina:tcp://localhost:%1$s?sync=false&lazySessionCreation=false",
getPort()));
}
@@ -47,7 +47,7 @@ public class MinaSendToProcessorTest extends BaseMinaTest {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").to(String.format("mina:tcp://localhost:%1$s?sync=false",
getPort()));
}
});
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpWithInOutTest.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpWithInOutTest.java
index 3c55dba2dbb..24915c05b1d 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpWithInOutTest.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpWithInOutTest.java
@@ -49,7 +49,7 @@ public class MinaTcpWithInOutTest extends BaseMinaTest {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:x").to(uri).process(new Processor() {
public void process(Exchange e) {
@@ -94,7 +94,7 @@ public class MinaTcpWithInOutTest extends BaseMinaTest {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:x").to(uri).process(new Processor() {
public void process(Exchange e) {
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTransferExchangeOptionTest.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTransferExchangeOptionTest.java
index 140617be96d..812e1854f21 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTransferExchangeOptionTest.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTransferExchangeOptionTest.java
@@ -103,7 +103,7 @@ public class MinaTransferExchangeOptionTest extends
BaseMinaTest {
from(String.format("mina:tcp://localhost:%1$s?sync=true&encoding=UTF-8&transferExchange=true",
getPort()))
.process(new Processor() {
- public void process(Exchange e) throws
InterruptedException {
+ public void process(Exchange e) {
LOG.debug("Enter Processor...");
assertNotNull(e.getIn().getBody());
LOG.debug("Enter Processor...1");
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpNoCamelTest.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpNoCamelTest.java
index c668cb0f4eb..694c852ff04 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpNoCamelTest.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpNoCamelTest.java
@@ -59,7 +59,7 @@ public class MinaUdpNoCamelTest {
}
@AfterEach
- public void closeUDPAcceptor() throws IOException {
+ public void closeUDPAcceptor() {
server.close();
}
@@ -106,13 +106,13 @@ public class MinaUdpNoCamelTest {
}
@Override
- public void messageReceived(IoSession session, Object message) throws
Exception {
+ public void messageReceived(IoSession session, Object message) {
logger.debug("UDPServer Received body: {}", message);
numMessagesReceived++;
}
@Override
- public void exceptionCaught(IoSession session, Throwable cause) throws
Exception {
+ public void exceptionCaught(IoSession session, Throwable cause) {
logger.error("Ooops! Something went wrong :|", cause);
}
}
@@ -161,12 +161,12 @@ public class MinaUdpNoCamelTest {
}
@Override
- public void messageReceived(IoSession session, Object message) throws
Exception {
+ public void messageReceived(IoSession session, Object message) {
logger.debug("Client Received body: {}", message);
}
@Override
- public void exceptionCaught(IoSession session, Throwable cause) throws
Exception {
+ public void exceptionCaught(IoSession session, Throwable cause) {
logger.error("Ooops! Something went wrong :|", cause);
}
}
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpUsingTemplateTest.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpUsingTemplateTest.java
index 9e879ff9509..c712e4b8e96 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpUsingTemplateTest.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpUsingTemplateTest.java
@@ -40,7 +40,7 @@ public class MinaUdpUsingTemplateTest extends BaseMinaTest {
assertMockEndpointsSatisfied();
}
- protected void sendUdpMessages() throws Exception {
+ protected void sendUdpMessages() {
for (int i = 0; i < messageCount; i++) {
template.sendBody(String.format("mina:udp://127.0.0.1:%1$s?sync=false",
getPort()), "Hello Message: " + i);
}
diff --git
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaVMCustomCodecTest.java
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaVMCustomCodecTest.java
index c0aac10a85b..035dd779c24 100644
---
a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaVMCustomCodecTest.java
+++
b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaVMCustomCodecTest.java
@@ -84,10 +84,10 @@ public class MinaVMCustomCodecTest extends BaseMinaTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
- public void configure() throws Exception {
+ public void configure() {
from(String.format("mina:vm://localhost:%1$s?sync=true&codec=#myCodec",
getPort()))
.transform(constant("Bye World")).to("mock:result");
}
@@ -97,7 +97,7 @@ public class MinaVMCustomCodecTest extends BaseMinaTest {
private static class MyCodec implements ProtocolCodecFactory {
@Override
- public ProtocolEncoder getEncoder(IoSession is) throws Exception {
+ public ProtocolEncoder getEncoder(IoSession is) {
return new ProtocolEncoder() {
public void encode(IoSession ioSession, Object message,
ProtocolEncoderOutput out) throws Exception {
@@ -108,7 +108,7 @@ public class MinaVMCustomCodecTest extends BaseMinaTest {
out.write(bb);
}
- public void dispose(IoSession ioSession) throws Exception {
+ public void dispose(IoSession ioSession) {
// do nothing
}
};
@@ -116,7 +116,7 @@ public class MinaVMCustomCodecTest extends BaseMinaTest {
}
@Override
- public ProtocolDecoder getDecoder(IoSession is) throws Exception {
+ public ProtocolDecoder getDecoder(IoSession is) {
return new CumulativeProtocolDecoder() {
protected boolean doDecode(IoSession session, IoBuffer in,
ProtocolDecoderOutput out) throws Exception {
