Added unit test for detecting cluster failure

Signed-off-by: Oded Arbel <oded@geek.co.il>
eclipse-vertx · Feb 10, 2017 · 017ed28 · 017ed28
1 parent 5671d7c
commit 017ed28
Showing 1 changed file with 26 additions and 5 deletions.
diff --git a/src/test/java/io/vertx/test/core/VertxTest.java b/src/test/java/io/vertx/test/core/VertxTest.java
@@ -1,13 +1,19 @@
 package io.vertx.test.core;
 
-import io.vertx.core.AsyncResult;
-import io.vertx.core.Closeable;
-import io.vertx.core.Future;
-import io.vertx.core.Handler;
-import io.vertx.core.Vertx;
+import io.vertx.core.*;
 import io.vertx.core.impl.VertxInternal;
+import io.vertx.core.shareddata.AsyncMap;
+import io.vertx.core.shareddata.Counter;
+import io.vertx.core.shareddata.Lock;
+import io.vertx.core.spi.cluster.AsyncMultiMap;
+import io.vertx.core.spi.cluster.ClusterManager;
+import io.vertx.core.spi.cluster.NodeListener;
+import io.vertx.test.fakecluster.FakeClusterManager;
+
 import org.junit.Test;
 
+import java.util.List;
+import java.util.Map;
 import java.util.concurrent.atomic.AtomicInteger;
 
 /**
@@ -88,4 +94,19 @@ 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()));
+			}
+
+		});
+		Future<Vertx> f = Future.future();
+		Vertx.clusteredVertx(options, f.completer());
+		assertFalse(f.succeeded());
+  }
+
 }