root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

Handle errors returned by the rpc call

This commit is contained in:
Michael Klishin 2019-02-20 10:55:36 +03:00 committed by kjnilsson
parent 581cd2dc25
commit 748b3ed485
1 changed files with 18 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
deps/rabbitmq_cli/lib/rabbitmq/cli/queues/commands/shrink_command.ex vendored
View File

@ -29,11 +29,10 @@ defmodule RabbitMQ.CLI.Queues.Commands.ShrinkCommand do
use RabbitMQ.CLI.Core.AcceptsOnePositionalArgument
use RabbitMQ.CLI.Core.RequiresRabbitAppRunning
def run([node], %{node: node_name,
errors_only: errs}) do
case :rabbit_misc.rpc_call(node_name, :rabbit_quorum_queue, :shrink_all, [
to_atom(node)
]) do
def run([node], %{node: node_name, errors_only: errs}) do
case :rabbit_misc.rpc_call(node_name, :rabbit_quorum_queue, :shrink_all, [to_atom(node)]) do
{:error, _} = error -> error;
{:badrpc, _} = error -> error;
results when errs ->
for {{:resource, vhost, _kind, name}, {_errors, _, _} = res} <- results,
do: [{:vhost, vhost},
@ -49,6 +48,20 @@ defmodule RabbitMQ.CLI.Queues.Commands.ShrinkCommand do
end
end
use RabbitMQ.CLI.DefaultOutput
def formatter(), do: RabbitMQ.CLI.Formatters.Table
def banner([node], _) do
"Shrinking queues on #{node}..."
end
def usage, do: "shrink <node> [--errors-only]"
#
# Implementation
#
defp format_size({:ok, size}) do
size
end
@ -72,15 +85,4 @@ defmodule RabbitMQ.CLI.Queues.Commands.ShrinkCommand do
defp format_result({:error, _size, err}) do
:io.format "error: ~W", [err, 10]
end
use RabbitMQ.CLI.DefaultOutput
def formatter(), do: RabbitMQ.CLI.Formatters.Table
def banner([node], _) do
"Shrinking queues on #{node}..."
end
def usage, do: "shrink <node> [--errors-only]"
end