From 40faeddd0e7748c88314a3202c622cfcdd3ba415 Mon Sep 17 00:00:00 2001 From: Ery Lee Date: Wed, 14 Jan 2015 14:15:06 +0800 Subject: [PATCH] session: reverse cached masseges --- apps/emqtt/src/emqtt_session.erl | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/apps/emqtt/src/emqtt_session.erl b/apps/emqtt/src/emqtt_session.erl index 373bbf551..72c2757fb 100644 --- a/apps/emqtt/src/emqtt_session.erl +++ b/apps/emqtt/src/emqtt_session.erl @@ -195,7 +195,7 @@ handle_cast({resume, ClientId, ClientPid}, State = #session_state { expire_timer = ETimer}) -> lager:info("Session: client ~s resumed by ~p", [ClientId, ClientPid]), 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}, {noreply, NewState};