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

More warnings

This commit is contained in:
Michael Klishin 2018-10-30 00:51:35 +03:00
parent 152395c30b
commit 582fa06686
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
deps/rabbitmq_cli/lib/rabbitmq/cli/ctl/commands/quorum_status_command.ex vendored
View File

@ -39,7 +39,7 @@ defmodule RabbitMQ.CLI.Ctl.Commands.QuorumStatusCommand do
use RabbitMQ.CLI.Core.RequiresRabbitAppRunning use RabbitMQ.CLI.Core.RequiresRabbitAppRunning
def run([name] = args, %{node: node_name, vhost: vhost}) do def run([name] = _args, %{node: node_name, vhost: vhost}) do
case :rabbit_misc.rpc_call(node_name, :rabbit_quorum_queue, :status, [vhost, name]) do case :rabbit_misc.rpc_call(node_name, :rabbit_quorum_queue, :status, [vhost, name]) do
{:error, :classic_queue_not_supported} -> {:error, :classic_queue_not_supported} ->
{:error, "Cannot get quorum status of a classic queue"}; {:error, "Cannot get quorum status of a classic queue"};

2
deps/rabbitmq_cli/lib/rabbitmq/cli/queues/commands/add_member.ex vendored
View File

@ -37,7 +37,7 @@ defmodule RabbitMQ.CLI.Queues.Commands.AddMember do
use RabbitMQ.CLI.Core.RequiresRabbitAppRunning use RabbitMQ.CLI.Core.RequiresRabbitAppRunning
def run([name, node] = args, %{vhost: vhost, node: node_name}) do def run([name, node] = _args, %{vhost: vhost, node: node_name}) do
case :rabbit_misc.rpc_call(node_name, case :rabbit_misc.rpc_call(node_name,
:rabbit_quorum_queue, :add_member, :rabbit_quorum_queue, :add_member,
[vhost, name, to_atom(node)]) do [vhost, name, to_atom(node)]) do

2
deps/rabbitmq_cli/lib/rabbitmq/cli/queues/commands/delete_member.ex vendored
View File

@ -37,7 +37,7 @@ defmodule RabbitMQ.CLI.Queues.Commands.DeleteMember do
use RabbitMQ.CLI.Core.RequiresRabbitAppRunning use RabbitMQ.CLI.Core.RequiresRabbitAppRunning
def run([name, node] = args, %{vhost: vhost, node: node_name}) do def run([name, node] = _args, %{vhost: vhost, node: node_name}) do
case :rabbit_misc.rpc_call(node_name, case :rabbit_misc.rpc_call(node_name,
:rabbit_quorum_queue, :delete_member, :rabbit_quorum_queue, :delete_member,
[vhost, name, to_atom(node)]) do [vhost, name, to_atom(node)]) do