Respect max message size property fo Quarkus GRPC client (44853)

quarkusio · Dec 1, 2024 · 5065e14 · 5065e14
1 parent 2649fa7
commit 5065e14
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/extensions/grpc/runtime/src/main/java/io/quarkus/grpc/runtime/supports/Channels.java b/extensions/grpc/runtime/src/main/java/io/quarkus/grpc/runtime/supports/Channels.java
@@ -31,6 +31,7 @@
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
 
+import io.vertx.grpc.client.GrpcClientOptions;
 import jakarta.enterprise.context.spi.CreationalContext;
 
 import org.eclipse.microprofile.context.ManagedExecutor;
@@ -335,7 +336,9 @@ public static Channel createChannel(String name, Set<String> perClientIntercepto
             options.setMetricsName("grpc|" + name);
 
             Vertx vertx = container.instance(Vertx.class).get();
-            io.vertx.grpc.client.GrpcClient client = io.vertx.grpc.client.GrpcClient.client(vertx, options);
+            io.vertx.grpc.client.GrpcClient client = io.vertx.grpc.client.GrpcClient.client(vertx,
+                    new GrpcClientOptions().setTransportOptions(options)
+                            .setMaxMessageSize(config.maxInboundMessageSize.orElse(DEFAULT_MAX_MESSAGE_SIZE)));
             Channel channel;
             if (stork) {
                 ManagedExecutor executor = container.instance(ManagedExecutor.class).get();