@Test
public void failFastWhenAllServerWasDown() throws IOException {

  tccLoadBalanceSender.onConnected();
  await().atMost(2, TimeUnit.SECONDS).until(new Callable<Boolean>() {
    @Override
    public Boolean call() {
      return connected.get(8080).size() == 1 && connected.get(8090).size() == 1;
    }
  });
  assertThat((connected.get(8080).size() == 1 && connected.get(8090).size() == 1), is(true));
  for (Server each : servers.values()) {
    each.shutdownNow();
  }
  try {
    tccLoadBalanceSender.participationStart(participationStartedEvent);
  } catch (OmegaException ex) {
    assertThat(ex.getMessage().endsWith("all alpha server is down."), is(true));
  }
  for (Integer each : ports) {
    startServerOnPort(each);
  }
}