diff options
4 files changed, 5 insertions, 3 deletions
diff --git a/deps/rabbitmq_management/include/rabbit_mgmt.hrl b/deps/rabbitmq_management/include/rabbit_mgmt.hrl index 0021807413..2a429a50e9 100644 --- a/deps/rabbitmq_management/include/rabbit_mgmt.hrl +++ b/deps/rabbitmq_management/include/rabbit_mgmt.hrl @@ -18,4 +18,5 @@ -define(HEALTH_CHECK_FAILURE_STATUS, 503). --define(MANAGEMENT_PG_SCOPE, rabbit_mgmt).
\ No newline at end of file +-define(MANAGEMENT_PG_SCOPE, rabbit_mgmt). +-define(MANAGEMENT_PG_GROUP, management_db). diff --git a/deps/rabbitmq_management/src/rabbit_mgmt_db.erl b/deps/rabbitmq_management/src/rabbit_mgmt_db.erl index b6b90a38b0..05e18ce25c 100644 --- a/deps/rabbitmq_management/src/rabbit_mgmt_db.erl +++ b/deps/rabbitmq_management/src/rabbit_mgmt_db.erl @@ -732,7 +732,7 @@ created_stats_delegated(Type) -> -spec delegate_invoke(mfargs()) -> [any()]. delegate_invoke(FunOrMFA) -> - MemberPids = [P || P <- pg:get_members(?MANAGEMENT_PG_SCOPE, management_db)], + MemberPids = [P || P <- pg:get_members(?MANAGEMENT_PG_SCOPE, ?MANAGEMENT_PG_GROUP)], {Results, Errors} = delegate:invoke(MemberPids, ?DELEGATE_PREFIX, FunOrMFA), case Errors of [] -> ok; diff --git a/deps/rabbitmq_management_agent/include/rabbit_mgmt_agent.hrl b/deps/rabbitmq_management_agent/include/rabbit_mgmt_agent.hrl index ad6b66bbfc..177532fbe9 100644 --- a/deps/rabbitmq_management_agent/include/rabbit_mgmt_agent.hrl +++ b/deps/rabbitmq_management_agent/include/rabbit_mgmt_agent.hrl @@ -15,3 +15,4 @@ %% -define(MANAGEMENT_PG_SCOPE, rabbit_mgmt). +-define(MANAGEMENT_PG_GROUP, management_db). diff --git a/deps/rabbitmq_management_agent/src/rabbit_mgmt_agent_sup.erl b/deps/rabbitmq_management_agent/src/rabbit_mgmt_agent_sup.erl index f944a7f48d..f5398671e4 100644 --- a/deps/rabbitmq_management_agent/src/rabbit_mgmt_agent_sup.erl +++ b/deps/rabbitmq_management_agent/src/rabbit_mgmt_agent_sup.erl @@ -36,7 +36,7 @@ start_link() -> maybe_enable_metrics_collector() -> case application:get_env(rabbitmq_management_agent, disable_metrics_collector, false) of false -> - ok = pg:join(?MANAGEMENT_PG_SCOPE, management_db, self()), + ok = pg:join(?MANAGEMENT_PG_SCOPE, ?MANAGEMENT_PG_GROUP, self()), ST = {rabbit_mgmt_storage, {rabbit_mgmt_storage, start_link, []}, permanent, ?WORKER_WAIT, worker, [rabbit_mgmt_storage]}, MD = {delegate_management_sup, {delegate_sup, start_link, [5, ?DELEGATE_PREFIX]}, |