From e941f4002371b880283458d92faffef7af3fa44e Mon Sep 17 00:00:00 2001 From: Ales Justin Date: Mon, 24 Feb 2025 10:48:58 +0100 Subject: [PATCH] Use debug with relfection services, remove duplicate health check (cherry picked from commit 7c81cec616cce28024796b5e9fdc1625a0a8ad68) --- .../java/io/quarkus/grpc/runtime/GrpcServerRecorder.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/extensions/grpc/runtime/src/main/java/io/quarkus/grpc/runtime/GrpcServerRecorder.java b/extensions/grpc/runtime/src/main/java/io/quarkus/grpc/runtime/GrpcServerRecorder.java index 222433e5d604a..a60e2349cbe87 100644 --- a/extensions/grpc/runtime/src/main/java/io/quarkus/grpc/runtime/GrpcServerRecorder.java +++ b/extensions/grpc/runtime/src/main/java/io/quarkus/grpc/runtime/GrpcServerRecorder.java @@ -204,7 +204,7 @@ private void buildGrpcServer(Vertx vertx, GrpcServerConfiguration configuration, boolean reflectionServiceEnabled = configuration.enableReflectionService() || launchMode == LaunchMode.DEVELOPMENT; if (reflectionServiceEnabled) { - LOGGER.info("Registering gRPC reflection service"); + LOGGER.debug("Registering gRPC reflection service"); ReflectionServiceV1 reflectionServiceV1 = new ReflectionServiceV1(definitions); ReflectionServiceV1alpha reflectionServiceV1alpha = new ReflectionServiceV1alpha(definitions); ServerServiceDefinition serviceDefinition = ServerInterceptors.intercept(reflectionServiceV1, globalInterceptors); @@ -216,8 +216,6 @@ private void buildGrpcServer(Vertx vertx, GrpcServerConfiguration configuration, bridgeAlpha.bind(server); } - initHealthStorage(); - Router router = routerSupplier.getValue(); if (securityHandlers != null) { for (Map.Entry> e : securityHandlers.entrySet()) { @@ -257,6 +255,7 @@ public void handle(Void unused) { } LOGGER.info("Starting new Quarkus gRPC server (using Vert.x transport)..."); + Route route = router.route().handler(ctx -> { if (!isGrpc(ctx)) { ctx.next(); @@ -611,7 +610,7 @@ private Map.Entry buildServer(Vertx vertx, GrpcServerConfigurat } if (reflectionServiceEnabled) { - LOGGER.info("Registering gRPC reflection service"); + LOGGER.debug("Registering gRPC reflection service"); builder.addService(ServerInterceptors.intercept(new ReflectionServiceV1(definitions), globalInterceptors)); builder.addService(ServerInterceptors.intercept(new ReflectionServiceV1alpha(definitions), globalInterceptors)); }