From faed069ac7db42228f7639b92346388d65e8386f Mon Sep 17 00:00:00 2001
From: Julien Viet <julien@julienviet.com>
Date: Mon, 23 Sep 2024 23:02:07 +0200
Subject: [PATCH] Update to vertx-core inbound message queue changes

---
 .../grpc/common/impl/GrpcReadStreamBase.java  |  2 +-
 .../server/GrpcServerOptionsConverter.java    | 55 +++++++++++++++++++
 2 files changed, 56 insertions(+), 1 deletion(-)
 create mode 100644 vertx-grpc-server/src/main/generated/io/vertx/grpc/server/GrpcServerOptionsConverter.java

diff --git a/vertx-grpc-common/src/main/java/io/vertx/grpc/common/impl/GrpcReadStreamBase.java b/vertx-grpc-common/src/main/java/io/vertx/grpc/common/impl/GrpcReadStreamBase.java
index 84a3956..312a104 100644
--- a/vertx-grpc-common/src/main/java/io/vertx/grpc/common/impl/GrpcReadStreamBase.java
+++ b/vertx-grpc-common/src/main/java/io/vertx/grpc/common/impl/GrpcReadStreamBase.java
@@ -75,7 +75,7 @@ protected GrpcReadStreamBase(Context context,
     this.maxMessageSize = maxMessageSize;
     this.stream = stream;
     this.format = format;
-    this.queue = new InboundMessageQueue<>(ctx.nettyEventLoop(), ctx, 8, 16) {
+    this.queue = new InboundMessageQueue<>(ctx.eventLoop(), ctx.executor(), 8, 16) {
       @Override
       protected void handleResume() {
         stream.resume();
diff --git a/vertx-grpc-server/src/main/generated/io/vertx/grpc/server/GrpcServerOptionsConverter.java b/vertx-grpc-server/src/main/generated/io/vertx/grpc/server/GrpcServerOptionsConverter.java
new file mode 100644
index 0000000..d5977dd
--- /dev/null
+++ b/vertx-grpc-server/src/main/generated/io/vertx/grpc/server/GrpcServerOptionsConverter.java
@@ -0,0 +1,55 @@
+package io.vertx.grpc.server;
+
+import io.vertx.core.json.JsonObject;
+import io.vertx.core.json.JsonArray;
+import java.time.Instant;
+import java.time.format.DateTimeFormatter;
+import java.util.Base64;
+
+/**
+ * Converter and mapper for {@link io.vertx.grpc.server.GrpcServerOptions}.
+ * NOTE: This class has been automatically generated from the {@link io.vertx.grpc.server.GrpcServerOptions} original class using Vert.x codegen.
+ */
+public class GrpcServerOptionsConverter {
+
+  private static final Base64.Decoder BASE64_DECODER = Base64.getUrlDecoder();
+  private static final Base64.Encoder BASE64_ENCODER = Base64.getUrlEncoder().withoutPadding();
+
+   static void fromJson(Iterable<java.util.Map.Entry<String, Object>> json, GrpcServerOptions obj) {
+    for (java.util.Map.Entry<String, Object> member : json) {
+      switch (member.getKey()) {
+        case "grpcWebEnabled":
+          if (member.getValue() instanceof Boolean) {
+            obj.setGrpcWebEnabled((Boolean)member.getValue());
+          }
+          break;
+        case "scheduleDeadlineAutomatically":
+          if (member.getValue() instanceof Boolean) {
+            obj.setScheduleDeadlineAutomatically((Boolean)member.getValue());
+          }
+          break;
+        case "deadlinePropagation":
+          if (member.getValue() instanceof Boolean) {
+            obj.setDeadlinePropagation((Boolean)member.getValue());
+          }
+          break;
+        case "maxMessageSize":
+          if (member.getValue() instanceof Number) {
+            obj.setMaxMessageSize(((Number)member.getValue()).longValue());
+          }
+          break;
+      }
+    }
+  }
+
+   static void toJson(GrpcServerOptions obj, JsonObject json) {
+    toJson(obj, json.getMap());
+  }
+
+   static void toJson(GrpcServerOptions obj, java.util.Map<String, Object> json) {
+    json.put("grpcWebEnabled", obj.isGrpcWebEnabled());
+    json.put("scheduleDeadlineAutomatically", obj.getScheduleDeadlineAutomatically());
+    json.put("deadlinePropagation", obj.getDeadlinePropagation());
+    json.put("maxMessageSize", obj.getMaxMessageSize());
+  }
+}