From 224aaaf8a7e5fbaa15825f177725dd57220c2539 Mon Sep 17 00:00:00 2001 From: Gilbert Wong Date: Mon, 27 Aug 2018 17:11:54 +0800 Subject: [PATCH] unsubscribe function should have two params --- src/emqx.erl | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/emqx.erl b/src/emqx.erl index 54f1952f4..de89a9981 100644 --- a/src/emqx.erl +++ b/src/emqx.erl @@ -95,7 +95,7 @@ unsubscribe(Topic) -> -spec(unsubscribe(topic() | string(), subscriber() | string()) -> ok | {error, term()}). unsubscribe(Topic, Sub) when is_list(Sub) -> - emqx_broker:unsubscribe(iolist_to_binary(Topic)); + emqx_broker:unsubscribe(iolist_to_binary(Topic), list_to_subid(Sub)); unsubscribe(Topic, Subscriber) when is_tuple(Subscriber) -> {SubPid, SubId} = Subscriber, emqx_broker:unsubscribe(iolist_to_binary(Topic), SubPid, SubId).