diff --git a/src/emqttd_retainer.erl b/src/emqttd_retainer.erl
index 1b033f5fd..00523f259 100644
--- a/src/emqttd_retainer.erl
+++ b/src/emqttd_retainer.erl
@@ -142,7 +142,7 @@ dispatch(Topic, CPid) when is_binary(Topic) ->
             end,
             mnesia:async_dirty(fun mnesia:foldl/3, [Fun, [], retained])
     end,
-    lists:foreach(fun(Msg) -> CPid ! {dispatch, Msg} end, lists:reverse(Msgs)).
+    lists:foreach(fun(Msg) -> CPid ! {dispatch, Topic, Msg} end, lists:reverse(Msgs)).
 
 %%%=============================================================================
 %%% gen_server callbacks