diff options
| author | Luke Bakken <luke@bakken.io> | 2021-12-01 06:57:25 -0800 |
|---|---|---|
| committer | Luke Bakken <luke@bakken.io> | 2021-12-01 06:57:25 -0800 |
| commit | 9ff201c3ab5e39297caca53fe535c75d5e45ace4 (patch) | |
| tree | 85e91541a3ede9d74c67306e636d82e6ff17dc4e | |
| parent | b5aecbd3e5469fee99e097d80ebb8e59ec00fd41 (diff) | |
| download | rabbitmq-server-git-9ff201c3ab5e39297caca53fe535c75d5e45ace4.tar.gz | |
Remove flaky assertion
Thanks @kjnilsson
| -rw-r--r-- | deps/rabbit/test/quorum_queue_SUITE.erl | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/deps/rabbit/test/quorum_queue_SUITE.erl b/deps/rabbit/test/quorum_queue_SUITE.erl index 6b21c1e813..ab271a169b 100644 --- a/deps/rabbit/test/quorum_queue_SUITE.erl +++ b/deps/rabbit/test/quorum_queue_SUITE.erl @@ -2795,9 +2795,6 @@ cancel_consumer_gh_3729(Config) -> ok = cancel(Ch), - D = #'queue.declare'{queue = QQ, passive = true, arguments = [{<<"x-queue-type">>, longstr, <<"quorum">>}]}, - #'queue.declare_ok'{queue = QQ, message_count = 0, consumer_count = 1} = amqp_channel:call(Ch, D), - receive #'basic.cancel_ok'{consumer_tag = <<"ctag">>} -> ok after 5000 -> @@ -2805,6 +2802,8 @@ cancel_consumer_gh_3729(Config) -> ct:fail("basic.cancel_ok timeout") end, + D = #'queue.declare'{queue = QQ, passive = true, arguments = [{<<"x-queue-type">>, longstr, <<"quorum">>}]}, + F = fun() -> #'queue.declare_ok'{queue = QQ, message_count = MC, |