diff options
| author | Michael Klishin <klishinm@vmware.com> | 2023-05-02 13:08:31 +0400 |
|---|---|---|
| committer | Michael Klishin <klishinm@vmware.com> | 2023-05-02 13:08:31 +0400 |
| commit | d5f16d4ce6d3c93ed20d7dd2e20145e5e0775dcd (patch) | |
| tree | 61fd6dd9d89673069b46df684d8cf5ae0f2b4b72 /deps | |
| parent | 7f78fc1fd85831a56602339299d956e82e770268 (diff) | |
| download | rabbitmq-server-git-d5f16d4ce6d3c93ed20d7dd2e20145e5e0775dcd.tar.gz | |
mix format
Diffstat (limited to 'deps')
| -rw-r--r-- | deps/rabbitmq_cli/lib/rabbitmq/cli/core/validators.ex | 1 | ||||
| -rw-r--r-- | deps/rabbitmq_cli/lib/rabbitmq/cli/queues/commands/add_member_command.ex | 4 | ||||
| -rw-r--r-- | deps/rabbitmq_cli/lib/rabbitmqctl.ex | 3 |
3 files changed, 5 insertions, 3 deletions
diff --git a/deps/rabbitmq_cli/lib/rabbitmq/cli/core/validators.ex b/deps/rabbitmq_cli/lib/rabbitmq/cli/core/validators.ex index 87798a0533..a4063d6b34 100644 --- a/deps/rabbitmq_cli/lib/rabbitmq/cli/core/validators.ex +++ b/deps/rabbitmq_cli/lib/rabbitmq/cli/core/validators.ex @@ -56,6 +56,7 @@ defmodule RabbitMQ.CLI.Core.Validators do def existing_cluster_member(args, %{node: node_name}, extract_member) do potential_member = extract_member.(args) + case Helpers.cluster_member?(node_name, potential_member) do false -> {:validation_failure, {:not_a_cluster_member, potential_member}} true -> :ok diff --git a/deps/rabbitmq_cli/lib/rabbitmq/cli/queues/commands/add_member_command.ex b/deps/rabbitmq_cli/lib/rabbitmq/cli/queues/commands/add_member_command.ex index 6951039c5d..9639be5436 100644 --- a/deps/rabbitmq_cli/lib/rabbitmq/cli/queues/commands/add_member_command.ex +++ b/deps/rabbitmq_cli/lib/rabbitmq/cli/queues/commands/add_member_command.ex @@ -30,8 +30,8 @@ defmodule RabbitMQ.CLI.Queues.Commands.AddMemberCommand do Validators.chain( [ &Validators.rabbit_is_running/2, - fn (args, opts) -> - extractor = fn([_, val]) -> val end + fn args, opts -> + extractor = fn [_, val] -> val end Validators.existing_cluster_member(args, opts, extractor) end ], diff --git a/deps/rabbitmq_cli/lib/rabbitmqctl.ex b/deps/rabbitmq_cli/lib/rabbitmqctl.ex index 8828cec80a..ca3a699b43 100644 --- a/deps/rabbitmq_cli/lib/rabbitmqctl.ex +++ b/deps/rabbitmq_cli/lib/rabbitmqctl.ex @@ -469,7 +469,8 @@ defmodule RabbitMQCtl do end defp format_error({:error, :not_found = result}, _opts, _) do - {:error, ExitCodes.exit_code_for(result), "Object (queue, stream, exchange, etc) was not found"} + {:error, ExitCodes.exit_code_for(result), + "Object (queue, stream, exchange, etc) was not found"} end defp format_error( |