diff --git a/src/emqx_rpc.erl b/src/emqx_rpc.erl index f76714f76..7c6b13846 100644 --- a/src/emqx_rpc.erl +++ b/src/emqx_rpc.erl @@ -18,10 +18,14 @@ -export([call/4, cast/4]). +-export([multicall/4]). + call(Node, Mod, Fun, Args) -> rpc:call(Node, Mod, Fun, Args). +multicall(Nodes, Mod, Fun, Args) -> + rpc:multicall(Nodes, Mod, Fun, Args). + cast(Node, Mod, Fun, Args) -> - %%TODO: not right - emqx_metrics:inc('messages/forward'), rpc:cast(Node, Mod, Fun, Args). +