summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/rabbit_multi.erl9
1 files changed, 4 insertions, 5 deletions
diff --git a/src/rabbit_multi.erl b/src/rabbit_multi.erl
index 4d00e660..8a6bfbe0 100644
--- a/src/rabbit_multi.erl
+++ b/src/rabbit_multi.erl
@@ -285,11 +285,10 @@ rotate_logs([], _, _) -> ok;
rotate_logs([{Node, _} | Rest], BinarySuffix, RpcTimeout) ->
io:format("Rotating logs for node ~p", [Node]),
case rpc:call(Node, rabbit, rotate_logs, [BinarySuffix], RpcTimeout) of
- {badrpc, Error} -> io:format(": ~p.~n", [Error]),
- throw(rotate_logs_failed);
- ok -> io:format(": ok.~n", []),
- rotate_logs(Rest, BinarySuffix, RpcTimeout)
- end.
+ {badrpc, Error} -> io:format(": ~p.~n", [Error]);
+ ok -> io:format(": ok.~n", [])
+ end,
+ rotate_logs(Rest, BinarySuffix, RpcTimeout).
call_all_nodes(Func) ->
case read_pids_file() of