Upgrade to Vert.x 5

Author: tsegismont

README.adoc

@@ -27,7 +27,7 @@ The _backend_ consumes messages sent to the `greetings` address, generates a gre
 == What you need
 
 * A text editor or IDE
-* Java 8 higher
+* Java 11 higher
 * Maven or Gradle
 * https://kubernetes.io/docs/tasks/tools/install-minikube/[Minikube] or any Kubernetes cluster
 * `kubectl` command-line tool
@@ -46,7 +46,8 @@ Both projects depend on:
 * https://vertx.io/docs/vertx-health-check/java[`Vert.x Health Check`]
 
 Vert.x Infinispan is a cluster manager for Vert.x based on the https://infinispan.org/[Infinispan] in-memory key/value data store.
-In Vert.x a cluster manager is used for various functions. In particular it provides discovery/membership of cluster nodes and stores _event bus_ subscription data.
+In Vert.x a cluster manager is used for various functions.
+In particular, it provides discovery/membership of cluster nodes and stores _event bus_ subscription data.
 
 Vert.x Web is a set of building blocks which make it easy to create HTTP applications.
 
@@ -286,7 +287,7 @@ The _backend_:
 ----
 
 TIP: Take note of the `backend` HTTP server port.
-By default it uses a random port to avoid conflict with the `frontend` HTTP server.
+By default, it uses a random port to avoid conflict with the `frontend` HTTP server.
 
 NOTE: The following examples use the https://httpie.org/[HTTPie] command line HTTP client.
 Please refer to the https://httpie.org/doc#installation[installation] documentation if you don't have it installed on your system yet.
@@ -358,6 +359,7 @@ There are https://minikube.sigs.k8s.io/docs/handbook/pushing/[different ways] to
 In this document, we will push directly to the in-cluster Docker daemon.
 To do so, we must point our shell to Minikube's docker-daemon:
 
+[source,shell]
 ----
 eval $(minikube -p minikube docker-env)
 ----
@@ -394,12 +396,14 @@ IMPORTANT: The headless service must account for pods even when not ready (`publ
 
 Apply this configuration:
 
+[source,shell]
 ----
 kubectl apply -f headless-service.yml
 ----
 
-Then verify it was succesful:
+Then verify it was successful:
 
+[source,shell]
 ----
 kubectl get services clustered-app
 ----
@@ -440,12 +444,14 @@ endif::env-github[]
 
 Apply this configuration:
 
+[source,shell]
 ----
 kubectl apply -f frontend/deployment.yml
 ----
 
 Verify the pods have started successfully:
 
+[source,shell]
 ----
 kubectl get pods
 ----
@@ -474,12 +480,14 @@ endif::env-github[]
 
 Apply this configuration:
 
+[source,shell]
 ----
 kubectl apply -f frontend/service.yml
 ----
 
 Verify the service has been created successfully:
 
+[source,shell]
 ----
 kubectl get services frontend
 ----
@@ -493,6 +501,7 @@ frontend   LoadBalancer   10.106.16.88   <pending>     80:30729/TCP   62s
 
 If you use Minikube, open another terminal window and run:
 
+[source,shell]
 ----
 minikube tunnel
 ----
@@ -539,12 +548,14 @@ endif::env-github[]
 
 Apply this configuration:
 
+[source,shell]
 ----
 kubectl apply -f backend/deployment.yml
 ----
 
 Verify the pods have started successfully:
 
+[source,shell]
 ----
 kubectl get pods
 ----

backend/build.gradle.kts

@@ -8,31 +8,30 @@ repositories {
   mavenCentral()
 }
 
-val vertxVersion = "4.0.0"
+val vertxVersion = "5.0.0.CR2"
 val verticle = "io.vertx.howtos.cluster.BackendVerticle"
 
 dependencies {
+  implementation("io.vertx:vertx-launcher-application:${vertxVersion}")
   implementation("io.vertx:vertx-web:${vertxVersion}")
   implementation("io.vertx:vertx-infinispan:${vertxVersion}")
   implementation("io.vertx:vertx-health-check:${vertxVersion}")
-  implementation("ch.qos.logback:logback-classic:1.2.3")
+  implementation("ch.qos.logback:logback-classic:1.5.12")
 }
 
 application {
-  mainClassName = verticle
+  applicationDefaultJvmArgs =
+    listOf("-Djava.net.preferIPv4Stack=true", "-Dvertx.jgroups.config=default-configs/default-jgroups-udp.xml")
+  mainClass = verticle
 }
 
 jib {
   to {
     image = "clustering-kubernetes/backend"
   }
   container {
-    mainClass = "io.vertx.core.Launcher"
-    args = listOf("run", verticle, "-cluster")
+    mainClass = "io.vertx.launcher.application.VertxApplication"
+    args = listOf(verticle, "-cluster")
     ports = listOf("8080", "7800")
   }
 }
-
-tasks.wrapper {
-  gradleVersion = "5.2"
-}

backend/pom.xml

@@ -9,8 +9,6 @@
   <version>1.0-SNAPSHOT</version>
 
   <properties>
-    <maven.compiler.source>1.8</maven.compiler.source>
-    <maven.compiler.target>1.8</maven.compiler.target>
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     <verticle>io.vertx.howtos.cluster.BackendVerticle</verticle>
   </properties>
@@ -20,14 +18,18 @@
       <dependency>
         <groupId>io.vertx</groupId>
         <artifactId>vertx-stack-depchain</artifactId>
-        <version>4.0.0</version>
+        <version>5.0.0.CR2</version>
         <type>pom</type>
         <scope>import</scope>
       </dependency>
     </dependencies>
   </dependencyManagement>
 
   <dependencies>
+    <dependency>
+      <groupId>io.vertx</groupId>
+      <artifactId>vertx-launcher-application</artifactId>
+    </dependency>
     <dependency>
       <groupId>io.vertx</groupId>
       <artifactId>vertx-web</artifactId>
@@ -43,17 +45,35 @@
     <dependency>
       <groupId>ch.qos.logback</groupId>
       <artifactId>logback-classic</artifactId>
-      <version>1.2.3</version>
+      <version>1.5.12</version>
     </dependency>
   </dependencies>
 
   <build>
     <plugins>
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-compiler-plugin</artifactId>
+        <version>3.13.0</version>
+        <configuration>
+          <release>11</release>
+        </configuration>
+      </plugin>
       <plugin>
         <groupId>org.codehaus.mojo</groupId>
         <artifactId>exec-maven-plugin</artifactId>
-        <version>1.5.0</version>
+        <version>3.5.0</version>
         <configuration>
+          <systemProperties>
+            <systemProperty>
+              <key>java.net.preferIPv4Stack</key>
+              <value>true</value>
+            </systemProperty>
+            <systemProperty>
+              <key>vertx.jgroups.config</key>
+              <value>default-configs/default-jgroups-udp.xml</value>
+            </systemProperty>
+          </systemProperties>
           <mainClass>${verticle}</mainClass>
         </configuration>
       </plugin>
@@ -66,9 +86,8 @@
             <image>clustering-kubernetes/backend</image>
           </to>
           <container>
-            <mainClass>io.vertx.core.Launcher</mainClass>
+            <mainClass>io.vertx.launcher.application.VertxApplication</mainClass>
             <args>
-              <arg>run</arg>
               <arg>${verticle}</arg>
               <arg>-cluster</arg>
             </args>

backend/src/main/java/io/vertx/howtos/cluster/BackendVerticle.java

@@ -1,15 +1,16 @@
 package io.vertx.howtos.cluster;
 
 import io.vertx.core.*;
+import io.vertx.core.http.HttpServer;
 import io.vertx.ext.cluster.infinispan.ClusterHealthCheck;
-import io.vertx.ext.healthchecks.HealthCheckHandler;
 import io.vertx.ext.healthchecks.HealthChecks;
 import io.vertx.ext.healthchecks.Status;
 import io.vertx.ext.web.Router;
+import io.vertx.ext.web.healthchecks.HealthCheckHandler;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-public class BackendVerticle extends AbstractVerticle {
+public class BackendVerticle extends VerticleBase {
 
   private static final Logger log = LoggerFactory.getLogger(BackendVerticle.class);
 
@@ -20,23 +21,25 @@ public class BackendVerticle extends AbstractVerticle {
 
   // tag::start[]
   @Override
-  public void start() {
-    registerConsumer();
+  public Future<?> start() {
+    Future<Void> registration = registerConsumer();
 
     Router router = setupRouter();
 
-    vertx.createHttpServer()
+    Future<HttpServer> httpServer = vertx.createHttpServer()
       .requestHandler(router)
       .listen(HTTP_PORT)
       .onSuccess(server -> log.info("Server started and listening on port {}", server.actualPort()));
+
+    return Future.join(registration, httpServer);
   }
   // end::start[]
 
   // tag::consumer[]
-  private void registerConsumer() {
-    vertx.eventBus().<String>consumer("greetings", msg -> {
+  private Future<Void> registerConsumer() {
+    return vertx.eventBus().<String>consumer("greetings", msg -> {
       msg.reply(String.format("Hello %s from %s", msg.body(), POD_NAME));
-    });
+    }).completion();
   }
   // end::consumer[]
 
@@ -57,7 +60,7 @@ private Router setupRouter() {
   public static void main(String[] args) {
     Vertx.clusteredVertx(new VertxOptions())
       .compose(vertx -> vertx.deployVerticle(new BackendVerticle()))
-      .onFailure(Throwable::printStackTrace);
+      .await();
   }
   // end::main[]
 }

frontend/build.gradle.kts

@@ -8,31 +8,30 @@ repositories {
   mavenCentral()
 }
 
-val vertxVersion = "4.0.0"
+val vertxVersion = "5.0.0.CR2"
 val verticle = "io.vertx.howtos.cluster.FrontendVerticle"
 
 dependencies {
+  implementation("io.vertx:vertx-launcher-application:${vertxVersion}")
   implementation("io.vertx:vertx-web:${vertxVersion}")
   implementation("io.vertx:vertx-infinispan:${vertxVersion}")
   implementation("io.vertx:vertx-health-check:${vertxVersion}")
-  implementation("ch.qos.logback:logback-classic:1.2.3")
+  implementation("ch.qos.logback:logback-classic:1.5.12")
 }
 
 application {
-  mainClassName = verticle
+  applicationDefaultJvmArgs =
+    listOf("-Djava.net.preferIPv4Stack=true", "-Dvertx.jgroups.config=default-configs/default-jgroups-udp.xml")
+  mainClass = verticle
 }
 
 jib {
   to {
     image = "clustering-kubernetes/frontend"
   }
   container {
-    mainClass = "io.vertx.core.Launcher"
-    args = listOf("run", verticle, "-cluster")
+    mainClass = "io.vertx.launcher.application.VertxApplication"
+    args = listOf(verticle, "-cluster")
     ports = listOf("8080", "7800")
   }
 }
-
-tasks.wrapper {
-  gradleVersion = "5.2"
-}