From 7629703ca4c59e1365de932e631a9ae5b8d5ee87 Mon Sep 17 00:00:00 2001 From: Luke Bakken Date: Wed, 19 Dec 2018 14:44:53 -0800 Subject: [PATCH] Add chunks equal to number of nodes Fixes #284 --- .../lib/rabbitmq/cli/ctl/commands/list_consumers_command.ex | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git 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 index 04a2437305..4e39e39793 100644 --- 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