You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2024/11/21 18:10:05 UTC
(activemq-artemis) branch main updated: ARTEMIS-4959 speeding up testMoveMessagesInPagingMode
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 20a115fcb1 ARTEMIS-4959 speeding up testMoveMessagesInPagingMode
20a115fcb1 is described below
commit 20a115fcb1265406576d1fa2c870e5e90f263a10
Author: Clebert Suconic <cl...@apache.org>
AuthorDate: Thu Nov 21 12:54:12 2024 -0500
ARTEMIS-4959 speeding up testMoveMessagesInPagingMode
This unit test was sending too many messages, and taking too long making it more a stress test
---
.../integration/management/QueueControlTest.java | 20 ++++++++++----------
1 file changed, 10 insertions(+), 10 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 48a2970b91..06d8f30a5a 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
@@ -142,7 +142,7 @@ public class QueueControlTest extends ManagementTestBase {
@TestTemplate
public void testMoveMessagesInPagingMode() throws Exception {
- final int TOTAL_MESSAGES = 10000;
+ final int TOTAL_MESSAGES = 100;
final String DLA = "DLA";
ClientSessionFactory sf = createSessionFactory(locator);
ClientSession session = sf.createSession(false, false);
@@ -153,7 +153,7 @@ public class QueueControlTest extends ManagementTestBase {
session.createQueue(QueueConfiguration.of(dlq));
// Set up paging on the queue address
- AddressSettings addressSettings = new AddressSettings().setPageSizeBytes(10 * 1024).setMaxSizeBytes(16 * 1024).setDeadLetterAddress(dlq);
+ AddressSettings addressSettings = new AddressSettings().setPageSizeBytes(1024 * 1024).setMaxSizeBytes(1).setDeadLetterAddress(dlq);
server.getAddressSettingsRepository().addMatch("#", addressSettings);
sendMessageBatch(TOTAL_MESSAGES, session, queueAddr);
@@ -170,11 +170,11 @@ public class QueueControlTest extends ManagementTestBase {
String queueControlResourceName = ResourceNames.QUEUE + "testQueue";
Object resource = server.getManagementService().getResource(queueControlResourceName);
QueueControl queueControl = (QueueControl) resource;
- assertEquals(queueControl.getMessageCount(), 10000);
+ assertEquals(queueControl.getMessageCount(), TOTAL_MESSAGES);
// move messages to DLQ
- int count = queueControl.moveMessages(500, "", DLA, false, 500);
- assertEquals(500, count);
+ int count = queueControl.moveMessages(5, "", DLA, false, 10);
+ assertEquals(10, count);
//messages shouldn't move on to the same queue
try {
@@ -184,13 +184,13 @@ public class QueueControlTest extends ManagementTestBase {
//ok
}
- // 9500 left
- count = queueControl.moveMessages(1000, "", DLA, false, 9000);
- assertEquals(9000, count);
+ // 90 left, moving 7 messages
+ count = queueControl.moveMessages(1000, "", DLA, false, 7);
+ assertEquals(7, count);
- // 500 left, try move 1000
+ // 83 left, trying to move 1000
count = queueControl.moveMessages(100, "", DLA, false, 1000);
- assertEquals(500, count);
+ assertEquals(83, count);
// zero left, try move again
count = queueControl.moveMessages(100, "", DLA, false, 1000);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@activemq.apache.org
For additional commands, e-mail: commits-help@activemq.apache.org
For further information, visit: https://activemq.apache.org/contact