You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@artemis.apache.org by cl...@apache.org on 2026/02/17 17:32:19 UTC
(artemis) branch main updated: NO-JIRA Fixing intermittent failure on QueueControlTest
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/artemis.git
The following commit(s) were added to refs/heads/main by this push:
new e866f466b9 NO-JIRA Fixing intermittent failure on QueueControlTest
e866f466b9 is described below
commit e866f466b9ba1c4fadbf665203d16a060557e9e9
Author: Clebert Suconic <cl...@apache.org>
AuthorDate: Tue Feb 17 12:26:35 2026 -0500
NO-JIRA Fixing intermittent failure on QueueControlTest
---
.../artemis/tests/integration/management/QueueControlTest.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
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 2656715d34..b114159ae7 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
@@ -5159,8 +5159,8 @@ public class QueueControlTest extends ManagementTestBase {
queueControl.moveMessage(messageID, queueName2.toString());
- assertEquals(messageCount, server.locateQueue(queueName1).getMessageCount());
- assertEquals(1, server.locateQueue(queueName2).getMessageCount());
+ Wait.assertEquals((long)messageCount, server.locateQueue(queueName1)::getMessageCount, 5000, 100);
+ Wait.assertEquals(1L, server.locateQueue(queueName2)::getMessageCount, 5000, 100);
}
@@ -5196,8 +5196,8 @@ public class QueueControlTest extends ManagementTestBase {
queueControl.copyMessage(messageID, queueName2.toString());
- assertEquals(messageCount + 1, server.locateQueue(queueName1).getMessageCount());
- assertEquals(1, server.locateQueue(queueName2).getMessageCount());
+ Wait.assertEquals((long)messageCount + 1, server.locateQueue(queueName1)::getMessageCount, 5000, 100);
+ Wait.assertEquals(1L, server.locateQueue(queueName2)::getMessageCount, 5000, 100);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@artemis.apache.org
For additional commands, e-mail: commits-help@artemis.apache.org