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;