diff options
Diffstat (limited to 'deps/rabbitmq_cli/lib/rabbitmq/cli/core/helpers.ex')
| -rw-r--r-- | deps/rabbitmq_cli/lib/rabbitmq/cli/core/helpers.ex | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/deps/rabbitmq_cli/lib/rabbitmq/cli/core/helpers.ex b/deps/rabbitmq_cli/lib/rabbitmq/cli/core/helpers.ex index 33ab985834..fb1699a2b2 100644 --- a/deps/rabbitmq_cli/lib/rabbitmq/cli/core/helpers.ex +++ b/deps/rabbitmq_cli/lib/rabbitmq/cli/core/helpers.ex @@ -77,6 +77,11 @@ defmodule RabbitMQ.CLI.Core.Helpers do end end + def cluster_member?(target_node, node_to_check, timeout \\ 30_000) do + node_to_check_a = DataCoercion.to_atom(node_to_check) + Enum.member?(nodes_in_cluster(target_node, timeout), node_to_check_a) + end + def node_running?(node) do :net_adm.ping(node) == :pong end |