diff --git a/apps/emqx_auto_subscribe/src/emqx_auto_subscribe.erl b/apps/emqx_auto_subscribe/src/emqx_auto_subscribe.erl index 0183726da..81b0d70a4 100644 --- a/apps/emqx_auto_subscribe/src/emqx_auto_subscribe.erl +++ b/apps/emqx_auto_subscribe/src/emqx_auto_subscribe.erl @@ -83,7 +83,7 @@ update_(Topics) when length(Topics) =< ?MAX_AUTO_SUBSCRIBE -> case emqx_conf:update([auto_subscribe, topics], Topics, #{rawconf_with_defaults => true, override_to => cluster}) of - {ok, #{config := NewTopics}} -> + {ok, #{raw_config := NewTopics}} -> ok = update_hook(), {ok, NewTopics}; {error, Reason} -> diff --git a/apps/emqx_modules/src/emqx_delayed_api.erl b/apps/emqx_modules/src/emqx_delayed_api.erl index 66d4a0fdc..5caad8aa1 100644 --- a/apps/emqx_modules/src/emqx_delayed_api.erl +++ b/apps/emqx_modules/src/emqx_delayed_api.erl @@ -222,7 +222,7 @@ generate_max_delayed_messages(Config) -> update_config_(Config) -> case emqx_delayed:update_config(Config) of - {ok, #{config := NewDelayed}} -> + {ok, #{raw_config := NewDelayed}} -> case maps:get(<<"enable">>, Config, undefined) of undefined -> ignore; diff --git a/apps/emqx_modules/src/emqx_event_message.erl b/apps/emqx_modules/src/emqx_event_message.erl index 3918e4dfc..3af57a38d 100644 --- a/apps/emqx_modules/src/emqx_event_message.erl +++ b/apps/emqx_modules/src/emqx_event_message.erl @@ -47,7 +47,7 @@ update(Params) -> case emqx_conf:update([event_message], Params, #{rawconf_with_defaults => true, override_to => cluster}) of - {ok, #{config := NewEventMessage}} -> + {ok, #{raw_config := NewEventMessage}} -> enable(), {ok, NewEventMessage}; {error, Reason} ->