diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/PagingTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/PagingTest.java index 9c7e4f6546..94fd334bdd 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/PagingTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/PagingTest.java @@ -3133,7 +3133,7 @@ public class PagingTest extends ActiveMQTestBase { session.start(); - for (int i = 0; i < 6; i++) { + for (int i = 0; i < 5; i++) { ClientMessage message2 = consumer.receive(PagingTest.RECEIVE_TIMEOUT); Assert.assertNotNull(message2); @@ -3154,7 +3154,7 @@ public class PagingTest extends ActiveMQTestBase { producer.send(message); } - for (int i = 0; i < 6; i++) { + for (int i = 0; i < 5; i++) { ClientMessage message2 = consumer.receive(PagingTest.RECEIVE_TIMEOUT); Assert.assertNotNull(message2); @@ -3185,7 +3185,7 @@ public class PagingTest extends ActiveMQTestBase { session.start(); - for (int i = 0; i < 6; i++) { + for (int i = 0; i < 5; i++) { ClientMessage message2 = consumer.receive(PagingTest.RECEIVE_TIMEOUT); Assert.assertNotNull(message2);