Use rabbitmqctl to start/stop rabbit application on node

Instead of using make. This way only HA tests need make to run.

(cherry picked from commit 9177ae2)

Author: acogoluegnes

src/test/java/com/rabbitmq/client/test/BrokerTestCase.java

@@ -143,8 +143,8 @@ protected void restart()
 
     protected void bareRestart()
             throws IOException {
-        Host.invokeMakeTarget(
-          "stop-rabbit-on-node start-rabbit-on-node");
+        Host.stopRabbitOnNode();
+        Host.startRabbitOnNode();
     }
 
     public void openConnection()

src/test/java/com/rabbitmq/client/test/server/DeadLetterExchangeDurable.java

@@ -58,9 +58,9 @@ protected void releaseResources() throws IOException {
         }
 
         closeConnection();
-        Host.invokeMakeTarget("stop-rabbit-on-node");
+        Host.stopRabbitOnNode();
         Thread.sleep(5000);
-        Host.invokeMakeTarget("start-rabbit-on-node");
+        Host.startRabbitOnNode();
         openConnection();
         openChannel();
 

src/test/java/com/rabbitmq/tools/Host.java

@@ -24,7 +24,10 @@
 import java.util.ArrayList;
 import java.util.List;
 
+import com.rabbitmq.client.Connection;
+import com.rabbitmq.client.ConnectionFactory;
 import com.rabbitmq.client.impl.NetworkConnection;
+import com.rabbitmq.client.test.TestUtils;
 
 public class Host {
 
@@ -128,9 +131,34 @@ public static Process invokeMakeTarget(String command) throws IOException {
                               " " + command);
     }
 
-    public static String systemHostname() throws IOException {
-        Process process = executeCommandIgnoringErrors("hostname");
-        return capture(process.getInputStream()).trim();
+    public static void startRabbitOnNode() throws IOException {
+        rabbitmqctl("eval 'rabbit:start().'");
+        tryConnectFor(10_000);
+    }
+
+    public static void stopRabbitOnNode() throws IOException {
+        rabbitmqctl("eval 'rabbit:stop().'");
+    }
+
+    public static void tryConnectFor(int timeoutInMs) throws IOException {
+        int waitTime = 100;
+        int totalWaitTime = 0;
+        while (totalWaitTime <= timeoutInMs) {
+            try {
+                Thread.sleep(waitTime);
+            } catch (InterruptedException e) {
+                throw new RuntimeException(e);
+            }
+            totalWaitTime += waitTime;
+            ConnectionFactory connectionFactory = TestUtils.connectionFactory();
+            try (Connection ignored = connectionFactory.newConnection()) {
+                return;
+
+            } catch (Exception e) {
+                // retrying
+            }
+        }
+        throw new IOException("Could not connect to broker for " + timeoutInMs + " ms");
     }
 
     public static String makeCommand()