diff options
| author | Diana Corbacho <diana@rabbitmq.com> | 2019-03-27 10:37:58 +0000 |
|---|---|---|
| committer | Diana Corbacho <diana@rabbitmq.com> | 2019-03-27 10:37:58 +0000 |
| commit | 029594e4f3341b2949dae90b84e48e8c9fdd963c (patch) | |
| tree | d4f87e519fec7ffe66ad62edc2758e153f13eca1 /test | |
| parent | b56ca1c9de895c770b196ea46f887ee2abafb48c (diff) | |
| download | rabbitmq-server-git-029594e4f3341b2949dae90b84e48e8c9fdd963c.tar.gz | |
Use in memory limit for quorum queue tests
All should work as normal, only memory usage it's affected
[#164735591]
Diffstat (limited to 'test')
| -rw-r--r-- | test/queue_parallel_SUITE.erl | 26 |
1 files changed, 25 insertions, 1 deletions
diff --git a/test/queue_parallel_SUITE.erl b/test/queue_parallel_SUITE.erl index d57b3c3021..eba0965608 100644 --- a/test/queue_parallel_SUITE.erl +++ b/test/queue_parallel_SUITE.erl @@ -62,7 +62,9 @@ groups() -> [ {classic_queue, [parallel], AllTests ++ [delete_immediately_by_pid_succeeds]}, {mirrored_queue, [parallel], AllTests ++ [delete_immediately_by_pid_succeeds]}, - {quorum_queue, [parallel], AllTests ++ [delete_immediately_by_pid_fails]} + {quorum_queue, [parallel], AllTests ++ [delete_immediately_by_pid_fails]}, + {quorum_queue_in_memory_limit, [parallel], AllTests ++ [delete_immediately_by_pid_fails]}, + {quorum_queue_in_memory_bytes, [parallel], AllTests ++ [delete_immediately_by_pid_fails]} ]} ]. @@ -97,6 +99,28 @@ init_per_group(quorum_queue, Config) -> Skip -> Skip end; +init_per_group(quorum_queue_in_memory_limit, Config) -> + case rabbit_ct_broker_helpers:enable_feature_flag(Config, quorum_queue) of + ok -> + rabbit_ct_helpers:set_config( + Config, + [{queue_args, [{<<"x-queue-type">>, longstr, <<"quorum">>}, + {<<"x-max-in-memory-length">>, long, 1}]}, + {queue_durable, true}]); + Skip -> + Skip + end; +init_per_group(quorum_queue_in_memory_bytes, Config) -> + case rabbit_ct_broker_helpers:enable_feature_flag(Config, quorum_queue) of + ok -> + rabbit_ct_helpers:set_config( + Config, + [{queue_args, [{<<"x-queue-type">>, longstr, <<"quorum">>}, + {<<"x-max-in-memory-bytes">>, long, 1}]}, + {queue_durable, true}]); + Skip -> + Skip + end; init_per_group(mirrored_queue, Config) -> rabbit_ct_broker_helpers:set_ha_policy(Config, 0, <<"^max_length.*queue">>, <<"all">>, [{<<"ha-sync-mode">>, <<"automatic">>}]), |