From 3a8ada21e0e6f636a48787fa08c91364b5f67fe2 Mon Sep 17 00:00:00 2001
From: Feng <ery.lee@gmail.com>
Date: Mon, 7 Dec 2015 21:30:58 +0800
Subject: [PATCH] dispatch

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

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