shutdown, keepalive_timeout

This commit is contained in:
Ery Lee 2015-01-14 18:25:59 +08:00
parent 8391eeb1dd
commit 890b429fad
1 changed files with 1 additions and 1 deletions

View File

@ -126,7 +126,7 @@ handle_info({keepalive, timeout}, State = #state { keepalive = KeepAlive }) ->
case emqtt_keepalive:resume(KeepAlive) of
timeout ->
lager:info("Client ~s: Keepalive Timeout!", [State#state.peer_name]),
{stop, normal, State};
stop({shutdown, keepalive_timeout}, State);
{resumed, KeepAlive1} ->
lager:info("Client ~s: Keepalive Resumed", [State#state.peer_name]),
{noreply, State#state{ keepalive = KeepAlive1 }}