✅ Terracotta-OSS#191: Failover Galvan tests

mathieucarbou · Dec 16, 2016 · 0a69901 · 0a69901
1 parent 6c395cc
commit 0a69901
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/...tegration-tests/src/test/java/org/terracotta/management/integration/tests/FailoverIT.java b/...tegration-tests/src/test/java/org/terracotta/management/integration/tests/FailoverIT.java
@@ -15,7 +15,6 @@
  */
 package org.terracotta.management.integration.tests;
 
-import org.junit.Ignore;
 import org.junit.Test;
 import org.terracotta.management.model.cluster.Cluster;
 import org.terracotta.management.model.cluster.Server;
@@ -32,7 +31,6 @@
 /**
  * @author Mathieu Carbou
  */
-@Ignore // TODO activate
 public class FailoverIT extends AbstractHATest {
 
   @Test
@@ -47,16 +45,22 @@ public void failover_management() throws Exception {
     tmsAgentService.readMessages();
 
     // kill active - passive should take the active role
+    System.out.printf("==> terminateActive()");
     voltron.getClusterControl().terminateActive();
+    System.out.printf("==> waitForActive()");
     voltron.getClusterControl().waitForActive();
 
+    System.out.printf("==> readTopology()");
     cluster = tmsAgentService.readTopology();
     Server newActive = cluster.serverStream().filter(Server::isActive).findFirst().get();
     assertThat(newActive.getState(), equalTo(Server.State.ACTIVE));
     assertThat(newActive.getServerName(), equalTo(passive.getServerName()));
 
     // read messages
     List<Message> messages = tmsAgentService.readMessages();
+
+    messages.forEach(System.out::println);
+
     assertThat(messages.size(), equalTo(3));
 
     List<ContextualNotification> notifs = messages.stream()