fixes #2043 Add an indicator ready for the server

networknt · Dec 13, 2023 · f572c1b · f572c1b
1 parent 92be1a4
commit f572c1b
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/server/src/main/java/com/networknt/server/Server.java b/server/src/main/java/com/networknt/server/Server.java
@@ -98,6 +98,9 @@ public class Server {
     // When dynamic port is used, this HashSet contains used port so that we just need to check here instead of trying bind.
     private static Set usedPorts;
 
+    // indicate if the server is ready to accept requests. Used by Kafka sidecar to consume messages in reactive consumer.
+    public static boolean ready = false;
+
     public static void main(final String[] args) {
         init();
     }
@@ -134,6 +137,7 @@ public static void init() {
             // send a graceful system shutdown
             System.exit(1);
         }
+        ready = true;
     }
 
     /**