diff options
| author | Michael Klishin <michaelklishin@me.com> | 2022-07-26 21:46:08 +0400 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-07-26 21:46:08 +0400 |
| commit | 71e4875d4e97c2f4b6626f80dc246442ae8cd8d4 (patch) | |
| tree | 4520c896008be8c518d06c5d9d3060997e82a153 | |
| parent | c67962c9a5e8553faa498421d3a47461e07b3db9 (diff) | |
| parent | 935a768a9065a442a7ae2db8f81af4835d7af939 (diff) | |
| download | rabbitmq-server-git-71e4875d4e97c2f4b6626f80dc246442ae8cd8d4.tar.gz | |
Merge pull request #5334 from rabbitmq/stream-queue-flakes
| -rw-r--r-- | deps/rabbit/test/rabbit_stream_queue_SUITE.erl | 12 |
1 files changed, 2 insertions, 10 deletions
diff --git a/deps/rabbit/test/rabbit_stream_queue_SUITE.erl b/deps/rabbit/test/rabbit_stream_queue_SUITE.erl index 95d1fc2374..7276b377ee 100644 --- a/deps/rabbit/test/rabbit_stream_queue_SUITE.erl +++ b/deps/rabbit/test/rabbit_stream_queue_SUITE.erl @@ -2335,16 +2335,8 @@ receive_batch_min_offset(Ch, N, M) -> exit({missing_offset, N}) end. -receive_batch(Ch, N, M) when N >= M -> - receive - {#'basic.deliver'{delivery_tag = DeliveryTag}, - #amqp_msg{props = #'P_basic'{headers = [{<<"x-stream-offset">>, long, N}]}}} -> - ok = amqp_channel:cast(Ch, #'basic.ack'{delivery_tag = DeliveryTag, - multiple = false}) - after 60000 -> - flush(), - exit({missing_offset, N}) - end; +receive_batch(_Ch, N, M) when N > M -> + ok; receive_batch(Ch, N, M) -> receive {_, |