From f16d56c8b911e5af4881e376008e6d00918a5ee9 Mon Sep 17 00:00:00 2001
From: Feng Lee <ery.lee@gmail.com>
Date: Sun, 18 Jan 2015 11:36:21 +0800
Subject: [PATCH] retained messages

---
 apps/emqtt/src/emqtt_server.erl | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/apps/emqtt/src/emqtt_server.erl b/apps/emqtt/src/emqtt_server.erl
index c464656e3..6cc58a14d 100644
--- a/apps/emqtt/src/emqtt_server.erl
+++ b/apps/emqtt/src/emqtt_server.erl
@@ -71,7 +71,9 @@ retain(Msg = #mqtt_message{retain = true}) ->
 
 %% 
 subscribe(Topics, CPid) when is_pid(CPid) ->
+    lager:info("Retained Topics: ~p", [match(Topics)]),
     RetainedMsgs = lists:flatten([mnesia:dirty_read(?RETAINED_TAB, Topic) || Topic <- match(Topics)]),
+    lager:info("Retained Messages: ~p", [RetainedMsgs]),
     lists:foreach(fun(Msg) -> 
                 CPid ! {dispatch, {self(), retained_msg(Msg)}}
         end, RetainedMsgs).