From d63f043566d0b6fc7b2d30b2cdda821d09d92d25 Mon Sep 17 00:00:00 2001
From: Feng Lee <ery.lee@gmail.com>
Date: Sat, 10 Oct 2015 11:53:31 +0800
Subject: [PATCH] fix timer

---
 src/emqttd_retained.erl | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/src/emqttd_retained.erl b/src/emqttd_retained.erl
index 29e83d52c..87a1193a2 100644
--- a/src/emqttd_retained.erl
+++ b/src/emqttd_retained.erl
@@ -149,10 +149,14 @@ dispatch(Topic, CPid) when is_binary(Topic) ->
 
 init([]) ->
     StatsFun = emqttd_stats:statsfun('retained/count', 'retained/max'),
+    %% One second
+    {ok, StatsTimer}  = timer:send_interval(1000, stats),
+    %% Five minutes
+    {ok, ExpireTimer} = timer:send_interval(300 * 1000, expire),
     {ok, #state{stats_fun     = StatsFun,
                 expired_after = env(expired_after),
-                stats_timer   = timer:send_interval(1000, stats),
-                expire_timer  = timer:send_interval(300 * 1000, expire)}}.
+                stats_timer   = StatsTimer,
+                expire_timer  = ExpireTimer}}.
 
 handle_call(_Request, _From, State) ->
     {reply, ok, State}.