diff options
| -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) -> |