vertx: set number of workThreads using options

- improve bootstrapping of multiple servers when vertx is present
- fix vertx server name (was set to netty)

Author: jknack

jooby/src/main/java/io/jooby/Server.java

@@ -292,29 +292,31 @@ static Server loadServer(@NonNull ServerOptions options) {
     if (servers.isEmpty()) {
       throw new StartupException("Server not found.");
     }
-    var index = 0;
+    Predicate<Server> vertxServer = it -> it.getClass().getSimpleName().equals("VertxServer");
+    Server server;
     if (servers.size() > 1) {
-      boolean warn = true;
-      if (servers.size() == 2) {
-        // Must be Netty and Vertx
-        var supported = new HashSet<String>();
-        supported.add("NettyServer");
-        supported.add("VertxServer");
-        servers.stream().map(it -> it.getClass().getSimpleName()).forEach(supported::remove);
-        if (supported.isEmpty()) {
-          if (!servers.getFirst().getClass().getSimpleName().equals("VertxServer")) {
-            index = 1;
-          }
-          warn = false;
-        }
+      boolean warn;
+      // Must be Netty and Vertx
+      var supported =
+          servers.stream().map(it -> it.getClass().getSimpleName()).collect(Collectors.toSet());
+      supported.remove("NettyServer");
+      supported.remove("VertxServer");
+      if (!supported.isEmpty()) {
+        // Never choose vertx when there is any other implementation.
+        vertxServer = vertxServer.negate();
+        warn = true;
+      } else {
+        warn = false;
       }
+      server = servers.stream().filter(vertxServer).findFirst().orElse(servers.getFirst());
       if (warn) {
         var names = servers.stream().map(Server::getName).collect(Collectors.toList());
-        var log = LoggerFactory.getLogger(servers.get(index).getClass());
-        log.warn("Multiple servers found {}. Using: {}", names, names.get(index));
+        var log = LoggerFactory.getLogger(server.getClass());
+        log.warn("Multiple servers found {}. Using: {}", names, server.getName());
       }
+    } else {
+      server = servers.getFirst();
     }
-    var server = servers.get(index);
     return server.setOptions(options);
   }
 }

modules/jooby-vertx/src/main/java/io/jooby/vertx/VertxServer.java

@@ -32,6 +32,12 @@
  * @since 4.0.8
  */
 public class VertxServer extends NettyServer {
+  private static final String NAME = "vertx";
+
+  static {
+    System.setProperty("__server_.name", NAME);
+  }
+
   private Vertx vertx;
 
   /**
@@ -63,7 +69,11 @@ public Server init(@NonNull Jooby application) {
     if (this.vertx == null) {
       var nThreads = getOptions().getIoThreads();
       var options =
-          new VertxOptions().setPreferNativeTransport(true).setEventLoopPoolSize(nThreads);
+          new VertxOptions()
+              .setPreferNativeTransport(true)
+              .setEventLoopPoolSize(nThreads)
+              .setWorkerPoolSize(getOptions().getWorkerThreads());
+
       this.vertx = Vertx.vertx(options);
     }
 
@@ -74,7 +84,7 @@ public Server init(@NonNull Jooby application) {
 
   @Override
   public String getName() {
-    return "vertx";
+    return NAME;
   }
 
   @Nullable @Override

modules/jooby-vertx/src/main/java/module-info.java

@@ -12,6 +12,7 @@
   requires org.slf4j;
   requires static com.github.spotbugs.annotations;
   requires jakarta.inject;
+  requires io.netty.common;
 
   provides Server with
       VertxServer;