diff --git a/apps/emqx_rule_engine/include/rule_engine.hrl b/apps/emqx_rule_engine/include/rule_engine.hrl index 568724263..6e8416688 100644 --- a/apps/emqx_rule_engine/include/rule_engine.hrl +++ b/apps/emqx_rule_engine/include/rule_engine.hrl @@ -158,7 +158,7 @@ -define(CLUSTER_CALL(Func, Args), ?CLUSTER_CALL(Func, Args, ok)). -define(CLUSTER_CALL(Func, Args, ResParttern), - fun() -> case rpc:multicall(ekka_mnesia:running_nodes(), ?MODULE, Func, Args, 5000) of + fun() -> case rpc:multicall(ekka_mnesia:running_nodes(), ?MODULE, Func, Args, 30000) of {ResL, []} -> case lists:filter(fun(ResParttern) -> false; (_) -> true end, ResL) of [] -> ResL; diff --git a/apps/emqx_rule_engine/src/emqx_rule_engine.appup.src b/apps/emqx_rule_engine/src/emqx_rule_engine.appup.src index 183504d97..80b64f027 100644 --- a/apps/emqx_rule_engine/src/emqx_rule_engine.appup.src +++ b/apps/emqx_rule_engine/src/emqx_rule_engine.appup.src @@ -22,9 +22,11 @@ {"4.3.3", [ {load_module, emqx_rule_engine, brutal_purge, soft_purge, []} , {load_module, emqx_rule_actions, brutal_purge, soft_purge, []} + , {load_module, emqx_rule_registry, brutal_purge, soft_purge, []} ]}, {"4.3.4", [ {load_module, emqx_rule_engine, brutal_purge, soft_purge, []} + , {load_module, emqx_rule_registry, brutal_purge, soft_purge, []} ]}, {<<".*">>, []} ], @@ -51,9 +53,11 @@ {"4.3.3", [ {load_module, emqx_rule_engine, brutal_purge, soft_purge, []} , {load_module, emqx_rule_actions, brutal_purge, soft_purge, []} + , {load_module, emqx_rule_registry, brutal_purge, soft_purge, []} ]}, {"4.3.4", [ {load_module, emqx_rule_engine, brutal_purge, soft_purge, []} + , {load_module, emqx_rule_registry, brutal_purge, soft_purge, []} ]}, {<<".*">>, []} ]