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:06:59 UTC
[camel] 02/10: CAMEL-17763: cleaned up unused exceptions in camel-stream
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 ff7b18b25c2d931d6b3685eeba03c16c794ece90
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Wed Apr 13 11:07:42 2022 +0200
CAMEL-17763: cleaned up unused exceptions in camel-stream
---
.../test/java/org/apache/camel/component/stream/StreamDelayTest.java | 2 +-
.../java/org/apache/camel/component/stream/StreamEncodingTest.java | 2 +-
.../test/java/org/apache/camel/component/stream/StreamFileTest.java | 4 ++--
.../camel/component/stream/StreamGroupLinesLastStrategyTest.java | 4 ++--
.../apache/camel/component/stream/StreamGroupLinesStrategyTest.java | 4 ++--
.../java/org/apache/camel/component/stream/StreamGroupLinesTest.java | 4 ++--
.../java/org/apache/camel/component/stream/StreamHeaderTest.java | 3 +--
.../java/org/apache/camel/component/stream/StreamSystemErrTest.java | 2 +-
.../apache/camel/component/stream/StreamSystemOutNewLineOffTest.java | 2 +-
.../java/org/apache/camel/component/stream/StreamSystemOutTest.java | 2 +-
.../test/java/org/apache/camel/component/stream/mock/Handler.java | 3 +--
.../org/apache/camel/component/stream/mock/MockURLConnection.java | 5 ++---
12 files changed, 17 insertions(+), 20 deletions(-)
diff --git a/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamDelayTest.java b/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamDelayTest.java
index 96892430dcc..fc56ef0cac9 100644
--- a/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamDelayTest.java
+++ b/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamDelayTest.java
@@ -28,7 +28,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
public class StreamDelayTest extends CamelTestSupport {
@Test
- public void testStringContent() throws Exception {
+ public void testStringContent() {
long start = System.currentTimeMillis();
template.sendBody("direct:in", "Hello Text World\n");
long delta = System.currentTimeMillis() - start;
diff --git a/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamEncodingTest.java b/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamEncodingTest.java
index 92a110c5acc..895ebcf7ad5 100644
--- a/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamEncodingTest.java
+++ b/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamEncodingTest.java
@@ -26,7 +26,7 @@ import org.junit.jupiter.api.Test;
public class StreamEncodingTest extends CamelTestSupport {
@Test
- public void testStringContent() throws Exception {
+ public void testStringContent() {
// include a UTF-8 char in the text \u0E08 is a Thai elephant
String body = "Hello Thai Elephant \u0E08";
diff --git a/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamFileTest.java b/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamFileTest.java
index 2451b8c8778..0195bbbc727 100644
--- a/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamFileTest.java
+++ b/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamFileTest.java
@@ -71,7 +71,7 @@ public class StreamFileTest extends CamelTestSupport {
// can not use route builder as we need to have the file created in the setup before route builder starts
Endpoint endpoint = context.getEndpoint("stream:file?fileName=target/stream/streamfile.txt&delay=100");
Consumer consumer = endpoint.createConsumer(new Processor() {
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
template.send("mock:result", exchange);
}
});
@@ -92,7 +92,7 @@ public class StreamFileTest extends CamelTestSupport {
context.addRoutes(new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("direct:start").routeId("produce")
.to("stream:file?fileName=target/stream/StreamFileTest.txt&autoCloseCount=2");
from("file://target/stream?fileName=StreamFileTest.txt&noop=true").routeId("consume").autoStartup(false)
diff --git a/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamGroupLinesLastStrategyTest.java b/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamGroupLinesLastStrategyTest.java
index 4b29e013cae..5b82b1aa2e9 100644
--- a/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamGroupLinesLastStrategyTest.java
+++ b/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamGroupLinesLastStrategyTest.java
@@ -46,10 +46,10 @@ public class StreamGroupLinesLastStrategyTest extends StreamGroupLinesStrategyTe
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("stream:file?fileName=target/stream/streamfile.txt&groupLines=4&groupStrategy=#myGroupStrategy")
.to("mock:result");
}
diff --git a/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamGroupLinesStrategyTest.java b/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamGroupLinesStrategyTest.java
index 38c056b9b0d..ecc931c53a7 100644
--- a/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamGroupLinesStrategyTest.java
+++ b/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamGroupLinesStrategyTest.java
@@ -64,10 +64,10 @@ public class StreamGroupLinesStrategyTest extends StreamGroupLinesTest {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("stream:file?fileName=target/stream/streamfile.txt&groupLines=3&groupStrategy=#myGroupStrategy")
.to("mock:result");
}
diff --git a/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamGroupLinesTest.java b/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamGroupLinesTest.java
index de3f194f6c3..28f7d82b047 100644
--- a/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamGroupLinesTest.java
+++ b/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamGroupLinesTest.java
@@ -84,10 +84,10 @@ public class StreamGroupLinesTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
- public void configure() throws Exception {
+ public void configure() {
from("stream:file?fileName=target/stream/streamfile.txt&groupLines=3").to("mock:result");
}
};
diff --git a/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamHeaderTest.java b/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamHeaderTest.java
index 88891f8d42b..83957072152 100644
--- a/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamHeaderTest.java
+++ b/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamHeaderTest.java
@@ -16,7 +16,6 @@
*/
package org.apache.camel.component.stream;
-import java.io.IOException;
import java.io.OutputStream;
import org.apache.camel.builder.RouteBuilder;
@@ -61,7 +60,7 @@ public class StreamHeaderTest extends CamelTestSupport {
private class MyOutputStream extends OutputStream {
@Override
- public void write(int b) throws IOException {
+ public void write(int b) {
sb.append((char) b);
}
}
diff --git a/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamSystemErrTest.java b/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamSystemErrTest.java
index 6211ec1e6ac..a1b352e8757 100644
--- a/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamSystemErrTest.java
+++ b/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamSystemErrTest.java
@@ -26,7 +26,7 @@ import org.junit.jupiter.api.Test;
public class StreamSystemErrTest extends CamelTestSupport {
@Test
- public void testStringContent() throws Exception {
+ public void testStringContent() {
template.sendBody("direct:in", "Hello Text World\n");
}
diff --git a/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamSystemOutNewLineOffTest.java b/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamSystemOutNewLineOffTest.java
index 24b376a4efe..7e4e362aba9 100644
--- a/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamSystemOutNewLineOffTest.java
+++ b/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamSystemOutNewLineOffTest.java
@@ -38,7 +38,7 @@ public class StreamSystemOutNewLineOffTest extends CamelTestSupport {
// START SNIPPET: e1
@Test
- public void testStringContent() throws Exception {
+ public void testStringContent() {
try {
// Given
System.setOut(new PrintStream(mockOut));
diff --git a/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamSystemOutTest.java b/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamSystemOutTest.java
index 99aac3e5bed..66ee47e5b99 100644
--- a/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamSystemOutTest.java
+++ b/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamSystemOutTest.java
@@ -39,7 +39,7 @@ public class StreamSystemOutTest extends CamelTestSupport {
// START SNIPPET: e1
@Test
- public void testStringContent() throws Exception {
+ public void testStringContent() {
try {
// Given
System.setOut(new PrintStream(mockOut));
diff --git a/components/camel-stream/src/test/java/org/apache/camel/component/stream/mock/Handler.java b/components/camel-stream/src/test/java/org/apache/camel/component/stream/mock/Handler.java
index 94b570927d6..fe696763e05 100644
--- a/components/camel-stream/src/test/java/org/apache/camel/component/stream/mock/Handler.java
+++ b/components/camel-stream/src/test/java/org/apache/camel/component/stream/mock/Handler.java
@@ -16,7 +16,6 @@
*/
package org.apache.camel.component.stream.mock;
-import java.io.IOException;
import java.net.URL;
import java.net.URLConnection;
import java.net.URLStreamHandler;
@@ -27,7 +26,7 @@ import java.net.URLStreamHandler;
public class Handler extends URLStreamHandler {
@Override
- protected URLConnection openConnection(URL u) throws IOException {
+ protected URLConnection openConnection(URL u) {
return new MockURLConnection(u);
}
diff --git a/components/camel-stream/src/test/java/org/apache/camel/component/stream/mock/MockURLConnection.java b/components/camel-stream/src/test/java/org/apache/camel/component/stream/mock/MockURLConnection.java
index 13eab09718a..5b00ac7b705 100644
--- a/components/camel-stream/src/test/java/org/apache/camel/component/stream/mock/MockURLConnection.java
+++ b/components/camel-stream/src/test/java/org/apache/camel/component/stream/mock/MockURLConnection.java
@@ -16,7 +16,6 @@
*/
package org.apache.camel.component.stream.mock;
-import java.io.IOException;
import java.io.OutputStream;
import java.net.URL;
import java.net.URLConnection;
@@ -38,11 +37,11 @@ public class MockURLConnection extends URLConnection {
}
@Override
- public void connect() throws IOException {
+ public void connect() {
}
@Override
- public OutputStream getOutputStream() throws IOException {
+ public OutputStream getOutputStream() {
return THREAD_OUTPUT_STREAM.get();
}