diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlTest.java
index 0b96e37fa6..da8ea17df0 100644
--- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlTest.java
+++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/management/QueueControlTest.java
@@ -2380,6 +2380,10 @@ public class QueueControlTest extends ManagementTestBase {
       message = session.createMessage(durable);
       producer.send(message);
 
+      Queue serverqueue = server.locateQueue(queue);
+
+      Wait.assertEquals(1, serverqueue::getMessageCount);
+
       // the message IDs are set on the server
       messages = queueControl.listMessages(null);
       Assert.assertEquals(1, messages.length);