Add chunks equal to number of nodes

Fixes #284
2018-12-19 14:44:53 -08:00 · 2018-12-19 14:44:53 -08:00 · 7629703ca4
parent 603a442d54
commit 7629703ca4
1 changed files with 1 additions and 1 deletions
--- a/deps/rabbitmq_cli/lib/rabbitmq/cli/ctl/commands/list_consumers_command.ex
+++ b/deps/rabbitmq_cli/lib/rabbitmq/cli/ctl/commands/list_consumers_command.ex
@ -53,7 +53,7 @@ defmodule RabbitMQ.CLI.Ctl.Commands.ListConsumersCommand do
      Helpers.with_nodes_in_cluster(node_name, fn(nodes) ->
        RpcStream.receive_list_items(node_name,
          :rabbit_amqqueue, :emit_consumers_all,
-          [nodes, vhost], timeout, info_keys)
+          [nodes, vhost], timeout, info_keys, Kernel.length(nodes))
      end)
  end