Update test expectations
This commit is contained in:
parent
c09ac9e37a
commit
5ab256d42c
|
|
@ -100,9 +100,9 @@ federation_links(Config) ->
|
||||||
%% Verify we have 5 running links and 5 down links
|
%% Verify we have 5 running links and 5 down links
|
||||||
wait_until(fun() ->
|
wait_until(fun() ->
|
||||||
AllLinks = http_get(Config, "/federation-links"),
|
AllLinks = http_get(Config, "/federation-links"),
|
||||||
Result = [{maps:get(<<"exchange">>, Link),
|
Result = [{maps:get(exchange, Link),
|
||||||
maps:get(<<"upstream">>, Link),
|
maps:get(upstream, Link),
|
||||||
maps:get(<<"status">>, Link)} || Link <- AllLinks],
|
maps:get(status, Link)} || Link <- AllLinks],
|
||||||
Verify(Result)
|
Verify(Result)
|
||||||
end).
|
end).
|
||||||
|
|
||||||
|
|
@ -121,9 +121,9 @@ federation_down_links(Config) ->
|
||||||
end,
|
end,
|
||||||
wait_until(fun() ->
|
wait_until(fun() ->
|
||||||
AllLinks = http_get(Config, "/federation-links/state/down"),
|
AllLinks = http_get(Config, "/federation-links/state/down"),
|
||||||
Result = [{maps:get(<<"exchange">>, Link),
|
Result = [{maps:get(exchange, Link),
|
||||||
maps:get(<<"upstream">>, Link),
|
maps:get(upstream, Link),
|
||||||
maps:get(<<"status">>, Link)} || Link <- AllLinks],
|
maps:get(status, Link)} || Link <- AllLinks],
|
||||||
Verify(Result)
|
Verify(Result)
|
||||||
end).
|
end).
|
||||||
|
|
||||||
|
|
@ -167,7 +167,7 @@ wait_until(Fun, N) ->
|
||||||
|
|
||||||
restart_uri(Link) ->
|
restart_uri(Link) ->
|
||||||
"/federation-links/vhost/%2f/" ++
|
"/federation-links/vhost/%2f/" ++
|
||||||
binary_to_list(maps:get(<<"id">>, Link)) ++ "/restart".
|
binary_to_list(maps:get(id, Link)) ++ "/restart".
|
||||||
|
|
||||||
%% -------------------------------------------------------------------
|
%% -------------------------------------------------------------------
|
||||||
%% Helpers from rabbitmq_management tests
|
%% Helpers from rabbitmq_management tests
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue