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

fix(rule_engine): use rpc in emqx_rule_engine_api

This commit is contained in:
Shawn 2020-12-18 18:34:16 +08:00
parent e15c0c325e
commit 443ff737ed
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqx_rule_engine/src/emqx_rule_engine_api.erl
View File

@ -268,7 +268,7 @@ list_resources(#{}, _Params) ->
Data0 = lists:foldr(fun maybe_record_to_map/2, [], emqx_rule_registry:get_resources()), Data0 = lists:foldr(fun maybe_record_to_map/2, [], emqx_rule_registry:get_resources()),
Data = lists:map(fun(Res = #{id := Id}) -> Data = lists:map(fun(Res = #{id := Id}) ->
Status = lists:all(fun(Node) -> Status = lists:all(fun(Node) ->
case emqx_rpc:call(Node, emqx_rule_registry, find_resource_params, [Id]) of case rpc:call(Node, emqx_rule_registry, find_resource_params, [Id]) of
{ok, #resource_params{status = #{is_alive := true}}} -> true; {ok, #resource_params{status = #{is_alive := true}}} -> true;
_ -> false _ -> false
end end