This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a commit to branch quarkus-master
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 5ad5a5443b3222a102a439340e3c0c0e111df4f3
Author: James Netherton <jamesnether...@gmail.com>
AuthorDate: Thu Mar 18 16:50:15 2021 +0000
Upgrade to Quarkus 1.14.0.Final
---
.../camel/quarkus/component/grpc/it/GrpcRoute.java | 27 +++++++++++++++-------
.../camel/quarkus/component/grpc/it/GrpcTest.java | 3 ++-
pom.xml | 2 +-
3 files changed, 22 insertions(+), 10 deletions(-)
diff --git
a/integration-tests/grpc/src/main/java/org/apache/camel/quarkus/component/grpc/it/GrpcRoute.java
b/integration-tests/grpc/src/main/java/org/apache/camel/quarkus/component/grpc/it/GrpcRoute.java
index 4adfd56..23f31f6 100644
---
a/integration-tests/grpc/src/main/java/org/apache/camel/quarkus/component/grpc/it/GrpcRoute.java
+++
b/integration-tests/grpc/src/main/java/org/apache/camel/quarkus/component/grpc/it/GrpcRoute.java
@@ -16,22 +16,33 @@
*/
package org.apache.camel.quarkus.component.grpc.it;
+import java.util.Optional;
+
import org.apache.camel.Message;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.quarkus.component.grpc.it.model.PingRequest;
import org.apache.camel.quarkus.component.grpc.it.model.PongResponse;
+import org.eclipse.microprofile.config.Config;
+import org.eclipse.microprofile.config.ConfigProvider;
public class GrpcRoute extends RouteBuilder {
@Override
public void configure() throws Exception {
-
from("grpc://localhost:9000/org.apache.camel.quarkus.component.grpc.it.model.PingPong?synchronous=true")
- .process(exchange -> {
- final Message message = exchange.getMessage();
- final PingRequest request =
message.getBody(PingRequest.class);
- final PongResponse response =
PongResponse.newBuilder().setPongName(request.getPingName() + " PONG")
- .setPongId(request.getPingId()).build();
- message.setBody(response);
- });
+
fromF("grpc://localhost:%d/org.apache.camel.quarkus.component.grpc.it.model.PingPong?synchronous=true",
+ getServerPort())
+ .process(exchange -> {
+ final Message message = exchange.getMessage();
+ final PingRequest request =
message.getBody(PingRequest.class);
+ final PongResponse response =
PongResponse.newBuilder().setPongName(request.getPingName() + " PONG")
+ .setPongId(request.getPingId()).build();
+ message.setBody(response);
+ });
+ }
+
+ public static int getServerPort() {
+ Config config = ConfigProvider.getConfig();
+ Optional<Integer> testServerPort =
config.getOptionalValue("quarkus.grpc.server.test-port", Integer.class);
+ return testServerPort.orElse(9000);
}
}
diff --git
a/integration-tests/grpc/src/test/java/org/apache/camel/quarkus/component/grpc/it/GrpcTest.java
b/integration-tests/grpc/src/test/java/org/apache/camel/quarkus/component/grpc/it/GrpcTest.java
index 4625a0c..e983b49 100644
---
a/integration-tests/grpc/src/test/java/org/apache/camel/quarkus/component/grpc/it/GrpcTest.java
+++
b/integration-tests/grpc/src/test/java/org/apache/camel/quarkus/component/grpc/it/GrpcTest.java
@@ -38,7 +38,8 @@ class GrpcTest {
public void consumer() {
ManagedChannel syncRequestChannel = null;
try {
- syncRequestChannel = ManagedChannelBuilder.forAddress("localhost",
9000).usePlaintext().build();
+ syncRequestChannel = ManagedChannelBuilder.forAddress("localhost",
GrpcRoute.getServerPort()).usePlaintext()
+ .build();
final PingPongBlockingStub blockingStub =
PingPongGrpc.newBlockingStub(syncRequestChannel);
final PingRequest pingRequest = PingRequest.newBuilder()
diff --git a/pom.xml b/pom.xml
index d88d695..57e3eb5 100644
--- a/pom.xml
+++ b/pom.xml
@@ -101,7 +101,7 @@
<optaplanner.version>7.46.0.Final</optaplanner.version>
<quarkiverse.freemarker.version>0.2.2</quarkiverse.freemarker.version>
<quarkiverse-minio.version>0.2.0</quarkiverse-minio.version>
- <quarkus.version>1.13.0.CR1</quarkus.version>
+ <quarkus.version>999-SNAPSHOT</quarkus.version>
<quarkus-google-cloud.version>0.3.0</quarkus-google-cloud.version>
<quarkus-hazelcast-client.version>1.1.1</quarkus-hazelcast-client.version>
<quarkus-qpid-jms.version>0.23.0</quarkus-qpid-jms.version>
