- Threading model support added on service level

- Redundant code removal
Areeb-Gillani · Dec 25, 2024 · 70f84d6 · 70f84d6
1 parent 5f88824
commit 70f84d6
Show file tree

Hide file tree

Showing 5 changed files with 8 additions and 7 deletions.
diff --git a/build.gradle.kts b/build.gradle.kts
@@ -4,8 +4,7 @@ plugins {
 }
 
 group = "io.github.areebgillani"
-version = "1.0.0"
-version = "1.0.1"
+version = "1.0.2"
 val vertxVersion = "4.5.8"
 publishing {
     publications {

diff --git a/src/main/java/io/github/areebgillani/boost/AbstractController.java b/src/main/java/io/github/areebgillani/boost/AbstractController.java
@@ -1,7 +1,6 @@
 package io.github.areebgillani.boost;
 
 import io.vertx.core.AbstractVerticle;
-import io.vertx.core.Vertx;
 import io.vertx.core.eventbus.EventBus;
 import io.vertx.core.impl.logging.Logger;
 import io.vertx.core.impl.logging.LoggerFactory;

diff --git a/src/main/java/io/github/areebgillani/boost/AbstractService.java b/src/main/java/io/github/areebgillani/boost/AbstractService.java
@@ -1,7 +1,6 @@
 package io.github.areebgillani.boost;
 
 import io.vertx.core.AbstractVerticle;
-import io.vertx.core.Vertx;
 import io.vertx.core.eventbus.EventBus;
 import io.vertx.core.impl.logging.Logger;
 import io.vertx.core.impl.logging.LoggerFactory;

diff --git a/src/main/java/io/github/areebgillani/boost/BoostApplication.java b/src/main/java/io/github/areebgillani/boost/BoostApplication.java
@@ -127,13 +127,17 @@ public ConfigRetrieverOptions initRetrieverConfig(String folderPath) {
                         .setConfig(new JsonObject().put("path", folderPath == null || folderPath.isEmpty() ? "config.json" : folderPath)))
                 .addStore(new ConfigStoreOptions().setType("sys"));
     }
-    private void deployServices(JsonObject config, Supplier<Verticle> serviceSupplier, String workerName, JsonObject workerConfig) throws Exception {
+    private void deployServices(JsonObject config, Supplier<Verticle> serviceSupplier, String workerName, JsonObject workerConfig) {
         vertx.deployVerticle(serviceSupplier, new DeploymentOptions()
                 .setConfig(config)
                 .setWorkerPoolName(workerName)
                 .setWorkerPoolSize(workerConfig.getInteger("poolSize", 20))
                 .setInstances(workerConfig.getInteger("instance", 5))
-                .setThreadingModel(ThreadingModel.WORKER), res -> {
+                .setThreadingModel(switch (workerConfig.getString("type", "W")) {
+                    case "EL": yield ThreadingModel.EVENT_LOOP;
+                    case "VT": yield ThreadingModel.VIRTUAL_THREAD;
+                    default: yield ThreadingModel.WORKER;
+                }), res -> {
             if (res.succeeded())
                 logger.info(workerName+" successfully deployed.");
             else

diff --git a/src/main/java/io/github/areebgillani/boost/Booster.java b/src/main/java/io/github/areebgillani/boost/Booster.java
@@ -64,7 +64,7 @@ private void scanControllers() throws Exception {
         }
     }
 
-    private void scanServices() throws Exception {
+    private void scanServices() {
         Reflections reflections = new Reflections(basePackage);
         Set<Class<?>> services = reflections.getTypesAnnotatedWith(Service.class);
         Set<Class<?>> repos = reflections.getTypesAnnotatedWith(Repository.class);