node_down clean_routes
This commit is contained in:
parent
1f1d8573f7
commit
fb50fbd13d
|
@ -480,7 +480,7 @@ cluster_node_down(_) ->
|
||||||
[<<"#">>, <<"a/b/c">>] = [Topic || #mqtt_route{topic = Topic} <- Routes],
|
[<<"#">>, <<"a/b/c">>] = [Topic || #mqtt_route{topic = Topic} <- Routes],
|
||||||
slave:stop(Z),
|
slave:stop(Z),
|
||||||
timer:sleep(1000),
|
timer:sleep(1000),
|
||||||
Routes = lists:sort(emqttd_router:match(<<"a/b/c">>)).
|
[] = lists:sort(emqttd_router:match(<<"a/b/c">>)).
|
||||||
|
|
||||||
set_alarms(_) ->
|
set_alarms(_) ->
|
||||||
AlarmTest = #mqtt_alarm{id = <<"1">>, severity = error, title="alarm title", summary="alarm summary"},
|
AlarmTest = #mqtt_alarm{id = <<"1">>, severity = error, title="alarm title", summary="alarm summary"},
|
||||||
|
|
Loading…
Reference in New Issue