cannot stop emqttd
This commit is contained in:
parent
ad1f3ca44a
commit
741ebf2ae1
|
@ -1,7 +1,7 @@
|
||||||
{application, emqttd,
|
{application, emqttd,
|
||||||
[
|
[
|
||||||
{description, "Erlang MQTT Broker"},
|
{description, "Erlang MQTT Broker"},
|
||||||
{vsn, "0.10.0"},
|
{vsn, "0.10.1"},
|
||||||
{modules, []},
|
{modules, []},
|
||||||
{registered, []},
|
{registered, []},
|
||||||
{applications, [kernel,
|
{applications, [kernel,
|
||||||
|
|
|
@ -134,10 +134,7 @@ worker_spec(Name, Opts) ->
|
||||||
|
|
||||||
%% close all listeners first...
|
%% close all listeners first...
|
||||||
prep_stop(State) ->
|
prep_stop(State) ->
|
||||||
stop_listeners(),
|
stop_listeners(),
|
||||||
timer:sleep(2),
|
|
||||||
emqttd_plugins:unload(),
|
|
||||||
timer:sleep(2),
|
|
||||||
State.
|
State.
|
||||||
|
|
||||||
stop_listeners() ->
|
stop_listeners() ->
|
||||||
|
|
|
@ -79,6 +79,7 @@ cluster([SNode]) ->
|
||||||
pong ->
|
pong ->
|
||||||
case emqttd:is_running(Node) of
|
case emqttd:is_running(Node) of
|
||||||
true ->
|
true ->
|
||||||
|
emqttd_plugins:unload(),
|
||||||
application:stop(emqttd),
|
application:stop(emqttd),
|
||||||
application:stop(esockd),
|
application:stop(esockd),
|
||||||
application:stop(gproc),
|
application:stop(gproc),
|
||||||
|
|
Loading…
Reference in New Issue