From a19777c2e6f52dae17761451f390707190c4af1f Mon Sep 17 00:00:00 2001
From: terry-xiaoyu <506895667@qq.com>
Date: Fri, 9 Aug 2019 19:12:56 +0800
Subject: [PATCH] Add hook message.acked

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

diff --git a/src/emqx_session.erl b/src/emqx_session.erl
index bb26a2135..2530f3a42 100644
--- a/src/emqx_session.erl
+++ b/src/emqx_session.erl
@@ -378,6 +378,7 @@ do_publish(PacketId, Msg = #message{timestamp = Ts},
 puback(PacketId, Session = #session{inflight = Inflight}) ->
     case emqx_inflight:lookup(PacketId, Inflight) of
         {value, {Msg, _Ts}} when is_record(Msg, message) ->
+            ok = emqx_hooks:run('message.acked', [Msg]),
             Inflight1 = emqx_inflight:delete(PacketId, Inflight),
             dequeue(Session#session{inflight = Inflight1});
         {value, {_OtherPub, _Ts}} ->
@@ -398,6 +399,7 @@ puback(PacketId, Session = #session{inflight = Inflight}) ->
 pubrec(PacketId, Session = #session{inflight = Inflight}) ->
     case emqx_inflight:lookup(PacketId, Inflight) of
         {value, {Msg, _Ts}} when is_record(Msg, message) ->
+            ok = emqx_hooks:run('message.acked', [Msg]),
             Inflight1 = emqx_inflight:update(PacketId, {pubrel, os:timestamp()}, Inflight),
             {ok, Session#session{inflight = Inflight1}};
         {value, {pubrel, _Ts}} ->