Display Khepri information

Author: acogoluegnes

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

@@ -87,6 +87,10 @@ static String rabbitmqStreamsCommand() {
     return rabbitmqctl.substring(0, lastIndex) + "rabbitmq-streams";
   }
 
+  static ProcessState rabbitmqctl(String command, String node) {
+    return executeCommand(replaceContainerId(rabbitmqctlCommand(), node) + " " + command);
+  }
+
   static ProcessState rabbitmqctl(String command) {
     return executeCommand(rabbitmqctlCommand() + " " + command);
   }
@@ -227,15 +231,20 @@ static void deleteQuorumQueueMember(String queue, String node) {
   }
 
   static String quorumStatus(String queue, String node) {
+    String cmd = replaceContainerId(rabbitmqQueuesCommand(), node);
+    return executeCommand(cmd + " quorum_status --formatter erlang " + queue).output();
+  }
+
+  private static String replaceContainerId(String cmd, 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);
+        break;
       }
     }
-    return executeCommand(cmd + " quorum_status --formatter erlang " + queue).output();
+    return cmd;
   }
 
   static void addStreamMember(String stream, String node) {

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

@@ -381,6 +381,9 @@ void consumeFromQuorumQueueWhenLeaderIsPaused() throws InterruptedException {
                   + "queue info "
                   + mgmt.queueInfo(q));
     } finally {
+      System.out.println(
+          Cli.rabbitmqctl("eval 'khepri:info(rabbitmq_metadata).'", initialFollowers.get(0))
+              .output());
       System.out.println(Cli.quorumStatus(q, initialFollowers.get(0)));
       if (nodePaused) {
         Cli.unpauseNode(initialLeader);