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

emqttd:env

This commit is contained in:
Feng Lee 2016-10-11 10:09:29 +08:00
parent 113bfc73a8
commit 14ba1e1c89
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/emqttd_app.erl
View File

@ -167,7 +167,7 @@ is_mod_enabled(Name) -> lists:keyfind(Name, 2, gen_conf:list(emqttd, module)).
%% @doc Start Listeners of the broker. %% @doc Start Listeners of the broker.
-spec(start_listeners() -> any()). -spec(start_listeners() -> any()).
start_listeners() -> lists:foreach(fun start_listener/1, env(listeners, [])). start_listeners() -> lists:foreach(fun start_listener/1, emqttd:env(listeners, [])).
%% Start mqtt listener %% Start mqtt listener
-spec(start_listener(listener()) -> any()). -spec(start_listener(listener()) -> any()).
@ -201,7 +201,7 @@ merge_sockopts(Options) ->
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------
%% @doc Stop Listeners %% @doc Stop Listeners
stop_listeners() -> lists:foreach(fun stop_listener/1, env(listeners, [])). stop_listeners() -> lists:foreach(fun stop_listener/1, emqttd:env(listeners, [])).
%% @private %% @private
stop_listener({listener, tcp, ListenOn, _Opts}) -> esockd:close('mqtt/tcp', ListenOn); stop_listener({listener, tcp, ListenOn, _Opts}) -> esockd:close('mqtt/tcp', ListenOn);