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

fix: undef function

This commit is contained in:
zhongwencool 2021-09-10 13:27:43 +08:00
parent 9820027953
commit 0303e593c5
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/emqx_rule_engine/src/emqx_rule_registry.erl
View File

@ -223,7 +223,7 @@ remove_rules(Rules) ->
insert_rules([]) -> ok; insert_rules([]) -> ok;
insert_rules(Rules) -> insert_rules(Rules) ->
_ = emqx_rule_utils:cluster_call(?MODULE, load_hooks_for_rule, [Rules]), _ = emqx_plugin_libs_rule:cluster_call(?MODULE, load_hooks_for_rule, [Rules]),
[mnesia:write(?RULE_TAB, Rule, write) ||Rule <- Rules]. [mnesia:write(?RULE_TAB, Rule, write) ||Rule <- Rules].
%% @private %% @private
@ -241,7 +241,7 @@ delete_rules(Rules = [Rule|_]) when is_record(Rule, rule) ->
delete_rules_unload_hooks(Rules). delete_rules_unload_hooks(Rules).
delete_rules_unload_hooks(Rules) -> delete_rules_unload_hooks(Rules) ->
_ = emqx_rule_utils:cluster_call(?MODULE, unload_hooks_for_rule, [Rules]), _ = emqx_plugin_libs_rule:cluster_call(?MODULE, unload_hooks_for_rule, [Rules]),
[mnesia:delete_object(?RULE_TAB, Rule, write) ||Rule <- Rules]. [mnesia:delete_object(?RULE_TAB, Rule, write) ||Rule <- Rules].
load_hooks_for_rule(Rules) -> load_hooks_for_rule(Rules) ->