summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authordcorbacho <dparracorbacho@piotal.io>2021-10-13 15:22:45 +0200
committerdcorbacho <dparracorbacho@piotal.io>2021-10-14 11:14:41 +0200
commit5f1ec61b503735220501c0c717a17c098961b3e8 (patch)
tree92cc97341b4aaaed0d36bf0249db717e0556d504
parent84b0ade5de5c95246b7c684402d1aebcc65ad71e (diff)
downloadrabbitmq-server-git-5f1ec61b503735220501c0c717a17c098961b3e8.tar.gz
Fix stream coordinator log messagefix-stream-coordinator-log
-rw-r--r--deps/rabbit/src/rabbit_stream_coordinator.erl4
1 files changed, 2 insertions, 2 deletions
diff --git a/deps/rabbit/src/rabbit_stream_coordinator.erl b/deps/rabbit/src/rabbit_stream_coordinator.erl
index f32d6de61d..4a689d2df8 100644
--- a/deps/rabbit/src/rabbit_stream_coordinator.erl
+++ b/deps/rabbit/src/rabbit_stream_coordinator.erl
@@ -255,8 +255,8 @@ process_command([], _Cmd) ->
process_command([Server | Servers], Cmd) ->
case ra:process_command(Server, Cmd, ?CMD_TIMEOUT) of
{timeout, _} ->
- rabbit_log:warning("Coordinator timeout on server ~s when processing command ~W",
- [Server, element(1, Cmd), 10]),
+ rabbit_log:warning("Coordinator timeout on server ~w when processing command ~W",
+ [element(2, Server), element(1, Cmd), 10]),
process_command(Servers, Cmd);
{error, noproc} ->
process_command(Servers, Cmd);