diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2020-03-07 20:26:16 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2020-03-07 20:26:16 +0300 |
| commit | 462f963cd4b6546d378d69eed2dabec7fd30251e (patch) | |
| tree | 11745476b5ad51a104c8a7f6568fdb7242de1865 | |
| parent | 93179acf580a69eb3e4fd6f6f7412a6a8d85caa6 (diff) | |
| download | rabbitmq-server-git-462f963cd4b6546d378d69eed2dabec7fd30251e.tar.gz | |
More logging
| -rw-r--r-- | src/rabbit_amqqueue.erl | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 6a5fd98775..f81c36829b 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -553,6 +553,7 @@ maybe_rebalance({true, Id}, Type, VhostSpec, QueueSpec) -> MaxQueuesDesired = (NumToRebalance div NumRunning) + Rem, Result = iterative_rebalance(ByNode, MaxQueuesDesired), global:del_lock(Id), + rabbit_log:info("Finished queue rebalance operation"), Result; maybe_rebalance(false, _Type, _VhostSpec, _QueueSpec) -> rabbit_log:warning("Queue rebalance operation is in progress, please wait."), |