diff options
| author | Michael Klishin <mklishin@pivotal.io> | 2019-02-21 01:10:35 +0300 |
|---|---|---|
| committer | Michael Klishin <mklishin@pivotal.io> | 2019-02-21 01:10:35 +0300 |
| commit | aee6ef638e9e25d5e687aa937fe8c93a2410ed3e (patch) | |
| tree | 1c50cfe6bd2484e3003de14eb7e50d15a82eae38 | |
| parent | cecdc6e90cc4af58ca43f1da4e33e68f04a0f118 (diff) | |
| download | rabbitmq-server-git-aee6ef638e9e25d5e687aa937fe8c93a2410ed3e.tar.gz | |
Quorum queue shrinking/growing: improve log messages
| -rw-r--r-- | src/rabbit_quorum_queue.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_quorum_queue.erl b/src/rabbit_quorum_queue.erl index 5d28ef506a..0ef6d88086 100644 --- a/src/rabbit_quorum_queue.erl +++ b/src/rabbit_quorum_queue.erl @@ -745,14 +745,14 @@ delete_member(Q, Node) when ?amqqueue_is_quorum(Q) -> shrink_all(Node) -> [begin QName = amqqueue:get_name(Q), - rabbit_log:info("~s: Removing member ~w", + rabbit_log:info("~s: removing member (replica) on node ~w", [rabbit_misc:rs(QName), Node]), Size = length(amqqueue:get_quorum_nodes(Q)), case delete_member(Q, Node) of ok -> {QName, {ok, Size-1}}; {error, Err} -> - rabbit_log:warning("~s: Failed to remove member ~w, Error ~w", + rabbit_log:warning("~s: failed to remove member (replica) on node ~w, error: ~w", [rabbit_misc:rs(QName), Node, Err]), {QName, {error, Size, Err}} end @@ -768,14 +768,14 @@ grow(Node, VhostSpec, QueueSpec, Strategy) -> [begin Size = length(amqqueue:get_quorum_nodes(Q)), QName = amqqueue:get_name(Q), - rabbit_log:info("~s: Adding member ~w", + rabbit_log:info("~s: adding a new member (replica) on node ~w", [rabbit_misc:rs(QName), Node]), case add_member(Q, Node) of ok -> {QName, {ok, Size + 1}}; {error, Err} -> rabbit_log:warning( - "~s: Failed to add member ~w, Error ~w", + "~s: failed to add member (replica) on node ~w, error: ~w", [rabbit_misc:rs(QName), Node, Err]), {QName, {error, Size, Err}} end |