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 21:50:28 +08:00
parent d6041395ef
commit 417cb3620d
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

@ -163,7 +163,7 @@ add_subscriber_(Topic, Subscriber) ->
false -> emqttd_router:add_route(Topic, node()); false -> emqttd_router:add_route(Topic, node());
true -> ok true -> ok
end, end,
ets:insert(subscriber, {Topic, Subscriber}). ets:insert(mqtt_subscriber, {Topic, Subscriber}).
del_subscriber_(Topic, Subscriber) -> del_subscriber_(Topic, Subscriber) ->
ets:delete_object(mqtt_subscriber, {Topic, Subscriber}), ets:delete_object(mqtt_subscriber, {Topic, Subscriber}),