Validating configs before initializing the hub

Signed-off-by: HimajaDhanyamraju2 <dhanyamraju.himaja2@mindtree.com>
mosip · Feb 6, 2024 · 4032cde · 4032cde
1 parent 8392b91
commit 4032cde
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/hub/start_hub.bal b/hub/start_hub.bal
@@ -43,14 +43,16 @@ public function main() returns error? {
             log:printInfo("found all metadata topics in kafka");
         }
     }
-    // Initialize the Hub
-    _ = @strand {thread: "any"} start syncRegsisteredTopicsCache();
-    _ = @strand {thread: "any"} start syncSubscribersCache();
 
     boolean|error validConfigs = validateConfigs();
     if validConfigs is error {
         return validConfigs;
     }
+
+    // Initialize the Hub
+    _ = @strand {thread: "any"} start syncRegsisteredTopicsCache();
+    _ = @strand {thread: "any"} start syncSubscribersCache();
+
     // Start the Hub
     http:Listener httpListener = check new (config:HUB_PORT);
     check httpListener.attach(healthCheckService, "hub/actuator/health");