diff --git a/src/emqx_session.erl b/src/emqx_session.erl
index 14ed2a21d..ad3e66cc5 100644
--- a/src/emqx_session.erl
+++ b/src/emqx_session.erl
@@ -806,7 +806,7 @@ await(PacketId, Msg, State = #state{inflight = Inflight}) ->
 acked(puback, PacketId, State = #state{client_id = ClientId, inflight  = Inflight}) ->
     case emqx_inflight:lookup(PacketId, Inflight) of
         {value, {publish, {_, Msg}, _Ts}} ->
-            emqx_hooks:run('message.acked', [#{client_id =>ClientId}], Msg),
+            emqx_hooks:run('message.acked', [#{client_id => ClientId}], Msg),
             State#state{inflight = emqx_inflight:delete(PacketId, Inflight)};
         none ->
             ?LOG(warning, "Duplicated PUBACK PacketId ~w", [PacketId], State),
@@ -816,7 +816,7 @@ acked(puback, PacketId, State = #state{client_id = ClientId, inflight  = Infligh
 acked(pubrec, PacketId, State = #state{client_id = ClientId, inflight  = Inflight}) ->
     case emqx_inflight:lookup(PacketId, Inflight) of
         {value, {publish, {_, Msg}, _Ts}} ->
-            emqx_hooks:run('message.acked', [ClientId], Msg),
+            emqx_hooks:run('message.acked', [#{client_id => ClientId}], Msg),
             State#state{inflight = emqx_inflight:update(PacketId, {pubrel, PacketId, os:timestamp()}, Inflight)};
         {value, {pubrel, PacketId, _Ts}} ->
             ?LOG(warning, "Duplicated PUBREC PacketId ~w", [PacketId], State),