diff options
| author | kjnilsson <knilsson@pivotal.io> | 2021-03-24 14:17:34 +0000 |
|---|---|---|
| committer | kjnilsson <knilsson@pivotal.io> | 2021-03-24 14:17:34 +0000 |
| commit | 8d8b67bb34792436a3a77b3d042fffe1614b64fb (patch) | |
| tree | 6d363f5afd9e562c40b89918a125d23acf105b51 | |
| parent | 43ab84a248441ccf8ace6605d0413916ed61e048 (diff) | |
| download | rabbitmq-server-git-8d8b67bb34792436a3a77b3d042fffe1614b64fb.tar.gz | |
fix rabbit_fifo_int_SUITE
| -rw-r--r-- | deps/rabbit/test/rabbit_fifo_int_SUITE.erl | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/deps/rabbit/test/rabbit_fifo_int_SUITE.erl b/deps/rabbit/test/rabbit_fifo_int_SUITE.erl index 1474c6b88d..ec40d599f5 100644 --- a/deps/rabbit/test/rabbit_fifo_int_SUITE.erl +++ b/deps/rabbit/test/rabbit_fifo_int_SUITE.erl @@ -9,6 +9,7 @@ -include_lib("rabbit_common/include/rabbit.hrl"). -define(RA_EVENT_TIMEOUT, 5000). +-define(RA_SYSTEM, quorum_queues). all() -> [ @@ -48,6 +49,8 @@ init_per_group(_, Config) -> ok = application:set_env(ra, data_dir, PrivDir), application:ensure_all_started(ra), application:ensure_all_started(lg), + SysCfg = ra_system:default_config(), + ra_system:start(SysCfg#{name => ?RA_SYSTEM}), Config. end_per_group(_, Config) -> @@ -61,7 +64,7 @@ init_per_testcase(TestCase, Config) -> meck:expect(rabbit_quorum_queue, file_handle_other_reservation, fun () -> ok end), meck:expect(rabbit_quorum_queue, cancel_consumer_handler, fun (_, _) -> ok end), - ra_server_sup_sup:remove_all(), + ra_server_sup_sup:remove_all(?RA_SYSTEM), ServerName2 = list_to_atom(atom_to_list(TestCase) ++ "2"), ServerName3 = list_to_atom(atom_to_list(TestCase) ++ "3"), ClusterName = rabbit_misc:r("/", queue, atom_to_binary(TestCase, utf8)), @@ -641,7 +644,8 @@ validate_process_down(Name, Num) -> end. start_cluster(ClusterName, ServerIds, RaFifoConfig) -> - {ok, Started, _} = ra:start_cluster(ClusterName#resource.name, + {ok, Started, _} = ra:start_cluster(?RA_SYSTEM, + ClusterName#resource.name, {module, rabbit_fifo, RaFifoConfig}, ServerIds), ?assertEqual(length(Started), length(ServerIds)), |