support to start listeners when emqttd is running
This commit is contained in:
parent
aa6ae3ad8a
commit
9433e563fb
|
@ -239,4 +239,3 @@ merge_sockopts_test_() ->
|
||||||
?_assert(merge_sockopts(Opts) == [{sockopts, ?MQTT_SOCKOPTS} | Opts]).
|
?_assert(merge_sockopts(Opts) == [{sockopts, ?MQTT_SOCKOPTS} | Opts]).
|
||||||
|
|
||||||
-endif.
|
-endif.
|
||||||
|
|
||||||
|
|
|
@ -479,11 +479,17 @@ listeners([]) ->
|
||||||
end, Info)
|
end, Info)
|
||||||
end, esockd:listeners());
|
end, esockd:listeners());
|
||||||
|
|
||||||
|
listeners(["start", Proto, ListenOn]) ->
|
||||||
|
ListenOn1 = listenon_tokens(ListenOn),
|
||||||
|
case emqttd_app:start_listener({list_to_atom(Proto), ListenOn1, []}) of
|
||||||
|
{ok, _Pid} ->
|
||||||
|
io:format("Start ~s listener on ~s successfully.~n", [Proto, ListenOn]);
|
||||||
|
{error, Error} ->
|
||||||
|
io:format("Failed to Start ~s listener on ~s, error:~p~n", [Proto, ListenOn, Error])
|
||||||
|
end;
|
||||||
|
|
||||||
listeners(["restart", Proto, ListenOn]) ->
|
listeners(["restart", Proto, ListenOn]) ->
|
||||||
ListenOn1 = case string:tokens(ListenOn, ":") of
|
ListenOn1 = listenon_tokens(ListenOn),
|
||||||
[Port] -> list_to_integer(Port);
|
|
||||||
[IP, Port] -> {IP, list_to_integer(Port)}
|
|
||||||
end,
|
|
||||||
case emqttd_app:restart_listener({list_to_atom(Proto), ListenOn1, []}) of
|
case emqttd_app:restart_listener({list_to_atom(Proto), ListenOn1, []}) of
|
||||||
{ok, _Pid} ->
|
{ok, _Pid} ->
|
||||||
io:format("Restart ~s listener on ~s successfully.~n", [Proto, ListenOn]);
|
io:format("Restart ~s listener on ~s successfully.~n", [Proto, ListenOn]);
|
||||||
|
@ -492,10 +498,7 @@ listeners(["restart", Proto, ListenOn]) ->
|
||||||
end;
|
end;
|
||||||
|
|
||||||
listeners(["stop", Proto, ListenOn]) ->
|
listeners(["stop", Proto, ListenOn]) ->
|
||||||
ListenOn1 = case string:tokens(ListenOn, ":") of
|
ListenOn1 = listenon_tokens(ListenOn),
|
||||||
[Port] -> list_to_integer(Port);
|
|
||||||
[IP, Port] -> {IP, list_to_integer(Port)}
|
|
||||||
end,
|
|
||||||
case emqttd_app:stop_listener({list_to_atom(Proto), ListenOn1, []}) of
|
case emqttd_app:stop_listener({list_to_atom(Proto), ListenOn1, []}) of
|
||||||
ok ->
|
ok ->
|
||||||
io:format("Stop ~s listener on ~s successfully.~n", [Proto, ListenOn]);
|
io:format("Stop ~s listener on ~s successfully.~n", [Proto, ListenOn]);
|
||||||
|
@ -605,3 +608,9 @@ format(_, Val) ->
|
||||||
Val.
|
Val.
|
||||||
|
|
||||||
bin(S) -> iolist_to_binary(S).
|
bin(S) -> iolist_to_binary(S).
|
||||||
|
|
||||||
|
listenon_tokens(ListenOn) ->
|
||||||
|
case string:tokens(ListenOn, ":") of
|
||||||
|
[Port] -> {"0.0.0.0", list_to_integer(Port)};
|
||||||
|
[IP, Port] -> {IP, list_to_integer(Port)}
|
||||||
|
end.
|
||||||
|
|
Loading…
Reference in New Issue