diff options
| author | Gerhard Lazu <gerhard@lazu.co.uk> | 2020-03-17 11:59:41 +0000 |
|---|---|---|
| committer | Jean-Sébastien Pédron <jean-sebastien@rabbitmq.com> | 2020-04-09 15:43:10 +0200 |
| commit | 9772aa8f8256a410bcc13ae5038f949ffe1d5b84 (patch) | |
| tree | da098cc7fadf654a11b6a693cf3e2835be93065d /test | |
| parent | 3b253f4e02d079ef80f5b2423b846daa6500b848 (diff) | |
| download | rabbitmq-server-git-9772aa8f8256a410bcc13ae5038f949ffe1d5b84.tar.gz | |
Remove dead_queue_rejects test flake
- It's not helping anyone in the current state
- I don't have enough context to be able to fix it
- I need to stay focused on the current task, cannot afford to context switch
- Feel free to fix it if it's important, otherwise leave it deleted
cc @michaelklishin @dumbbell
Signed-off-by: Gerhard Lazu <gerhard@lazu.co.uk>
Diffstat (limited to 'test')
| -rw-r--r-- | test/confirms_rejects_SUITE.erl | 37 |
1 files changed, 0 insertions, 37 deletions
diff --git a/test/confirms_rejects_SUITE.erl b/test/confirms_rejects_SUITE.erl index 402bca8737..db5e6b981a 100644 --- a/test/confirms_rejects_SUITE.erl +++ b/test/confirms_rejects_SUITE.erl @@ -19,7 +19,6 @@ groups() -> {parallel_tests, [parallel], [ {overflow_reject_publish_dlx, [parallel], OverflowTests}, {overflow_reject_publish, [parallel], OverflowTests}, - dead_queue_rejects, mixed_dead_alive_queues_reject ]} ]. @@ -65,7 +64,6 @@ init_per_testcase(policy_resets_to_default = Testcase, Config) -> rabbit_ct_helpers:set_config(Config, [{conn, Conn}]), Testcase); init_per_testcase(Testcase, Config) when Testcase == confirms_rejects_conflict; - Testcase == dead_queue_rejects; Testcase == mixed_dead_alive_queues_reject -> Conn = rabbit_ct_client_helpers:open_unmanaged_connection(Config), Conn1 = rabbit_ct_client_helpers:open_unmanaged_connection(Config), @@ -92,10 +90,6 @@ end_per_testcase(confirms_rejects_conflict = Testcase, Config) -> QueueName = <<"confirms_rejects_conflict", "_", XOverflow/binary>>, amqp_channel:call(Ch, #'queue.delete'{queue = QueueName}), end_per_testcase0(Testcase, Config); -end_per_testcase(dead_queue_rejects = Testcase, Config) -> - {_, Ch} = rabbit_ct_client_helpers:open_connection_and_channel(Config, 0), - amqp_channel:call(Ch, #'queue.delete'{queue = <<"dead_queue_rejects">>}), - end_per_testcase0(Testcase, Config); end_per_testcase(mixed_dead_alive_queues_reject = Testcase, Config) -> {_, Ch} = rabbit_ct_client_helpers:open_connection_and_channel(Config, 0), amqp_channel:call(Ch, #'queue.delete'{queue = <<"mixed_dead_alive_queues_reject_dead">>}), @@ -116,37 +110,6 @@ end_per_testcase0(Testcase, Config) -> rabbit_ct_helpers:testcase_finished(Config, Testcase). -dead_queue_rejects(Config) -> - Conn = ?config(conn, Config), - {ok, Ch} = amqp_connection:open_channel(Conn), - QueueName = <<"dead_queue_rejects">>, - amqp_channel:call(Ch, #'confirm.select'{}), - amqp_channel:register_confirm_handler(Ch, self()), - - amqp_channel:call(Ch, #'queue.declare'{queue = QueueName, - durable = true}), - - amqp_channel:call(Ch, #'basic.publish'{routing_key = QueueName}, - #amqp_msg{payload = <<"HI">>}), - - receive - {'basic.ack',_,_} -> ok - after 10000 -> - error(timeout_waiting_for_initial_ack) - end, - - kill_the_queue(QueueName, Config), - - amqp_channel:call(Ch, #'basic.publish'{routing_key = QueueName}, - #amqp_msg{payload = <<"HI">>}), - - receive - {'basic.ack',_,_} -> error(expecting_nack_got_ack); - {'basic.nack',_,_,_} -> ok - after 10000 -> - error(timeout_waiting_for_nack) - end. - mixed_dead_alive_queues_reject(Config) -> Conn = ?config(conn, Config), {ok, Ch} = amqp_connection:open_channel(Conn), |
