summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorArnaud Cogoluègnes <acogoluegnes@gmail.com>2020-11-03 11:45:22 +0100
committerArnaud Cogoluègnes <acogoluegnes@gmail.com>2020-11-03 11:45:22 +0100
commit0f569d705afb03b1de06def59e56cdbb1a69a832 (patch)
tree32df3f6d070f407f7a42015f23e8377306a61151
parent34711b405893e3b1457fe0c7d55b1153249f5c94 (diff)
downloadrabbitmq-server-git-0f569d705afb03b1de06def59e56cdbb1a69a832.tar.gz
Return Erlang node long name in metadata
Fixes #2
-rw-r--r--deps/rabbitmq_stream/src/rabbit_stream.erl13
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 ->