summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMichael Klishin <michael@clojurewerkz.org>2021-11-24 18:04:35 +0300
committerMichael Klishin <michael@clojurewerkz.org>2021-11-24 18:04:35 +0300
commit4f09fd109c0192318803db8c1de599c43b6589f4 (patch)
tree86d1949fa9504497f219dd86cb277a2f32688232
parent6a08e143e94401bed05265975ef70242e5895977 (diff)
downloadrabbitmq-server-git-lukebakken/gh-3729.tar.gz
quorum_queue_SUITE: bump some timeoutslukebakken/gh-3729
-rw-r--r--deps/rabbit/test/quorum_queue_SUITE.erl10
1 files changed, 5 insertions, 5 deletions
diff --git a/deps/rabbit/test/quorum_queue_SUITE.erl b/deps/rabbit/test/quorum_queue_SUITE.erl
index 5045d89340..6b21c1e813 100644
--- a/deps/rabbit/test/quorum_queue_SUITE.erl
+++ b/deps/rabbit/test/quorum_queue_SUITE.erl
@@ -1982,7 +1982,7 @@ subscribe_redelivery_limit(Config) ->
receive
{#'basic.deliver'{redelivered = true}, #amqp_msg{}} ->
throw(unexpected_redelivery)
- after 2000 ->
+ after 5000 ->
ok
end.
@@ -2028,7 +2028,7 @@ subscribe_redelivery_policy(Config) ->
receive
{#'basic.deliver'{redelivered = true}, #amqp_msg{}} ->
throw(unexpected_redelivery)
- after 2000 ->
+ after 5000 ->
ok
end,
ok = rabbit_ct_broker_helpers:clear_policy(Config, 0, <<"delivery-limit">>).
@@ -2788,7 +2788,7 @@ cancel_consumer_gh_3729(Config) ->
{#'basic.deliver'{delivery_tag = DeliveryTag}, _} ->
R = #'basic.reject'{delivery_tag = DeliveryTag, requeue = true},
ok = amqp_channel:cast(Ch, R)
- after 1000 ->
+ after 5000 ->
flush(100),
ct:fail("basic.deliver timeout")
end,
@@ -2800,7 +2800,7 @@ cancel_consumer_gh_3729(Config) ->
receive
#'basic.cancel_ok'{consumer_tag = <<"ctag">>} -> ok
- after 1000 ->
+ after 5000 ->
flush(100),
ct:fail("basic.cancel_ok timeout")
end,
@@ -2966,7 +2966,7 @@ validate_queue(Ch, Queue, ExpectedMsgs) ->
#amqp_msg{payload = M}} ->
amqp_channel:cast(Ch, #'basic.ack'{delivery_tag = DeliveryTag1,
multiple = false})
- after 2000 ->
+ after 5000 ->
flush(10),
exit({validate_queue_timeout, M})
end