From c86aa94ae75c101a7438e33bf5cf4ed7e9d02097 Mon Sep 17 00:00:00 2001 From: Feng Lee Date: Wed, 10 Aug 2016 22:41:06 +0800 Subject: [PATCH] mqtt_subscriber --- src/emqttd_pubsub.erl | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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.