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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
