diff options
author | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2020-11-03 11:45:22 +0100 |
---|---|---|
committer | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2020-11-03 11:45:22 +0100 |
commit | 0f569d705afb03b1de06def59e56cdbb1a69a832 (patch) | |
tree | 32df3f6d070f407f7a42015f23e8377306a61151 | |
parent | 34711b405893e3b1457fe0c7d55b1153249f5c94 (diff) | |
download | rabbitmq-server-git-0f569d705afb03b1de06def59e56cdbb1a69a832.tar.gz |
Return Erlang node long name in metadata
Fixes #2
-rw-r--r-- | deps/rabbitmq_stream/src/rabbit_stream.erl | 13 |
1 files changed, 11 insertions, 2 deletions
diff --git a/deps/rabbitmq_stream/src/rabbit_stream.erl b/deps/rabbitmq_stream/src/rabbit_stream.erl index ac713a1aba..8353d66d57 100644 --- a/deps/rabbitmq_stream/src/rabbit_stream.erl +++ b/deps/rabbitmq_stream/src/rabbit_stream.erl @@ -31,12 +31,21 @@ start(_Type, _Args) -> host() -> case application:get_env(rabbitmq_stream, advertised_host, undefined) of undefined -> - {ok, Host} = inet:gethostname(), - list_to_binary(Host); + hostname_from_node(); Host -> rabbit_data_coercion:to_binary(Host) end. +hostname_from_node() -> + case re:split(rabbit_data_coercion:to_binary(node()), + "@", + [{return, binary}, {parts, 2}]) of + [_, Hostname] -> + Hostname; + [_] -> + rabbit_data_coercion:to_binary(inet:gethostname()) + end. + port() -> case application:get_env(rabbitmq_stream, advertised_port, undefined) of undefined -> |