Test: shutdown of test cluster

src/main/java/io/crate/testing/CrateTestCluster.java

@@ -442,6 +442,7 @@ public void after() {
         CrateTestServer[] localServers = serversSafe();
         for (CrateTestServer server : localServers) {
             server.after();
+            assert !server.isAlive();
         }
         try {
             removeCrateDir();

src/main/java/io/crate/testing/CrateTestServer.java

@@ -135,6 +135,13 @@ protected void after() {
         }
     }
 
+    public Boolean isAlive() {
+        if (crateProcess == null) {
+            return false;
+        }
+        return crateProcess.isAlive();
+    }
+
     private long startCrateAsDaemon() throws IOException, InterruptedException {
         Map<String, Object> settingsMap = prepareSettings();
 

src/test/java/io/crate/testing/ShutdownTest.java

@@ -0,0 +1,31 @@
+import io.crate.testing.CrateTestCluster;
+import org.junit.AfterClass;
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+import static org.hamcrest.MatcherAssert.assertThat;
+import static org.hamcrest.CoreMatchers.is;
+
+public class ShutdownTest {
+
+    private static CrateTestCluster testCluster;
+
+    @BeforeClass
+    public static void setUpClusterAndAgent() throws Throwable {
+        testCluster = CrateTestCluster.fromURL("https://cdn.crate.io/downloads/releases/nightly/crate-latest.tar.gz")
+                .keepWorkingDir(false)
+                .build();
+        testCluster.before();
+    }
+
+    @AfterClass
+    public static void tearDown() {
+        // if cluster cannot be terminated, an expection will be thrown
+        testCluster.after();
+    }
+
+    @Test
+    public void test() {
+        assertThat(true, is(true));
+    }
+}