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 index c7e3b159759bd..e7cc902b6384a 100644 --- 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 @@ -79,6 +79,7 @@ import io.vertx.core.net.PemTrustOptions; import io.vertx.core.net.SocketAddress; import io.vertx.grpc.client.GrpcClientChannel; +import io.vertx.grpc.client.GrpcClientOptions; @SuppressWarnings({ "OptionalIsPresent" }) public class Channels { @@ -335,7 +336,9 @@ public static Channel createChannel(String name, Set 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();