use async test facilities properly (I hope)

Signed-off-by: Oded Arbel <oded@geek.co.il>
eclipse-vertx · Feb 10, 2017 · 1c3603e · 1c3603e
1 parent 017ed28
commit 1c3603e
Showing 1 changed file with 13 additions and 10 deletions.
diff --git a/src/test/java/io/vertx/test/core/VertxTest.java b/src/test/java/io/vertx/test/core/VertxTest.java
@@ -14,6 +14,7 @@
 
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicInteger;
 
 /**
@@ -97,16 +98,18 @@ public void close(Handler<AsyncResult<Void>> completionHandler) {
 
   @Test
   public void testClusterManagerFailure() throws Exception {
-		VertxOptions options = new VertxOptions().setClusterManager(new FakeClusterManager(){
-			@Override
-			public void join(Handler<AsyncResult<Void>> resultHandler) {
-				resultHandler.handle(Future.failedFuture(new Exception()));
-			}
-
-		});
-		Future<Vertx> f = Future.future();
-		Vertx.clusteredVertx(options, f.completer());
-		assertFalse(f.succeeded());
+    VertxOptions options = new VertxOptions().setClusterManager(new FakeClusterManager(){
+      @Override
+      public void join(Handler<AsyncResult<Void>> resultHandler) {
+        resultHandler.handle(Future.failedFuture(new Exception("joinfailure")));
+      }
+    });
+    Vertx.clusteredVertx(options, ar -> {
+      assertTrue(ar.failed());
+      assertEquals("joinfailure", ar.cause().getMessage());
+      testComplete();
+    });
+    await();
   }
 
 }