diff options
| author | Jean-Sébastien Pédron <jean-sebastien@rabbitmq.com> | 2020-10-15 15:04:11 +0200 |
|---|---|---|
| committer | Jean-Sébastien Pédron <jean-sebastien@rabbitmq.com> | 2020-10-15 15:04:11 +0200 |
| commit | 4b320dd21ad099fc7513a55052f7553a719073bc (patch) | |
| tree | f19f7ca7c60ecfc9bbc4aea0e284e40c5b5166b8 | |
| parent | 7772eac5590ce942657cc2434ceecb9a572538b7 (diff) | |
| download | rabbitmq-server-git-4b320dd21ad099fc7513a55052f7553a719073bc.tar.gz | |
rabbit_stream_queue_SUITE: Give more time for expired messages to go away
The testcase is time-sensitive: it may be possible that the expired
messages are not all dropped at the time we consume the queue to
acknowledge they are gone.
We give them 5 more seconds: it should be enough for the last expired
messages to be removed, without affecting newer messages (which we
expect to be there).
| -rw-r--r-- | test/rabbit_stream_queue_SUITE.erl | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/test/rabbit_stream_queue_SUITE.erl b/test/rabbit_stream_queue_SUITE.erl index 67ca8eba8b..d3dfd60f7c 100644 --- a/test/rabbit_stream_queue_SUITE.erl +++ b/test/rabbit_stream_queue_SUITE.erl @@ -1097,6 +1097,8 @@ max_age(Config) -> [publish(Ch, Q, Payload) || _ <- lists:seq(1, 100)], amqp_channel:wait_for_confirms(Ch, 5000), + timer:sleep(5000), + Ch1 = rabbit_ct_client_helpers:open_channel(Config, Server), qos(Ch1, 200, false), subscribe(Ch1, Q, false, 0), |