Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-5214 Fixing test with Wait.assertEquals

This commit is contained in:
Clebert Suconic 2024-12-17 11:17:45 -05:00
parent 934061764c
commit 5c1ecea69a
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/JMXManagementTest.java
View File

@ -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);