From 417cb3620d1e0e24b70820b63318a70439e8e75e Mon Sep 17 00:00:00 2001 From: Feng Lee Date: Wed, 10 Aug 2016 21:50:28 +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 cd58d2b95..10a6466aa 100644 --- a/src/emqttd_pubsub.erl +++ b/src/emqttd_pubsub.erl @@ -163,7 +163,7 @@ add_subscriber_(Topic, Subscriber) -> false -> emqttd_router:add_route(Topic, node()); true -> ok end, - ets:insert(subscriber, {Topic, Subscriber}). + ets:insert(mqtt_subscriber, {Topic, Subscriber}). del_subscriber_(Topic, Subscriber) -> ets:delete_object(mqtt_subscriber, {Topic, Subscriber}),