yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix timer

This commit is contained in:
Feng Lee 2015-10-10 11:53:31 +08:00
parent a2bbceff3c
commit d63f043566
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/emqttd_retained.erl
View File

@ -149,10 +149,14 @@ dispatch(Topic, CPid) when is_binary(Topic) ->
init([]) -> init([]) ->
StatsFun = emqttd_stats:statsfun('retained/count', 'retained/max'), 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, {ok, #state{stats_fun = StatsFun,
expired_after = env(expired_after), expired_after = env(expired_after),
stats_timer = timer:send_interval(1000, stats), stats_timer = StatsTimer,
expire_timer = timer:send_interval(300 * 1000, expire)}}. expire_timer = ExpireTimer}}.
handle_call(_Request, _From, State) -> handle_call(_Request, _From, State) ->
{reply, ok, State}. {reply, ok, State}.