diff options
| author | kjnilsson <knilsson@pivotal.io> | 2019-02-19 09:29:38 +0000 |
|---|---|---|
| committer | kjnilsson <knilsson@pivotal.io> | 2019-02-19 09:29:38 +0000 |
| commit | ed13f5398197f5ff735c2c1b97519ecc0d22dd6f (patch) | |
| tree | 31c89e8f707334fd49bc8ffc75148f8fc860d6c9 /src | |
| parent | 8e6701b310679eb1b05e4a80ab42e6e1b1af0768 (diff) | |
| download | rabbitmq-server-git-ed13f5398197f5ff735c2c1b97519ecc0d22dd6f.tar.gz | |
Add cluster size to shrink result
Also add rabbitmq-queue integration test for shrink command.
[#162782789]
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_quorum_queue.erl | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/rabbit_quorum_queue.erl b/src/rabbit_quorum_queue.erl index fd57608515..3ca607689c 100644 --- a/src/rabbit_quorum_queue.erl +++ b/src/rabbit_quorum_queue.erl @@ -740,13 +740,14 @@ shrink_all(Node) -> QName = amqqueue:get_name(Q), rabbit_log:info("~s: Removing member ~w", [rabbit_misc:rs(QName), Node]), + Size = length(amqqueue:get_quorum_nodes(Q)), case delete_member(Q, Node) of ok -> - {QName, ok}; + {QName, {ok, Size-1}}; {error, Err} -> rabbit_log:warning("~s: Failed to remove member ~w, Error ~w", [rabbit_misc:rs(QName), Node, Err]), - {QName, {error, Err}} + {QName, {error, Size, Err}} end end || Q <- rabbit_amqqueue:list(), amqqueue:get_type(Q) == quorum, |