public void runSimpleProcedure(String... members) throws Exception {
    coordinator = buildNewCoordinator();
    Procedure task = new Procedure(coordinator, monitor, WAKE_FREQUENCY, TIMEOUT, procName,
      procData, Arrays.asList(members));
    final Procedure spy = spy(task);
    runCoordinatedProcedure(spy, members);
  }
Check handling a connection failure correctly if we get it during the barrier phase
hbase-server/src/test/java/org/apache/hadoop/hbase/procedure/TestProcedureCoordinator.java