diff --git a/deps/rabbitmq_recent_history_exchange/test/system_SUITE.erl b/deps/rabbitmq_recent_history_exchange/test/system_SUITE.erl index f87d6d9d1f50..b42ac89705dc 100644 --- a/deps/rabbitmq_recent_history_exchange/test/system_SUITE.erl +++ b/deps/rabbitmq_recent_history_exchange/test/system_SUITE.erl @@ -148,6 +148,9 @@ e2e_test(Config) -> routing_key = <<"">> }), + %% Wait a few seconds for all messages to be queued. + timer:sleep(3000), + #'queue.declare_ok'{message_count = Count, queue = Q} = amqp_channel:call(Chan, #'queue.declare' { passive = true,