Adapt "kill leader" command to new return type

References rabbitmq/rabbitmq-server#3874
rabbitmq · Dec 10, 2021 · 67c1f36 · 67c1f36
1 parent 4956812
commit 67c1f36
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/test/java/com/rabbitmq/stream/Host.java b/src/test/java/com/rabbitmq/stream/Host.java
@@ -98,9 +98,9 @@ public static Process killConnection(String connectionName) throws IOException {
 
   public static Process killStreamLeaderProcess(String stream) throws IOException {
     return rabbitmqctl(
-        "eval 'exit(rabbit_stream_manager:lookup_leader(<<\"/\">>, <<\""
+        "eval 'case rabbit_stream_manager:lookup_leader(<<\"/\">>, <<\""
             + stream
-            + "\">>),kill).'");
+            + "\">>) of {ok, Pid} -> exit(Pid, kill); Pid -> exit(Pid, kill) end.'");
   }
 
   public static String rabbitmqctlCommand() {

diff --git a/src/test/java/com/rabbitmq/stream/impl/TestUtils.java b/src/test/java/com/rabbitmq/stream/impl/TestUtils.java
@@ -193,7 +193,7 @@ public void accept(Object o) {
         try {
           task.run(o);
         } catch (Exception e) {
-          throw new RuntimeException();
+          throw new RuntimeException(e);
         }
       }