Include queue name on log message

This commit is contained in:
dcorbacho 2021-07-06 13:48:40 +02:00
parent e58ee79b4a
commit 6610c3443d
1 changed files with 4 additions and 3 deletions

View File

@ -850,7 +850,8 @@ make_ra_conf(Node, Nodes) ->
machine => {module, ?MODULE, #{}},
ra_event_formatter => Formatter}.
filter_command(_Meta, {delete_replica, _, #{node := Node}}, #stream{members = Members0}) ->
filter_command(_Meta, {delete_replica, _, #{node := Node}}, #stream{id = StreamId,
members = Members0}) ->
Members = maps:filter(fun(_, #member{target = S}) when S =/= deleted ->
true;
(_, _) ->
@ -859,8 +860,8 @@ filter_command(_Meta, {delete_replica, _, #{node := Node}}, #stream{members = Me
case maps:size(Members) =< 1 of
true ->
rabbit_log:warning(
"~s failed to delete ~p replica, last cluster member",
[?MODULE, Node]),
"~s failed to delete ~p replica for stream queue ~s, last cluster member",
[?MODULE, Node, StreamId]),
{error, last_stream_member};
false ->
ok