Use GitHub Actions for CI

Author: acogoluegnes

.github/workflows/test-linux.yml

@@ -0,0 +1,30 @@
+name: Build (Linux)
+
+on:
+  push:
+    branches:
+      - master
+  pull_request:
+    branches:
+      - master
+
+jobs:
+  build:
+    runs-on: ubuntu-18.04
+
+    services:
+      rabbitmq:
+        image: rabbitmq:3.8
+        ports:
+          - 5672:5672
+
+    steps:
+      - uses: actions/checkout@v2
+
+      - name: Set up JDK 1.8
+        uses: actions/setup-java@v1
+        with:
+          java-version: 1.8
+
+      - name: Test
+        run: ./mvnw check -Drabbitmqctl.bin=DOCKER:${{job.services.rabbitmq.id}}

.travis.yml

@@ -1,6 +1,6 @@
 ## RabbitMQ Performance Testing Tool
 
-[![Travis CI](https://travis-ci.org/rabbitmq/rabbitmq-jms-client.svg?branch=master)](https://travis-ci.org/rabbitmq/rabbitmq-perf-test)
+[![Build Status](https://github.com/rabbitmq/rabbitmq-perf-test/workflows/Build%20(Linux)/badge.svg?branch=master)](https://github.com/rabbitmq/rabbitmq-perf-test/actions?query=workflow%3A%22Build+%28Linux%29%22+branch%3Amaster)
 
 This repository contains source code of the RabbitMQ Performance Testing Tool.
 The client is maintained by the [RabbitMQ team at VMware](https://github.com/rabbitmq/).
@@ -56,17 +56,36 @@ See [CONTRIBUTING.md](./CONTRIBUTING.md) for an overview of the development proc
 To build the JAR file:
 
 ```
-./mvnw clean package
+./mvnw clean package -Dmaven.test.skip
 ```
 
 Files are then in the `target` directory.
 
 To build the JAR file, source and binary distributions:
 
 ```
-./mvnw clean package -P assemblies -Dgpg.skip=true
+./mvnw clean package -P assemblies -Dgpg.skip=true -Dmaven.test.skip
 ```
 
+### Running tests
+
+The test suite needs to execute `rabbitmqctl` to test connection recovery. You
+can specify the path to `rabbitmqctl` like the following:
+
+    ./mvnw clean verify -Drabbitmqctl.bin=/path/to/rabbitmqctl
+
+You need a local running RabbitMQ instance.
+
+### Running tests with Docker
+
+Start a RabbitMQ container:
+
+    docker run -it --rm --name rabbitmq -p 5672:5672 rabbitmq:3.8
+
+Run the test suite:
+
+    ./mvnw clean verify -Drabbitmqctl.bin=DOCKER:rabbitmq
+
 Files are then in the `target` directory.
 
 ## Maven Artifact

README.md

@@ -15,8 +15,6 @@
 
 package com.rabbitmq.perf.it;
 
-import com.rabbitmq.client.impl.NetworkConnection;
-
 import java.io.BufferedReader;
 import java.io.IOException;
 import java.io.InputStream;
@@ -96,10 +94,21 @@ public static void startBrokerApp() throws IOException {
     }
 
     public static String rabbitmqctlCommand() {
-        return System.getProperty("rabbitmqctl.bin");
+        String rabbitmqCtl = System.getProperty("rabbitmqctl.bin");
+        if (rabbitmqCtl == null) {
+            throw new IllegalStateException("Please define the rabbitmqctl.bin system property");
+        }
+        if (rabbitmqCtl.startsWith("DOCKER:")) {
+            String containerId = rabbitmqCtl.split(":")[1];
+            return "docker exec " + containerId + " rabbitmqctl";
+        } else if ("sudo_rabbitmqctl".equals(rabbitmqCtl)) {
+            return "sudo rabbitmqctl";
+        } else {
+            return rabbitmqCtl;
+        }
     }
 
-    public static void closeConnection(String pid) throws IOException {
+    private static void closeConnection(String pid) throws IOException {
         rabbitmqctl("close_connection '" + pid + "' 'Closed via rabbitmqctl'");
     }
 
@@ -109,24 +118,21 @@ public static void closeAllConnections(List<ConnectionInfo> connectionInfos) thr
         }
     }
 
-    public static void closeAllConnections() throws IOException {
-        closeAllConnections(listConnections());
-    }
-
     public static List<ConnectionInfo> listConnections() throws IOException {
         String output = capture(rabbitmqctl("list_connections -q pid peer_port").getInputStream());
         // output (header line presence depends on broker version):
         // pid	peer_port
         // <[email protected]>	58713
         String[] allLines = output.split("\n");
 
-        List<ConnectionInfo> result = new ArrayList<ConnectionInfo>();
+        List<ConnectionInfo> result = new ArrayList<>();
         for (String line : allLines) {
             // line: <[email protected]>	58713
             String[] columns = line.split("\t");
             // can be also header line, so ignoring NumberFormatException
             try {
-                result.add(new ConnectionInfo(columns[0], Integer.valueOf(columns[1])));
+                Integer.valueOf(columns[1]);
+                result.add(new ConnectionInfo(columns[0]));
             } catch (NumberFormatException e) {
                 // OK
             }
@@ -160,33 +166,17 @@ public static List<String> listQueues() throws IOException {
                 .collect(Collectors.toList());
     }
 
-    private static Host.ConnectionInfo findConnectionInfoFor(List<ConnectionInfo> xs, NetworkConnection c) {
-        Host.ConnectionInfo result = null;
-        for (Host.ConnectionInfo ci : xs) {
-            if (c.getLocalPort() == ci.getPeerPort()) {
-                result = ci;
-                break;
-            }
-        }
-        return result;
-    }
-
     public static class ConnectionInfo {
 
         private final String pid;
-        private final int peerPort;
 
-        public ConnectionInfo(String pid, int peerPort) {
+        public ConnectionInfo(String pid) {
             this.pid = pid;
-            this.peerPort = peerPort;
         }
 
         public String getPid() {
             return pid;
         }
 
-        public int getPeerPort() {
-            return peerPort;
-        }
     }
 }