diff --git a/src/emqx_cm.erl b/src/emqx_cm.erl index 6eb375aba..61982f569 100644 --- a/src/emqx_cm.erl +++ b/src/emqx_cm.erl @@ -376,7 +376,7 @@ lookup_channels(local, ClientId) -> %% @private rpc_call(Node, Fun, Args) -> - case rpc:call(Node, ?MODULE, Fun, Args) of + case rpc:call(Node, ?MODULE, Fun, Args, 2 * ?T_TAKEOVER) of {badrpc, Reason} -> error(Reason); Res -> Res end.