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
The following commit(s) were added to refs/heads/main by this push:
new 5c1ecea69a ARTEMIS-5214 Fixing test with Wait.assertEquals
5c1ecea69a is described below
commit 5c1ecea69a55c313f4f72a84b5521affc0890129
Author: Clebert Suconic <[email protected]>
AuthorDate: Tue Dec 17 11:17:45 2024 -0500
ARTEMIS-5214 Fixing test with Wait.assertEquals
---
.../artemis/tests/integration/amqp/JMXManagementTest.java | 12 ++++++++++--
1 file changed, 10 insertions(+), 2 deletions(-)
diff --git
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMXManagementTest.java
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMXManagementTest.java
index 7e1677baaa..677e09faf5 100644
---
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMXManagementTest.java
+++
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMXManagementTest.java
@@ -27,6 +27,7 @@ import org.apache.activemq.artemis.api.core.RoutingType;
import org.apache.activemq.artemis.api.core.SimpleString;
import org.apache.activemq.artemis.api.core.management.QueueControl;
import org.apache.activemq.artemis.core.paging.PagingStore;
+import org.apache.activemq.artemis.core.server.Queue;
import
org.apache.activemq.artemis.tests.integration.management.ManagementControlHelper;
import org.apache.activemq.artemis.tests.util.Wait;
import org.apache.activemq.transport.amqp.client.AmqpClient;
@@ -136,6 +137,9 @@ public class JMXManagementTest extends JMSClientTestSupport
{
sender.send(message);
session.commit();
+ Queue serverQueue = server.locateQueue(getQueueName());
+ Wait.assertEquals(1L, serverQueue::getMessageCount, 100, 5000);
+
SimpleString queue = SimpleString.of(getQueueName());
QueueControl queueControl = createManagementControl(queue, queue);
String firstMessageAsJSON = queueControl.getFirstMessageAsJSON();
@@ -180,6 +184,10 @@ public class JMXManagementTest extends
JMSClientTestSupport {
session.commit();
SimpleString queue = SimpleString.of(getQueueName());
+
+ Queue serverQueue = server.locateQueue(getQueueName());
+ Wait.assertEquals(1L, serverQueue::getMessageCount, 100, 5000);
+
QueueControl queueControl = createManagementControl(queue, queue);
String firstMessageAsJSON = queueControl.getFirstMessageAsJSON();
assertNotNull(firstMessageAsJSON);
@@ -272,8 +280,8 @@ public class JMXManagementTest extends JMSClientTestSupport
{
senderB.send(message);
}
- assertEquals(MESSAGE_COUNT, queueAControl.countMessages());
- assertEquals(MESSAGE_COUNT, queueBControl.countMessages());
+ Wait.assertEquals((long)MESSAGE_COUNT, () ->
queueAControl.countMessages(), 5000, 100);
+ Wait.assertEquals((long)MESSAGE_COUNT, () ->
queueBControl.countMessages(), 5000, 100);
assertEquals(0, queueCControl.countMessages());
queueAControl.moveMessages(null, queueC);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
