diff --git a/src/emqttd_dispatcher.erl b/src/emqttd_dispatcher.erl index ddef32347..44e44219a 100644 --- a/src/emqttd_dispatcher.erl +++ b/src/emqttd_dispatcher.erl @@ -84,7 +84,7 @@ unsubscribe(Topic, Subscriber) -> -spec(async_unsubscribe(binary(), emqttd:subscriber()) -> ok). async_unsubscribe(Topic, Subscriber) -> - cast(pick(Topic), {async_unsubscribe, Topic, Subscriber}). + cast(pick(Topic), {unsubscribe, Topic, Subscriber}). call(Server, Req) -> gen_server2:call(Server, Req, infinity).