From e25856e9a1682fffbd6a4c6cd2cf33f8580fc4a6 Mon Sep 17 00:00:00 2001 From: Feng Date: Sat, 7 Nov 2015 23:09:31 +0800 Subject: [PATCH] fix issue #374 --- src/emqttd_session.erl | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/emqttd_session.erl b/src/emqttd_session.erl index 7f1df1baa..193b6b3fe 100644 --- a/src/emqttd_session.erl +++ b/src/emqttd_session.erl @@ -174,7 +174,7 @@ destroy(SessPid, ClientId) -> %%------------------------------------------------------------------------------ -spec subscribe(pid(), [{binary(), mqtt_qos()}]) -> ok. subscribe(SessPid, TopicTable) -> - subscribe(SessPid, TopicTable, fun(_) -> ok end). + gen_server2:cast(SessPid, {subscribe, TopicTable, fun(_) -> ok end}). -spec subscribe(pid(), mqtt_packet_id(), [{binary(), mqtt_qos()}]) -> ok. subscribe(SessPid, PacketId, TopicTable) ->