This is an automated email from the ASF dual-hosted git repository. clebertsuconic pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
commit dbcad446cc2eaf0cbdba5529cd8eafa6afc27d2b Author: Clebert Suconic <[email protected]> AuthorDate: Mon Apr 7 12:21:20 2025 -0400 NO-JIRA Fixing intermittent test failure --- .../activemq/artemis/tests/integration/amqp/AmqpLargeMessageTest.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpLargeMessageTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpLargeMessageTest.java index 9d57c9685f..e033dc9c2c 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpLargeMessageTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpLargeMessageTest.java @@ -172,8 +172,7 @@ public class AmqpLargeMessageTest extends AmqpClientTestSupport { try { sendMessages(nMsgs, connection); - int count = getMessageCount(server.getPostOffice(), testQueueName); - assertEquals(nMsgs, count); + Wait.assertEquals(nMsgs, () -> getMessageCount(server.getPostOffice(), testQueueName), 5000, 100); org.apache.activemq.artemis.core.server.Queue serverQueue = server.locateQueue(testQueueName); serverQueue.forEach(ref -> { try { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected] For further information, visit: https://activemq.apache.org/contact
