diff --git a/apps/emqx_prometheus/src/emqx_prometheus.erl b/apps/emqx_prometheus/src/emqx_prometheus.erl index 8ffc1c0eb..92513ed71 100644 --- a/apps/emqx_prometheus/src/emqx_prometheus.erl +++ b/apps/emqx_prometheus/src/emqx_prometheus.erl @@ -73,7 +73,7 @@ %%-------------------------------------------------------------------- %% update new config update(Config) -> - case emqx:update_config([prometheus], Config, + case emqx_conf:update([prometheus], Config, #{rawconf_with_defaults => true, override_to => cluster}) of {ok, #{raw_config := NewConfigRows}} -> case maps:get(<<"enable">>, Config, true) of diff --git a/apps/emqx_statsd/src/emqx_statsd.erl b/apps/emqx_statsd/src/emqx_statsd.erl index 99ba7c06e..545019884 100644 --- a/apps/emqx_statsd/src/emqx_statsd.erl +++ b/apps/emqx_statsd/src/emqx_statsd.erl @@ -57,14 +57,14 @@ }). update(Config) -> - case emqx:update_config([statsd], + case emqx_conf:update([statsd], Config, #{rawconf_with_defaults => true, override_to => cluster}) of {ok, #{raw_config := NewConfigRows}} -> - _ = start(), + ok = stop(), case maps:get(<<"enable">>, Config, true) of true -> - ok = stop(); + ok = start(); false -> ignore end,