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

Load plugins after autocluster

This commit is contained in:
Feng Lee 2017-07-21 13:07:04 +08:00
parent 041b9100ed
commit c1bce429d9
1 changed files with 10 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/emqttd_app.erl
View File

@ -44,9 +44,7 @@ start(_Type, _Args) ->
start_servers(Sup), start_servers(Sup),
emqttd_cli:load(), emqttd_cli:load(),
register_acl_mod(), register_acl_mod(),
emqttd_plugins:init(), start_autocluster(),
emqttd_plugins:load(),
cluster_bootstrap(),
register(emqttd, self()), register(emqttd, self()),
print_vsn(), print_vsn(),
{ok, Sup}. {ok, Sup}.
@ -147,14 +145,19 @@ register_acl_mod() ->
end. end.
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------
%% Cluster bootstrap %% AutoCluster
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------
cluster_bootstrap() -> start_autocluster() ->
ekka:callback(prepare, fun emqttd:shutdown/1), ekka:callback(prepare, fun emqttd:shutdown/1),
ekka:callback(reboot, fun emqttd:reboot/0), ekka:callback(reboot, fun emqttd:reboot/0),
Callback = fun() -> ekka_autocluster:start(fun start_listeners/0) end, Fun = fun() -> ekka_autocluster:start(fun after_autocluster/0) end,
run_outside_application(5000, Callback). run_outside_application(5000, Fun).
after_autocluster() ->
emqttd_plugins:init(),
emqttd_plugins:load(),
start_listeners().
run_outside_application(Delay, Callback) -> run_outside_application(Delay, Callback) ->
spawn(fun() -> spawn(fun() ->