yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

mqtt_subscriber

This commit is contained in:
Feng Lee 2016-08-10 22:41:06 +08:00
parent 8a0a7978dd
commit c86aa94ae7
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/emqttd_pubsub.erl
View File

@ -96,7 +96,7 @@ dispatch(SubId, Topic, Msg) when is_binary(SubId) ->
emqttd_sm:dispatch(SubId, Topic, Msg). emqttd_sm:dispatch(SubId, Topic, Msg).
subscribers(Topic) -> 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 %% @private
%% @doc Ingore $SYS Messages. %% @doc Ingore $SYS Messages.