From 954e85bb73ab625bd107ced0524f6bbb3834a408 Mon Sep 17 00:00:00 2001
From: lafirest <blankalupo@163.com>
Date: Mon, 24 Jan 2022 17:03:37 +0800
Subject: [PATCH] fix(emqx_slow_subs): fix qos2 pattern matching error

---
 src/emqx_session.erl | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/emqx_session.erl b/src/emqx_session.erl
index 2e2a4dafe..5741b2753 100644
--- a/src/emqx_session.erl
+++ b/src/emqx_session.erl
@@ -392,7 +392,7 @@ pubrel(PacketId, Session = #session{awaiting_rel = AwaitingRel}) ->
        | {error, emqx_types:reason_code()}).
 pubcomp(ClientInfo, PacketId, Session = #session{inflight = Inflight}) ->
     case emqx_inflight:lookup(PacketId, Inflight) of
-        {value, {Pubrel, Msg}} when is_record(Pubrel, pubrel_await) ->
+        {value, {#pubrel_await{message = Msg}, _Ts}} ->
             on_delivery_completed(ClientInfo, Msg, Session),
             Inflight1 = emqx_inflight:delete(PacketId, Inflight),
             dequeue(ClientInfo, Session#session{inflight = Inflight1});