diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2020-07-15 17:35:13 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2020-07-15 17:35:13 +0300 |
| commit | 81809c741a963230961859bf3be960f004a2b27a (patch) | |
| tree | c38aa0da07e429db5b7212cb59c07c2a127f3959 /deps/rabbitmq_federation/src | |
| parent | 29d5fead22b8d54e5620d03dd34fcf68e2e53501 (diff) | |
| download | rabbitmq-server-git-81809c741a963230961859bf3be960f004a2b27a.tar.gz | |
Handle cases where rabbitmq_federation.pgroup_name_cluster_id is undefined
it's highly unusual to see but being more defensive is
very easy in this case.
Diffstat (limited to 'deps/rabbitmq_federation/src')
| -rw-r--r-- | deps/rabbitmq_federation/src/rabbit_federation_util.erl | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/deps/rabbitmq_federation/src/rabbit_federation_util.erl b/deps/rabbitmq_federation/src/rabbit_federation_util.erl index db2c36b8f0..df07f8f01d 100644 --- a/deps/rabbitmq_federation/src/rabbit_federation_util.erl +++ b/deps/rabbitmq_federation/src/rabbit_federation_util.erl @@ -64,7 +64,9 @@ r(Q) when ?is_amqqueue(Q) -> amqqueue:get_name(Q). pgname(Name) -> case application:get_env(rabbitmq_federation, pgroup_name_cluster_id) of {ok, false} -> Name; - {ok, true} -> {rabbit_nodes:cluster_name(), Name} + {ok, true} -> {rabbit_nodes:cluster_name(), Name}; + %% default value is 'false', so do the same thing + undefined -> Name end. obfuscate_upstream(#upstream{uris = Uris} = Upstream) -> |