move test of failed cluster join according to comments by tsegismont

Signed-off-by: Oded Arbel <oded@geek.co.il>
eclipse-vertx · Feb 10, 2017 · 37fcfa1 · 37fcfa1
1 parent 1c3603e
commit 37fcfa1
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 18 deletions.
diff --git a/src/test/java/io/vertx/test/core/CreateVertxTest.java b/src/test/java/io/vertx/test/core/CreateVertxTest.java
@@ -16,10 +16,11 @@
 
 package io.vertx.test.core;
 
-import io.vertx.core.Vertx;
-import io.vertx.core.VertxOptions;
 import org.junit.Test;
 
+import io.vertx.core.*;
+import io.vertx.test.fakecluster.FakeClusterManager;
+
 /**
  * @author <a href="http://tfox.org">Tim Fox</a>
  */
@@ -88,4 +89,20 @@ public void testCreateClusteredVertxAsyncDontSetClustered() {
     await();
   }
 
+
+  @Test
+  public void testCreateClusteredVertxAsyncDetectJoinFailure() {
+    VertxOptions options = new VertxOptions().setClusterManager(new FakeClusterManager(){
+      @Override
+      public void join(Handler<AsyncResult<Void>> resultHandler) {
+        resultHandler.handle(Future.failedFuture(new Exception("joinfailure")));
+      }
+    });
+    clusteredVertx(options, ar -> {
+      assertTrue(ar.failed());
+      assertEquals("joinfailure", ar.cause().getMessage());
+      testComplete();
+    });
+    await();
+  }
 }
diff --git a/src/test/java/io/vertx/test/core/VertxTest.java b/src/test/java/io/vertx/test/core/VertxTest.java
@@ -96,20 +96,4 @@ public void close(Handler<AsyncResult<Void>> completionHandler) {
     await();
   }
 
-  @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("joinfailure")));
-      }
-    });
-    Vertx.clusteredVertx(options, ar -> {
-      assertTrue(ar.failed());
-      assertEquals("joinfailure", ar.cause().getMessage());
-      testComplete();
-    });
-    await();
-  }
-
 }