diff options
Diffstat (limited to 'test')
| -rw-r--r-- | test/rabbit_fifo_int_SUITE.erl | 24 |
1 files changed, 14 insertions, 10 deletions
diff --git a/test/rabbit_fifo_int_SUITE.erl b/test/rabbit_fifo_int_SUITE.erl index 5790964c91..b51975b062 100644 --- a/test/rabbit_fifo_int_SUITE.erl +++ b/test/rabbit_fifo_int_SUITE.erl @@ -475,24 +475,28 @@ test_queries(Config) -> ClusterName = ?config(cluster_name, Config), ServerId = ?config(node_id, Config), ok = start_cluster(ClusterName, [ServerId]), + Self = self(), P = spawn(fun () -> F0 = rabbit_fifo_client:init(ClusterName, [ServerId], 4), {ok, F1} = rabbit_fifo_client:enqueue(m1, F0), {ok, F2} = rabbit_fifo_client:enqueue(m2, F1), process_ra_events(receive_ra_events(2, 0), F2), - receive stop -> ok end + Self ! ready, + receive stop -> ok end end), F0 = rabbit_fifo_client:init(ClusterName, [ServerId], 4), + ok = receive ready -> ok after 5000 -> timeout end, {ok, _} = rabbit_fifo_client:checkout(<<"tag">>, 1, undefined, F0), - {ok, {_, Ready}, _} = ra:local_query(ServerId, - fun rabbit_fifo:query_messages_ready/1), - ?assertEqual(1, Ready), - {ok, {_, Checked}, _} = ra:local_query(ServerId, - fun rabbit_fifo:query_messages_checked_out/1), - ?assertEqual(1, Checked), - {ok, {_, Processes}, _} = ra:local_query(ServerId, - fun rabbit_fifo:query_processes/1), - ?assertEqual(2, length(Processes)), + ?assertMatch({ok, {_RaIdxTerm, 1}, _Leader}, + ra:local_query(ServerId, + fun rabbit_fifo:query_messages_ready/1)), + ?assertMatch({ok, {_RaIdxTerm, 1}, _Leader}, + ra:local_query(ServerId, + fun rabbit_fifo:query_messages_checked_out/1)), + ?assertMatch({ok, {_RaIdxTerm, Processes}, _Leader} + when length(Processes) == 2, + ra:local_query(ServerId, + fun rabbit_fifo:query_processes/1)), P ! stop, ra:stop_server(ServerId), ok. |