From 3f42f1271b4bf4b1e62f26530a6de4cf2f1b8f38 Mon Sep 17 00:00:00 2001 From: terry-xiaoyu <506895667@qq.com> Date: Fri, 31 Aug 2018 18:14:10 +0800 Subject: [PATCH] bug fix --- src/emqx_session.erl | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/emqx_session.erl b/src/emqx_session.erl index 81299711d..75c3ac197 100644 --- a/src/emqx_session.erl +++ b/src/emqx_session.erl @@ -720,7 +720,7 @@ run_dispatch_steps([], Msg, State) -> dispatch(Msg, State); run_dispatch_steps([{nl, 1}|_Steps], #message{from = ClientId}, State = #state{client_id = ClientId}) -> State; -run_dispatch_steps([{nl, 0}|Steps], Msg, State) -> +run_dispatch_steps([{nl, _}|Steps], Msg, State) -> run_dispatch_steps(Steps, Msg, State); run_dispatch_steps([{qos, SubQoS}|Steps], Msg = #message{qos = PubQoS}, State = #state{upgrade_qos = false}) -> run_dispatch_steps(Steps, Msg#message{qos = min(SubQoS, PubQoS)}, State); @@ -897,4 +897,3 @@ shutdown(Reason, State) -> %% TODO: GC Policy and Shutdown Policy %% maybe_gc(State) -> State. -