diff --git a/src/emqx_relup.erl b/src/emqx_relup.erl index 66a5281da..cb71c6305 100644 --- a/src/emqx_relup.erl +++ b/src/emqx_relup.erl @@ -4,26 +4,31 @@ , post_release_downgrade/2 ]). +-define(INFO(FORMAT), io:format("[emqx_relup] " ++ FORMAT ++ "~n")). +-define(INFO(FORMAT, ARGS), io:format("[emqx_relup] " ++ FORMAT ++ "~n", ARGS)). + %% what to do after upgraded from a old release vsn. post_release_upgrade(_FromRelVsn, _) -> + ?INFO("emqx has been upgraded to ~s", [emqx_app:get_release()]), reload_components(). %% what to do after downgraded to a old release vsn. post_release_downgrade(_ToRelVsn, _) -> + ?INFO("emqx has been downgrade to ~s", [emqx_app:get_release()]), reload_components(). -ifdef(EMQX_ENTERPRISE). reload_components() -> - io:format("reloading resource providers ...~n"), + ?INFO("reloading resource providers ..."), emqx_rule_engine:load_providers(), - io:format("reloading module providers ...~n"), + ?INFO("reloading module providers ..."), emqx_modules:load_providers(), - io:format("loading plugins ...~n"), + ?INFO("loading plugins ..."), emqx_plugins:load(). -else. reload_components() -> - io:format("reloading resource providers ...~n"), + ?INFO("reloading resource providers ..."), emqx_rule_engine:load_providers(), - io:format("loading plugins ...~n"), + ?INFO("loading plugins ..."), emqx_plugins:load(). -endif.