summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMichael Klishin <klishinm@vmware.com>2022-10-25 14:46:34 +0400
committerGitHub <noreply@github.com>2022-10-25 14:46:34 +0400
commitfac5a9aa48eac7c01f88901b397933c9ef2a8ef1 (patch)
tree2340ded71a57b6e8acaf8d77adda63008ebcd5ba
parent5b9941baf660e9130019e7b41c13e16b8a21bb21 (diff)
parentfdad0e99b199c1d936dba0cc023f0f0c7e8379db (diff)
downloadrabbitmq-server-git-fac5a9aa48eac7c01f88901b397933c9ef2a8ef1.tar.gz
Merge pull request #6240 from rabbitmq/stream-coord-log-rewords
Stream coordinator: reword some log messages
-rw-r--r--deps/rabbit/src/rabbit_stream_coordinator.erl6
1 files changed, 3 insertions, 3 deletions
diff --git a/deps/rabbit/src/rabbit_stream_coordinator.erl b/deps/rabbit/src/rabbit_stream_coordinator.erl
index d10aa1c7b2..8e5414f7f5 100644
--- a/deps/rabbit/src/rabbit_stream_coordinator.erl
+++ b/deps/rabbit/src/rabbit_stream_coordinator.erl
@@ -1753,7 +1753,7 @@ fail_active_actions(Streams, Exclude) ->
end, Members),
case Mnesia of
{updating, E} ->
- rabbit_log:debug("~ts: schema database action failed, will have to retry. "
+ rabbit_log:debug("~ts: failing stale action to trigger retry. "
"Stream ID: ~ts, node: ~w, action: ~w",
[?MODULE, Id, node(), updating_mnesia]),
send_self_command({action_failed, Id,
@@ -1774,9 +1774,9 @@ fail_action(_StreamId, #member{current = undefined}) ->
fail_action(StreamId, #member{role = {_, E},
current = {Action, Idx},
node = Node}) ->
- rabbit_log:debug("~ts: schema database action failed, will have to retry. "
+ rabbit_log:debug("~ts: failing stale action to trigger retry. "
"Stream ID: ~ts, node: ~w, action: ~w",
- [?MODULE, StreamId, node(), updating_mnesia]),
+ [?MODULE, StreamId, node(), Action]),
%% if we have an action send failure message
send_self_command({action_failed, StreamId,
#{action => Action,