summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMichael Klishin <klishinm@vmware.com>2021-12-01 18:53:34 +0300
committerGitHub <noreply@github.com>2021-12-01 18:53:34 +0300
commitd95eb3b87d9fa9b265020066a302643e3e0a5389 (patch)
tree85e91541a3ede9d74c67306e636d82e6ff17dc4e
parentb5aecbd3e5469fee99e097d80ebb8e59ec00fd41 (diff)
parent9ff201c3ab5e39297caca53fe535c75d5e45ace4 (diff)
downloadrabbitmq-server-git-d95eb3b87d9fa9b265020066a302643e3e0a5389.tar.gz
Merge pull request #3820 from rabbitmq/lukebakken/fix-flaky-gh-3729-test
Remove flaky assertion
-rw-r--r--deps/rabbit/test/quorum_queue_SUITE.erl5
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,