yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(rule_engine): only refresh enabled rules at bootup

This commit is contained in:
Shawn 2021-04-27 10:52:52 +08:00 committed by turtleDeng
parent 7198c018e2
commit 6557b132a2
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
apps/emqx_rule_engine/src/emqx_rule_engine.erl
View File

@ -388,11 +388,13 @@ refresh_resource(#resource{id = ResId}) ->
-spec(refresh_rules() -> ok). -spec(refresh_rules() -> ok).
refresh_rules() -> refresh_rules() ->
lists:foreach(fun(#rule{} = Rule) -> lists:foreach(fun
try refresh_rule(Rule) (#rule{enabled = true} = Rule) ->
catch _:_ -> try refresh_rule(Rule)
emqx_rule_registry:add_rule(Rule#rule{enabled = false, state = refresh_failed_at_bootup}) catch _:_ ->
end emqx_rule_registry:add_rule(Rule#rule{enabled = false, state = refresh_failed_at_bootup})
end;
(_) -> ok
end, emqx_rule_registry:get_rules()). end, emqx_rule_registry:get_rules()).
refresh_rule(#rule{id = RuleId, for = Topics, actions = Actions}) -> refresh_rule(#rule{id = RuleId, for = Topics, actions = Actions}) ->