diff --git a/apps/emqx/src/emqx_router_helper.erl b/apps/emqx/src/emqx_router_helper.erl index 1340848ec..3f712bf4a 100644 --- a/apps/emqx/src/emqx_router_helper.erl +++ b/apps/emqx/src/emqx_router_helper.erl @@ -47,6 +47,11 @@ code_change/3 ]). +%% Internal exports (RPC) +-export([ + cleanup_routes/1 +]). + -record(routing_node, {name, const = unused}). -define(ROUTE, emqx_route). @@ -145,7 +150,7 @@ handle_info({nodedown, Node}, State = #{nodes := Nodes}) -> global:trans( {?LOCK, self()}, fun() -> - mria:transaction(?ROUTE_SHARD, fun cleanup_routes/1, [Node]) + mria:transaction(?ROUTE_SHARD, fun ?MODULE:cleanup_routes/1, [Node]) end ), ok = mria:dirty_delete(?ROUTING_NODE, Node),