Skip to content

Commit

Permalink
Use debug with relfection services, remove duplicate health check
Browse files Browse the repository at this point in the history
(cherry picked from commit 7c81cec)
  • Loading branch information
alesj authored and gsmet committed Feb 25, 2025
1 parent c5b74db commit e941f40
Showing 1 changed file with 3 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand All @@ -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<Integer, Handler<RoutingContext>> e : securityHandlers.entrySet()) {
Expand Down Expand Up @@ -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();
Expand Down Expand Up @@ -611,7 +610,7 @@ private Map.Entry<Integer, Server> 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));
}
Expand Down

0 comments on commit e941f40

Please sign in to comment.