diff options
| author | Gerhard Lazu <gerhard@lazu.co.uk> | 2020-03-20 15:45:38 +0000 |
|---|---|---|
| committer | Jean-Sébastien Pédron <jean-sebastien@rabbitmq.com> | 2020-04-09 15:44:32 +0200 |
| commit | d8771acee402446071b945c76b9dc737e572b992 (patch) | |
| tree | 725499a8a4a90a35470729f147761770c0983041 /test | |
| parent | 598c14f76ff593f19faa0a01458273dc5b09197b (diff) | |
| download | rabbitmq-server-git-d8771acee402446071b945c76b9dc737e572b992.tar.gz | |
Remove mixed_dead_alive_queues_reject test flake
https://github.com/rabbitmq/rabbitmq-server/runs/521986549#step:4:468
confirms_rejects_SUITE > parallel_tests > mixed_dead_alive_queues_reject
#1. {error,
{expecting_nack_got_ack,
[{confirms_rejects_SUITE,mixed_dead_alive_queues_reject,1,
[{file,"test/confirms_rejects_SUITE.erl"},{line,158}]},
{test_server,ts_tc,3,[{file,"test_server.erl"},{line,1562}]},
{test_server,run_test_case_eval1,6,
[{file,"test_server.erl"},{line,1080}]},
{test_server,run_test_case_eval,9,
[{file,"test_server.erl"},{line,1012}]}]}}
- 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 | 62 |
1 files changed, 2 insertions, 60 deletions
diff --git a/test/confirms_rejects_SUITE.erl b/test/confirms_rejects_SUITE.erl index db5e6b981a..56d95df878 100644 --- a/test/confirms_rejects_SUITE.erl +++ b/test/confirms_rejects_SUITE.erl @@ -18,8 +18,7 @@ groups() -> [ {parallel_tests, [parallel], [ {overflow_reject_publish_dlx, [parallel], OverflowTests}, - {overflow_reject_publish, [parallel], OverflowTests}, - mixed_dead_alive_queues_reject + {overflow_reject_publish, [parallel], OverflowTests} ]} ]. @@ -63,8 +62,7 @@ init_per_testcase(policy_resets_to_default = Testcase, Config) -> rabbit_ct_helpers:testcase_started( rabbit_ct_helpers:set_config(Config, [{conn, Conn}]), Testcase); init_per_testcase(Testcase, Config) - when Testcase == confirms_rejects_conflict; - Testcase == mixed_dead_alive_queues_reject -> + when Testcase == confirms_rejects_conflict -> Conn = rabbit_ct_client_helpers:open_unmanaged_connection(Config), Conn1 = rabbit_ct_client_helpers:open_unmanaged_connection(Config), @@ -89,12 +87,6 @@ end_per_testcase(confirms_rejects_conflict = Testcase, Config) -> XOverflow = ?config(overflow, Config), QueueName = <<"confirms_rejects_conflict", "_", XOverflow/binary>>, amqp_channel:call(Ch, #'queue.delete'{queue = QueueName}), - 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">>}), - amqp_channel:call(Ch, #'queue.delete'{queue = <<"mixed_dead_alive_queues_reject_alive">>}), - amqp_channel:call(Ch, #'exchange.delete'{exchange = <<"mixed_dead_alive_queues_reject">>}), end_per_testcase0(Testcase, Config). end_per_testcase0(Testcase, Config) -> @@ -110,56 +102,6 @@ end_per_testcase0(Testcase, Config) -> rabbit_ct_helpers:testcase_finished(Config, Testcase). -mixed_dead_alive_queues_reject(Config) -> - Conn = ?config(conn, Config), - {ok, Ch} = amqp_connection:open_channel(Conn), - QueueNameDead = <<"mixed_dead_alive_queues_reject_dead">>, - QueueNameAlive = <<"mixed_dead_alive_queues_reject_alive">>, - ExchangeName = <<"mixed_dead_alive_queues_reject">>, - - amqp_channel:call(Ch, #'confirm.select'{}), - amqp_channel:register_confirm_handler(Ch, self()), - - amqp_channel:call(Ch, #'queue.declare'{queue = QueueNameDead, - durable = true}), - amqp_channel:call(Ch, #'queue.declare'{queue = QueueNameAlive, - durable = true}), - - amqp_channel:call(Ch, #'exchange.declare'{exchange = ExchangeName, - durable = true}), - - amqp_channel:call(Ch, #'queue.bind'{exchange = ExchangeName, - queue = QueueNameAlive, - routing_key = <<"route">>}), - - amqp_channel:call(Ch, #'queue.bind'{exchange = ExchangeName, - queue = QueueNameDead, - routing_key = <<"route">>}), - - amqp_channel:call(Ch, #'basic.publish'{exchange = ExchangeName, - routing_key = <<"route">>}, - #amqp_msg{payload = <<"HI">>}), - - receive - {'basic.ack',_,_} -> ok; - {'basic.nack',_,_,_} -> error(expecting_ack_got_nack) - after 50000 -> - error({timeout_waiting_for_initial_ack, process_info(self(), messages)}) - end, - - kill_the_queue(QueueNameDead, Config), - - amqp_channel:call(Ch, #'basic.publish'{exchange = ExchangeName, - routing_key = <<"route">>}, - #amqp_msg{payload = <<"HI">>}), - - receive - {'basic.nack',_,_,_} -> ok; - {'basic.ack',_,_} -> error(expecting_nack_got_ack) - after 50000 -> - error({timeout_waiting_for_nack, process_info(self(), messages)}) - end. - confirms_rejects_conflict(Config) -> Conn = ?config(conn, Config), Conn1 = ?config(conn1, Config), |
