Avoid concurrent modification of vertx list to close

tsegismont · Sep 17, 2024 · ecd187c · ecd187c
1 parent 0ec29db
commit ecd187c
Showing 1 changed file with 7 additions and 12 deletions.
diff --git a/vertx-core/src/test/java/io/vertx/tests/eventbus/ClusterHostTest.java b/vertx-core/src/test/java/io/vertx/tests/eventbus/ClusterHostTest.java
@@ -11,6 +11,7 @@
 
 package io.vertx.tests.eventbus;
 
+import io.vertx.core.Vertx;
 import io.vertx.core.VertxOptions;
 import io.vertx.core.impl.Utils;
 import io.vertx.test.core.VertxTestBase;
@@ -33,10 +34,8 @@ public String clusterHost() {
         return "127.0.0.3";
       }
     };
-    clusteredVertx(new VertxOptions(), clusterManager)
-      .onComplete(onSuccess(clusteredVertx -> {
-        assertEquals("127.0.0.3", clusterManager.getNodeInfo().host());
-      }));
+    Vertx clusteredVertx = clusteredVertx(new VertxOptions(), clusterManager).await();
+    assertEquals("127.0.0.3", clusterManager.getNodeInfo().host());
   }
 
   @Test
@@ -52,10 +51,8 @@ public String clusterPublicHost() {
         return "127.0.0.3";
       }
     };
-    clusteredVertx(new VertxOptions(), clusterManager)
-      .onComplete(onSuccess(clusteredVertx -> {
-        assertEquals("127.0.0.3", clusterManager.getNodeInfo().host());
-      }));
+    Vertx clusteredVertx = clusteredVertx(new VertxOptions(), clusterManager).await();
+    assertEquals("127.0.0.3", clusterManager.getNodeInfo().host());
   }
 
   @Test
@@ -73,9 +70,7 @@ public String clusterPublicHost() {
     };
     VertxOptions options = new VertxOptions();
     options.getEventBusOptions().setHost("127.0.0.4");
-    clusteredVertx(options, clusterManager)
-      .onComplete(onSuccess(clusteredVertx -> {
-        assertEquals("127.0.0.4", clusterManager.getNodeInfo().host());
-      }));
+    Vertx clusteredVertx = clusteredVertx(options, clusterManager).await();
+    assertEquals("127.0.0.4", clusterManager.getNodeInfo().host());
   }
 }