From 23522fd83d3c16ca637223fa336103a73bd86905 Mon Sep 17 00:00:00 2001
From: Gary Tully <gary.tully@gmail.com>
Date: Fri, 10 May 2024 11:14:12 +0100
Subject: [PATCH] NO-JIRA fix intermittent failure, this test failed on local
 repeat getting a null from immediate

---
 .../artemis/tests/integration/client/SlowConsumerTest.java     | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/SlowConsumerTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/SlowConsumerTest.java
index 1eb45af4b7..3b557bbd90 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/SlowConsumerTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/SlowConsumerTest.java
@@ -210,6 +210,9 @@ public class SlowConsumerTest extends ActiveMQTestBase {
       ClientConsumer consumer = addClientConsumer(session.createConsumer(QUEUE));
       session.start();
 
+      Queue queue = server.locateQueue(QUEUE);
+      Wait.assertTrue(() -> queue.getDeliveringCount() >= 3 * threshold);
+
       for (int i = 0; i < 3 * threshold; i++) {
          consumer.receiveImmediate().individualAcknowledge();
       }