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

session: reverse cached masseges

This commit is contained in:
Ery Lee 2015-01-14 14:15:06 +08:00
parent b10c9c7dfe
commit 40faeddd0e
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqtt/src/emqtt_session.erl
View File

@ -195,7 +195,7 @@ handle_cast({resume, ClientId, ClientPid}, State = #session_state {
expire_timer = ETimer}) -> expire_timer = ETimer}) ->
lager:info("Session: client ~s resumed by ~p", [ClientId, ClientPid]), lager:info("Session: client ~s resumed by ~p", [ClientId, ClientPid]),
erlang:cancel_timer(ETimer), erlang:cancel_timer(ETimer),
[ClientPid ! {dispatch, {self(), Message}} || Message <- Messages], [ClientPid ! {dispatch, {self(), Message}} || Message <- lists:reverse(Messages)],
NewState = State#session_state{ client_pid = ClientPid, messages = [], expire_timer = undefined}, NewState = State#session_state{ client_pid = ClientPid, messages = [], expire_timer = undefined},
{noreply, NewState}; {noreply, NewState};