NO-JIRA fix intermittent failure, this test failed on local repeat ge…

…tting a null from immediate
apache · May 12, 2024 · 23522fd · 23522fd
1 parent e78136b
commit 23522fd
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/.../src/test/java/org/apache/activemq/artemis/tests/integration/client/SlowConsumerTest.java b/.../src/test/java/org/apache/activemq/artemis/tests/integration/client/SlowConsumerTest.java
@@ -210,6 +210,9 @@ public void testSlowConsumerSparedAfterBurst() throws Exception {
       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();
       }