diff --git a/apps/emqx_auto_subscribe/src/emqx_auto_subscribe.erl b/apps/emqx_auto_subscribe/src/emqx_auto_subscribe.erl index 134248920..03bacca68 100644 --- a/apps/emqx_auto_subscribe/src/emqx_auto_subscribe.erl +++ b/apps/emqx_auto_subscribe/src/emqx_auto_subscribe.erl @@ -60,8 +60,12 @@ test(_) -> %% hook on_client_connected(ClientInfo, ConnInfo, {TopicHandler, Options}) -> - TopicTables = erlang:apply(TopicHandler, handle, [ClientInfo, ConnInfo, Options]), - self() ! {subscribe, TopicTables}; + case erlang:apply(TopicHandler, handle, [ClientInfo, ConnInfo, Options]) of + [] -> ok; + TopicTables -> + _ = self() ! {subscribe, TopicTables}, + ok + end; on_client_connected(_, _, _) -> ok.