Print quorum status in test

Author: acogoluegnes

src/test/java/com/rabbitmq/client/amqp/impl/Cli.java

@@ -50,7 +50,7 @@ private Cli() {}
   public static String rabbitmqctlCommand() {
     String rabbitmqCtl = System.getProperty("rabbitmqctl.bin");
     if (rabbitmqCtl == null) {
-      rabbitmqCtl = "DOCKER:rabbitmq";
+      rabbitmqCtl = DOCKER_PREFIX + "rabbitmq";
     }
     if (rabbitmqCtl.startsWith(DOCKER_PREFIX)) {
       String containerId = rabbitmqCtl.split(":")[1];
@@ -226,6 +226,19 @@ static void deleteQuorumQueueMember(String queue, String node) {
     rabbitmqQueues(" delete_member " + queue + " " + node);
   }
 
+  static String quorumStatus(String queue, String node) {
+    String containerId = DOCKER_NODES_TO_CONTAINERS.get(node);
+    Assert.notNull(containerId, "Container ID for node " + node);
+    String cmd = rabbitmqQueuesCommand();
+    for (String value : DOCKER_NODES_TO_CONTAINERS.values()) {
+      if (cmd.contains("docker exec " + value)) {
+        cmd = cmd.replace("docker exec " + value, "docker exec " + containerId);
+      }
+    }
+    System.out.println(cmd);
+    return executeCommand(cmd + " quorum_status --formatter erlang " + queue).output();
+  }
+
   static void addStreamMember(String stream, String node) {
     rabbitmqStreams(" add_replica " + stream + " " + node);
   }

src/test/java/com/rabbitmq/client/amqp/impl/ClusterTest.java

@@ -299,10 +299,12 @@ void publishConsumeQuorumQueueWhenLeaderChanges() {
   }
 
   @Test
-  void consumeFromQuorumQueueWhenLeaderIsPaused() {
+  void consumeFromQuorumQueueWhenLeaderIsPaused() throws InterruptedException {
     management.queue(q).type(QUORUM).declare();
     Management.QueueInfo queueInfo = queueInfo();
     String initialLeader = queueInfo.leader();
+    List<String> initialFollowers =
+        queueInfo.members().stream().filter(n -> !n.equals(initialLeader)).collect(toList());
     boolean nodePaused = false;
     try {
       AmqpConnection consumeConnection = connection(b -> b.affinity().queue(q).operation(CONSUME));
@@ -335,8 +337,6 @@ void consumeFromQuorumQueueWhenLeaderIsPaused() {
       assertThat(messageIds).containsExactlyInAnyOrder(1L);
       consumeSync.reset();
 
-      List<String> initialFollowers =
-          queueInfo.members().stream().filter(n -> !n.equals(initialLeader)).collect(toList());
       assertThat(initialFollowers).isNotEmpty();
 
       Cli.pauseNode(initialLeader);
@@ -384,6 +384,7 @@ void consumeFromQuorumQueueWhenLeaderIsPaused() {
       if (nodePaused) {
         Cli.unpauseNode(initialLeader);
       }
+      System.out.println(Cli.quorumStatus(q, initialFollowers.get(0)));
       management.queueDelete(q);
     }
   }