diff --git a/src/emqx_connection.erl b/src/emqx_connection.erl index bd9a9fbe4..abba2bcdd 100644 --- a/src/emqx_connection.erl +++ b/src/emqx_connection.erl @@ -858,6 +858,7 @@ inc_incoming_stats(Packet = ?PACKET(Type)) -> case Type =:= ?PUBLISH of true -> inc_counter(recv_msg, 1), + inc_qos_stats(recv_msg, Packet), inc_counter(incoming_pubs, 1); false -> ok