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

dispatch

This commit is contained in:
Feng 2015-12-07 21:30:58 +08:00
parent 3d8e91bc20
commit 3a8ada21e0
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/emqttd_retainer.erl
View File

@ -142,7 +142,7 @@ dispatch(Topic, CPid) when is_binary(Topic) ->
end, end,
mnesia:async_dirty(fun mnesia:foldl/3, [Fun, [], retained]) mnesia:async_dirty(fun mnesia:foldl/3, [Fun, [], retained])
end, end,
lists:foreach(fun(Msg) -> CPid ! {dispatch, Msg} end, lists:reverse(Msgs)). lists:foreach(fun(Msg) -> CPid ! {dispatch, Topic, Msg} end, lists:reverse(Msgs)).
%%%============================================================================= %%%=============================================================================
%%% gen_server callbacks %%% gen_server callbacks