diff --git a/src/emqttd_pubsub.erl b/src/emqttd_pubsub.erl index af1c1537d..eb4722bb8 100644 --- a/src/emqttd_pubsub.erl +++ b/src/emqttd_pubsub.erl @@ -96,7 +96,7 @@ dispatch(SubId, Topic, Msg) when is_binary(SubId) -> emqttd_sm:dispatch(SubId, Topic, Msg). subscribers(Topic) -> - try ets:lookup_element(subscriber, Topic, 2) catch error:badarg -> [] end. + try ets:lookup_element(mqtt_subscriber, Topic, 2) catch error:badarg -> [] end. %% @private %% @doc Ingore $SYS Messages.