From 1266b4e86011ac42f78bb44d69dae15f5acdac03 Mon Sep 17 00:00:00 2001 From: Feng Lee Date: Fri, 12 Aug 2016 22:39:13 +0800 Subject: [PATCH] ack qos --- 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 9345071dc..55eb08b11 100644 --- a/src/emqttd_session.erl +++ b/src/emqttd_session.erl @@ -315,7 +315,7 @@ handle_cast({subscribe, RawTopicTable, AckFun}, Session = #session{client_id dict:store(Topic, Qos, SubDict) end end, Subscriptions, TopicTable), - AckFun([Qos || {_, Qos} <- TopicTable]), + AckFun([Qos || {_, Qos} <- RawTopicTable]), emqttd:run_hooks('client.subscribe.after', [ClientId], TopicTable), hibernate(Session#session{subscriptions = Subscriptions1}); {stop, TopicTable} ->