Skip to content

Commit 48f5593

Browse files
committed
fix rabbitmq_queues_cli_integration_SUITE
1 parent 80ee054 commit 48f5593

File tree

2 files changed

+4
-10
lines changed

2 files changed

+4
-10
lines changed

deps/rabbitmq_cli/lib/rabbitmq/cli/queues/commands/grow_command.ex

Lines changed: 2 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -67,15 +67,9 @@ defmodule RabbitMQ.CLI.Queues.Commands.GrowCommand do
6767
membership: membership,
6868
errors_only: errors_only
6969
}) do
70-
args = [to_atom(node), vhost_pat, queue_pat, to_atom(strategy)]
70+
args = [to_atom(node), vhost_pat, queue_pat, to_atom(strategy), to_atom(membership)]
7171

72-
args =
73-
case to_atom(membership) do
74-
:promotable -> args
75-
other -> args ++ [other]
76-
end
77-
78-
case :rabbit_misc.rpc_call(node_name, :rabbit_queue_command, :grow, args) do
72+
case :rabbit_misc.rpc_call(node_name, :rabbit_queue_commands, :grow, args) do
7973
{:error, _} = error ->
8074
error
8175

deps/rabbitmq_cli/lib/rabbitmq/cli/queues/commands/shrink_command.ex

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ defmodule RabbitMQ.CLI.Queues.Commands.ShrinkCommand do
3232
{:badrpc, _} = error ->
3333
error
3434

35-
results when errs ->
35+
{:ok, results} when errs ->
3636
for {{:resource, vhost, _kind, name}, {:error, _, _} = res} <- results,
3737
do: [
3838
{:vhost, vhost},
@@ -41,7 +41,7 @@ defmodule RabbitMQ.CLI.Queues.Commands.ShrinkCommand do
4141
{:result, format_result(res)}
4242
]
4343

44-
results ->
44+
{:ok, results} ->
4545
for {{:resource, vhost, _kind, name}, res} <- results,
4646
do: [
4747
{:vhost, vhost},

0 commit comments

Comments
 (0)