diff options
| -rw-r--r-- | deps/rabbit/src/rabbit_amqqueue.erl | 2 | ||||
| -rw-r--r-- | deps/rabbitmq_cli/lib/rabbitmq/cli/queues/commands/rebalance_command.ex | 14 |
2 files changed, 12 insertions, 4 deletions
diff --git a/deps/rabbit/src/rabbit_amqqueue.erl b/deps/rabbit/src/rabbit_amqqueue.erl index 5536b35414..a8422b3da3 100644 --- a/deps/rabbit/src/rabbit_amqqueue.erl +++ b/deps/rabbit/src/rabbit_amqqueue.erl @@ -498,7 +498,7 @@ maybe_migrate(ByNode, _, []) -> ?amqqueue_is_classic(Q) end, V), [[{<<"Node name">>, K}, {<<"Number of quorum queues">>, length(QQs)}, - {<<"Number of classic queues">>, length(CQs)}] | Acc] + {<<"Number of replicated classic queues">>, length(CQs)}] | Acc] end, [], ByNode)}; maybe_migrate(ByNode, MaxQueuesDesired, [N | Nodes]) -> case maps:get(N, ByNode, []) of diff --git a/deps/rabbitmq_cli/lib/rabbitmq/cli/queues/commands/rebalance_command.ex b/deps/rabbitmq_cli/lib/rabbitmq/cli/queues/commands/rebalance_command.ex index 1416a7c570..1c7f44b2de 100644 --- a/deps/rabbitmq_cli/lib/rabbitmq/cli/queues/commands/rebalance_command.ex +++ b/deps/rabbitmq_cli/lib/rabbitmq/cli/queues/commands/rebalance_command.ex @@ -75,10 +75,18 @@ defmodule RabbitMQ.CLI.Queues.Commands.RebalanceCommand do def help_section, do: :cluster_management - def description, do: "Rebalances queues." + def description, do: "Re-balances leaders of replicated queues across up-and-running cluster nodes" + def banner([:all], _) do + "Re-balancing leaders of all replicated queues..." + end + def banner([:classic], _) do + "Re-balancing leaders of replicated (mirrored, non-exclusive) classic queues..." + end + def banner([:quorum], _) do + "Re-balancing leaders of quorum queues..." + end def banner([type], _) do - "Rebalancing #{type} queues..." + "Re-balancing leaders of #{type} queues..." end - end |