diff --git a/src/test/java/io/vertx/test/core/CreateVertxTest.java b/src/test/java/io/vertx/test/core/CreateVertxTest.java index 1a8bfe18eb6..e0059c65636 100644 --- 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 Tim Fox */ @@ -88,4 +89,20 @@ public void testCreateClusteredVertxAsyncDontSetClustered() { await(); } + + @Test + public void testCreateClusteredVertxAsyncDetectJoinFailure() { + VertxOptions options = new VertxOptions().setClusterManager(new FakeClusterManager(){ + @Override + public void join(Handler> 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 index 2bde5bb610a..b7e52bf6b04 100644 --- 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> completionHandler) { await(); } - @Test - public void testClusterManagerFailure() throws Exception { - VertxOptions options = new VertxOptions().setClusterManager(new FakeClusterManager(){ - @Override - public void join(Handler> resultHandler) { - resultHandler.handle(Future.failedFuture(new Exception("joinfailure"))); - } - }); - Vertx.clusteredVertx(options, ar -> { - assertTrue(ar.failed()); - assertEquals("joinfailure", ar.cause().getMessage()); - testComplete(); - }); - await(); - } - }