diff options
| author | Jean-Sébastien Pédron <jean-sebastien@rabbitmq.com> | 2020-11-03 13:57:45 +0100 |
|---|---|---|
| committer | Jean-Sébastien Pédron <jean-sebastien@rabbitmq.com> | 2020-11-03 13:57:45 +0100 |
| commit | 918031aafbd7e5beb486dc2e22b71a6d106b3411 (patch) | |
| tree | bfdb02f0dafc15510ec1e5aad1a0d96647f96c79 | |
| parent | 2bd19aafb531d9027ecc776222415d5583243c61 (diff) | |
| download | rabbitmq-server-git-918031aafbd7e5beb486dc2e22b71a6d106b3411.tar.gz | |
quorum_queue_SUITE: Delete `restart_queue` queue
| -rw-r--r-- | test/quorum_queue_SUITE.erl | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/test/quorum_queue_SUITE.erl b/test/quorum_queue_SUITE.erl index 29946dd81d..b79cd25490 100644 --- a/test/quorum_queue_SUITE.erl +++ b/test/quorum_queue_SUITE.erl @@ -482,7 +482,9 @@ restart_queue(Config) -> rpc:call(Server, application, which_applications, []))), Expected = Children + 1, ?assertMatch(Expected, - length(rpc:call(Server, supervisor, which_children, [ra_server_sup_sup]))). + length(rpc:call(Server, supervisor, which_children, [ra_server_sup_sup]))), + Ch2 = rabbit_ct_client_helpers:open_channel(Config, Server), + delete_queues(Ch2, [LQ]). idempotent_recover(Config) -> Server = rabbit_ct_broker_helpers:get_node_config(Config, 0, nodename), @@ -588,7 +590,8 @@ restart_all_types(Config) -> delete_queues(Ch2, [QQ1, QQ2, CQ1, CQ2]). delete_queues(Ch, Queues) -> - [amqp_channel:call(Ch, #'queue.delete'{queue = Q}) || Q <- Queues]. + [amqp_channel:call(Ch, #'queue.delete'{queue = Q}) || Q <- Queues], + ok. stop_start_rabbit_app(Config) -> %% Test start/stop of rabbit app with both types of queues (quorum and |