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. -