Max concurrent streams (#337)

restatedev · May 31, 2024 · ff15028 · ff15028
1 parent 01dab68
commit ff15028
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/sdk-http-vertx/src/main/java/dev/restate/sdk/http/vertx/RestateHttpEndpointBuilder.java b/sdk-http-vertx/src/main/java/dev/restate/sdk/http/vertx/RestateHttpEndpointBuilder.java
@@ -15,6 +15,7 @@
 import io.opentelemetry.api.OpenTelemetry;
 import io.vertx.core.AsyncResult;
 import io.vertx.core.Vertx;
+import io.vertx.core.http.Http2Settings;
 import io.vertx.core.http.HttpServer;
 import io.vertx.core.http.HttpServerOptions;
 import java.util.*;
@@ -46,7 +47,8 @@ public class RestateHttpEndpointBuilder {
   private OpenTelemetry openTelemetry = OpenTelemetry.noop();
   private HttpServerOptions options =
       new HttpServerOptions()
-          .setPort(Optional.ofNullable(System.getenv("PORT")).map(Integer::parseInt).orElse(9080));
+          .setPort(Optional.ofNullable(System.getenv("PORT")).map(Integer::parseInt).orElse(9080))
+          .setInitialSettings(new Http2Settings().setMaxConcurrentStreams(Integer.MAX_VALUE));
 
   private RestateHttpEndpointBuilder(Vertx vertx) {
     this.vertx = vertx;