diff options
| author | dcorbacho <dparracorbacho@piotal.io> | 2020-09-15 15:09:51 +0100 |
|---|---|---|
| committer | kjnilsson <knilsson@pivotal.io> | 2020-09-22 09:57:56 +0100 |
| commit | 6a43f14c4ece18f4a29dcfa87a7335ac1eee060c (patch) | |
| tree | 15b539209d822dab3e8016fe544e933b631e548d | |
| parent | df084aabb81132ed05ee539fb7eb32fdd863ccbe (diff) | |
| download | rabbitmq-server-git-6a43f14c4ece18f4a29dcfa87a7335ac1eee060c.tar.gz | |
Test invariant: peek must not drain the queue
| -rw-r--r-- | test/quorum_queue_SUITE.erl | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/test/quorum_queue_SUITE.erl b/test/quorum_queue_SUITE.erl index e871e7497d..942b42f5e4 100644 --- a/test/quorum_queue_SUITE.erl +++ b/test/quorum_queue_SUITE.erl @@ -2427,6 +2427,8 @@ peek(Config) -> ?assertMatch({error, no_message_at_pos}, rabbit_ct_broker_helpers:rpc(Config, 0, rabbit_quorum_queue, peek, [3, QName])), + + wait_for_messages(Config, [[QQ, <<"2">>, <<"2">>, <<"0">>]]), ok. in_memory(Config) -> |