From 031a288b5083048a8741a8d0a509027f4939e125 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=BB=84=E4=B8=B9?= Date: Mon, 31 Oct 2016 20:22:09 +0800 Subject: [PATCH] Update emqttd_pubsub.erl modify table name --- 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 4275f88fd..f4d6859a4 100644 --- a/src/emqttd_pubsub.erl +++ b/src/emqttd_pubsub.erl @@ -228,7 +228,7 @@ del_subscriber_(Share, Topic, Subscriber) -> del_local_subscriber_(Share, Topic, Subscriber) -> ets:delete_object(mqtt_subscriber, {{local, Topic}, shared(Share, Subscriber)}), - (not ets:member(subscriber, {local, Topic})) andalso emqttd_router:del_local_route(Topic). + (not ets:member(mqtt_subscriber, {local, Topic})) andalso emqttd_router:del_local_route(Topic). shared(undefined, Subscriber) -> Subscriber;