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 73ca0021af ARTEMIS-5173 Replacing SimpleManager by direct object usage
73ca0021af is described below
commit 73ca0021af1616509d9ac1b77c3c439839feb7ef
Author: Clebert Suconic <[email protected]>
AuthorDate: Tue Dec 10 16:00:19 2024 -0500
ARTEMIS-5173 Replacing SimpleManager by direct object usage
---
.../apache/activemq/artemis/tests/integration/server/LVQTest.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/LVQTest.java
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/LVQTest.java
index 27c3ac7a1f..4922f442ab 100644
---
a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/LVQTest.java
+++
b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/server/LVQTest.java
@@ -36,7 +36,6 @@ import
org.apache.activemq.artemis.api.core.client.ClientProducer;
import org.apache.activemq.artemis.api.core.client.ClientSession;
import org.apache.activemq.artemis.api.core.client.ClientSessionFactory;
import org.apache.activemq.artemis.api.core.client.ServerLocator;
-import org.apache.activemq.artemis.api.core.management.SimpleManagement;
import org.apache.activemq.artemis.core.server.ActiveMQServer;
import org.apache.activemq.artemis.core.server.ActiveMQServers;
import org.apache.activemq.artemis.core.server.MessageReference;
@@ -171,9 +170,10 @@ public class LVQTest extends ActiveMQTestBase {
producer.send(m2);
producer.send(m3);
producer.send(m4);
- SimpleManagement simpleManagement = new
SimpleManagement("tcp://localhost:61616", null, null);
- Wait.assertEquals(2L, () ->
simpleManagement.getMessageCountOnQueue(qName1.toString()), 5000, 100);
- Wait.assertEquals(4L, () ->
simpleManagement.getMessagesAddedOnQueue(qName1.toString()), 5000, 100);
+ Queue serverQueue = server.locateQueue(qName1);
+ Wait.assertEquals(2L, serverQueue::getMessageCount, 5000, 100);
+ Wait.assertEquals(4L, serverQueue::getMessagesAdded, 5000, 100);
+ Wait.assertEquals(2L, serverQueue::getMessagesReplaced, 5000, 100);
clientSession.start();
ClientMessage m = consumer.receive(1000);
assertNotNull(m);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
