From 645c971a07210f4a38feb01ea5fb4fe198e43388 Mon Sep 17 00:00:00 2001
From: Feng Lee <feng@emqx.io>
Date: Mon, 6 Aug 2018 17:09:14 +0800
Subject: [PATCH] Fix QoS tuning

---
 src/emqx_session.erl | 10 ++++------
 1 file changed, 4 insertions(+), 6 deletions(-)

diff --git a/src/emqx_session.erl b/src/emqx_session.erl
index 75e927a9c..03bcae3f2 100644
--- a/src/emqx_session.erl
+++ b/src/emqx_session.erl
@@ -758,14 +758,12 @@ dequeue2(State = #state{mqueue = Q}) ->
 tune_qos(Topic, Msg = #message{qos = PubQoS},
          #state{subscriptions = SubMap, upgrade_qos = UpgradeQoS}) ->
     case maps:find(Topic, SubMap) of
-        {ok, SubQoS} when UpgradeQoS andalso (SubQoS > PubQoS) ->
+        {ok, #{qos := SubQoS}} when UpgradeQoS andalso (SubQoS > PubQoS) ->
             Msg#message{qos = SubQoS};
-        {ok, SubQoS} when (not UpgradeQoS) andalso (SubQoS < PubQoS) ->
+        {ok, #{qos := SubQoS}} when (not UpgradeQoS) andalso (SubQoS < PubQoS) ->
             Msg#message{qos = SubQoS};
-        {ok, _} ->
-            Msg;
-        error ->
-            Msg
+        {ok, _} -> Msg;
+        error   -> Msg
     end.
 
 %%------------------------------------------------------------------------------