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 13:34:58 UTC
[camel] 02/08: CAMEL-17763: cleanup unused exceptions in camel-grpc
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 cec38eb8c153e162ee2c54fa24e6b49c7bda477f
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Mon Apr 11 14:10:31 2022 +0200
CAMEL-17763: cleanup unused exceptions in camel-grpc
---
.../camel/component/grpc/GrpcConsumerAggregationTest.java | 6 +++---
.../camel/component/grpc/GrpcConsumerConcurrentTest.java | 8 ++++----
.../camel/component/grpc/GrpcConsumerExceptionTest.java | 2 +-
.../camel/component/grpc/GrpcConsumerPropagationTest.java | 2 +-
.../apache/camel/component/grpc/GrpcConsumerSecurityTest.java | 2 +-
.../apache/camel/component/grpc/GrpcProducerAsyncTest.java | 5 ++---
.../component/grpc/GrpcProducerClientInterceptorTest.java | 8 +++-----
.../apache/camel/component/grpc/GrpcProducerSecurityTest.java | 11 +++++------
.../camel/component/grpc/GrpcProducerStreamingTest.java | 5 ++---
.../org/apache/camel/component/grpc/GrpcProducerSyncTest.java | 11 +++++------
10 files changed, 27 insertions(+), 33 deletions(-)
diff --git a/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcConsumerAggregationTest.java b/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcConsumerAggregationTest.java
index 3193cacc047..e822d1076f6 100644
--- a/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcConsumerAggregationTest.java
+++ b/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcConsumerAggregationTest.java
@@ -73,7 +73,7 @@ public class GrpcConsumerAggregationTest extends CamelTestSupport {
}
@Test
- public void testSyncSyncMethodInSync() throws Exception {
+ public void testSyncSyncMethodInSync() {
LOG.info("gRPC pingSyncSync method blocking test start");
PingRequest pingRequest
= PingRequest.newBuilder().setPingName(GRPC_TEST_PING_VALUE).setPingId(GRPC_TEST_PING_ID).build();
@@ -85,7 +85,7 @@ public class GrpcConsumerAggregationTest extends CamelTestSupport {
}
@Test
- public void testSyncAsyncMethodInSync() throws Exception {
+ public void testSyncAsyncMethodInSync() {
LOG.info("gRPC pingSyncAsync method blocking test start");
PingRequest pingRequest
= PingRequest.newBuilder().setPingName(GRPC_TEST_PING_VALUE).setPingId(GRPC_TEST_PING_ID).build();
@@ -177,7 +177,7 @@ public class GrpcConsumerAggregationTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
diff --git a/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcConsumerConcurrentTest.java b/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcConsumerConcurrentTest.java
index 77e88f61839..47d989b7063 100644
--- a/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcConsumerConcurrentTest.java
+++ b/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcConsumerConcurrentTest.java
@@ -59,7 +59,7 @@ public class GrpcConsumerConcurrentTest extends CamelTestSupport {
}
@Test
- public void testAsyncWithConcurrentThreads() throws Exception {
+ public void testAsyncWithConcurrentThreads() {
RunnableAssert ra = new RunnableAssert("foo") {
@Override
@@ -99,7 +99,7 @@ public class GrpcConsumerConcurrentTest extends CamelTestSupport {
}
@Test
- public void testHeadersWithConcurrentThreads() throws Exception {
+ public void testHeadersWithConcurrentThreads() {
RunnableAssert ra = new RunnableAssert("foo") {
@Override
@@ -140,7 +140,7 @@ public class GrpcConsumerConcurrentTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
@@ -195,7 +195,7 @@ public class GrpcConsumerConcurrentTest extends CamelTestSupport {
@Override
@SuppressWarnings("unchecked")
- public void process(Exchange exchange) throws Exception {
+ public void process(Exchange exchange) {
List<PingRequest> pingRequests = (List<PingRequest>) exchange.getIn().getBody();
String userAgentName = (String) exchange.getIn().getHeader(GrpcConstants.GRPC_USER_AGENT_HEADER);
diff --git a/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcConsumerExceptionTest.java b/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcConsumerExceptionTest.java
index ecce0df9973..d5cdd0ac31b 100644
--- a/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcConsumerExceptionTest.java
+++ b/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcConsumerExceptionTest.java
@@ -88,7 +88,7 @@ public class GrpcConsumerExceptionTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
diff --git a/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcConsumerPropagationTest.java b/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcConsumerPropagationTest.java
index 57c1ffed525..dc17e9bdffd 100644
--- a/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcConsumerPropagationTest.java
+++ b/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcConsumerPropagationTest.java
@@ -117,7 +117,7 @@ public class GrpcConsumerPropagationTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
diff --git a/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcConsumerSecurityTest.java b/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcConsumerSecurityTest.java
index 2ce2af4e6d1..9900ec5dd4c 100644
--- a/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcConsumerSecurityTest.java
+++ b/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcConsumerSecurityTest.java
@@ -179,7 +179,7 @@ public class GrpcConsumerSecurityTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
diff --git a/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerAsyncTest.java b/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerAsyncTest.java
index b3c82e3432c..c01dddaaed9 100644
--- a/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerAsyncTest.java
+++ b/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerAsyncTest.java
@@ -16,7 +16,6 @@
*/
package org.apache.camel.component.grpc;
-import java.io.IOException;
import java.util.List;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
@@ -60,7 +59,7 @@ public class GrpcProducerAsyncTest extends CamelTestSupport {
}
@AfterAll
- public static void stopGrpcServer() throws IOException {
+ public static void stopGrpcServer() {
if (grpcServer != null) {
grpcServer.shutdown();
LOG.info("gRPC server stopped");
@@ -181,7 +180,7 @@ public class GrpcProducerAsyncTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
diff --git a/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerClientInterceptorTest.java b/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerClientInterceptorTest.java
index 5cc038b3251..b40fed63380 100644
--- a/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerClientInterceptorTest.java
+++ b/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerClientInterceptorTest.java
@@ -16,8 +16,6 @@
*/
package org.apache.camel.component.grpc;
-import java.io.IOException;
-
import io.grpc.Server;
import io.grpc.ServerBuilder;
import io.grpc.stub.StreamObserver;
@@ -59,7 +57,7 @@ public class GrpcProducerClientInterceptorTest extends CamelTestSupport {
}
@AfterAll
- public static void stopGrpcServer() throws IOException {
+ public static void stopGrpcServer() {
if (grpcServer != null) {
grpcServer.shutdown();
LOG.info("gRPC server stopped");
@@ -67,7 +65,7 @@ public class GrpcProducerClientInterceptorTest extends CamelTestSupport {
}
@Test
- public void testClientInterceptors() throws Exception {
+ public void testClientInterceptors() {
when(mockClientInterceptor.interceptCall(any(), any(), any())).thenCallRealMethod();
when(mockClientInterceptor2.interceptCall(any(), any(), any())).thenCallRealMethod();
LOG.info("gRPC PingSyncSync method test start");
@@ -91,7 +89,7 @@ public class GrpcProducerClientInterceptorTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
// This needs to be here because if it's any earlier the context won't be set up and if it's any later, we'll
// put it in the registry after the component is already set up.
context.getRegistry().bind("grpcMockClientInterceptor", mockClientInterceptor);
diff --git a/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerSecurityTest.java b/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerSecurityTest.java
index a0adacae78c..902299137c9 100644
--- a/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerSecurityTest.java
+++ b/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerSecurityTest.java
@@ -17,7 +17,6 @@
package org.apache.camel.component.grpc;
import java.io.File;
-import java.io.IOException;
import io.grpc.Server;
import io.grpc.StatusRuntimeException;
@@ -87,7 +86,7 @@ public class GrpcProducerSecurityTest extends CamelTestSupport {
}
@AfterAll
- public static void stopGrpcServer() throws IOException {
+ public static void stopGrpcServer() {
if (grpcServerWithTLS != null) {
grpcServerWithTLS.shutdown();
LOG.info("gRPC server with TLS stopped");
@@ -100,7 +99,7 @@ public class GrpcProducerSecurityTest extends CamelTestSupport {
}
@Test
- public void testWithEnableTLS() throws Exception {
+ public void testWithEnableTLS() {
LOG.info("gRPC PingSyncSync method test start with TLS enable");
// Testing simple sync method invoke using TLS negotiation
PingRequest pingRequest
@@ -114,7 +113,7 @@ public class GrpcProducerSecurityTest extends CamelTestSupport {
}
@Test
- public void testWithCorrectJWT() throws Exception {
+ public void testWithCorrectJWT() {
LOG.info("gRPC PingSyncSync method test start with correct JWT authentication");
// Testing simple sync method invoke using correct JWT authentication
PingRequest pingRequest
@@ -128,7 +127,7 @@ public class GrpcProducerSecurityTest extends CamelTestSupport {
}
@Test
- public void testWithIncorrectJWT() throws Exception {
+ public void testWithIncorrectJWT() {
LOG.info("gRPC PingSyncSync method test start with incorrect JWT authentication");
// Testing simple sync method invoke using incorrect JWT authentication
PingRequest pingRequest
@@ -146,7 +145,7 @@ public class GrpcProducerSecurityTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
diff --git a/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerStreamingTest.java b/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerStreamingTest.java
index 41a0b90958f..e7e6cd22162 100644
--- a/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerStreamingTest.java
+++ b/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerStreamingTest.java
@@ -16,7 +16,6 @@
*/
package org.apache.camel.component.grpc;
-import java.io.IOException;
import java.util.LinkedList;
import java.util.List;
@@ -54,7 +53,7 @@ public class GrpcProducerStreamingTest extends CamelTestSupport {
}
@AfterEach
- public void stopGrpcServer() throws IOException {
+ public void stopGrpcServer() {
if (grpcServer != null) {
grpcServer.shutdown();
LOG.info("gRPC server stopped");
@@ -115,7 +114,7 @@ public class GrpcProducerStreamingTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {
diff --git a/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerSyncTest.java b/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerSyncTest.java
index 71ec8e47104..99999e002f3 100644
--- a/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerSyncTest.java
+++ b/components/camel-grpc/src/test/java/org/apache/camel/component/grpc/GrpcProducerSyncTest.java
@@ -16,7 +16,6 @@
*/
package org.apache.camel.component.grpc;
-import java.io.IOException;
import java.util.List;
import io.grpc.Server;
@@ -57,7 +56,7 @@ public class GrpcProducerSyncTest extends CamelTestSupport {
}
@AfterAll
- public static void stopGrpcServer() throws IOException {
+ public static void stopGrpcServer() {
if (grpcServer != null) {
grpcServer.shutdown();
LOG.info("gRPC server stopped");
@@ -65,7 +64,7 @@ public class GrpcProducerSyncTest extends CamelTestSupport {
}
@Test
- public void testPingSyncSyncMethodInvocation() throws Exception {
+ public void testPingSyncSyncMethodInvocation() {
LOG.info("gRPC PingSyncSync method test start");
// Testing simple sync method invoke with host and port parameters
PingRequest pingRequest
@@ -85,7 +84,7 @@ public class GrpcProducerSyncTest extends CamelTestSupport {
}
@Test
- public void testPingSyncSyncMultipleInvocation() throws Exception {
+ public void testPingSyncSyncMultipleInvocation() {
final StopWatch stopwatch = new StopWatch();
// Multiple sync methods call for average performance estimation
for (int id = 0; id < MULTIPLE_RUN_TEST_COUNT; id++) {
@@ -100,7 +99,7 @@ public class GrpcProducerSyncTest extends CamelTestSupport {
@Test
@SuppressWarnings("unchecked")
- public void testPingSyncAsyncMethodInvocation() throws Exception {
+ public void testPingSyncAsyncMethodInvocation() {
LOG.info("gRPC PingSyncAsync method test start");
// Testing simple method with sync request and asyc response in synchronous invocation style
PingRequest pingRequest
@@ -114,7 +113,7 @@ public class GrpcProducerSyncTest extends CamelTestSupport {
}
@Override
- protected RouteBuilder createRouteBuilder() throws Exception {
+ protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
@Override
public void configure() {