(activemq) branch main updated: fix(test): set queue prefetch in UsageBlockedDispatchTest to prevent flaky failure (#1765)

[jb...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jbonofre pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq.git


The following commit(s) were added to refs/heads/main by this push:
     new ed31052b75 fix(test): set queue prefetch in UsageBlockedDispatchTest to prevent flaky failure (#1765)
ed31052b75 is described below

commit ed31052b75a017e972067ff8811fc7047f590efc
Author: JB Onofré <jb...@apache.org>
AuthorDate: Wed Mar 18 05:45:12 2026 +0100

    fix(test): set queue prefetch in UsageBlockedDispatchTest to prevent flaky failure (#1765)
    
    The test only set topicPrefetch but uses queues, leaving the default
    queue prefetch at 1000. This caused the broker to dispatch many messages
    to the consumer's prefetch buffer, freeing enough memory to unblock the
    cursor and fail the assertNull check on line 166.
---
 .../test/java/org/apache/activemq/usecases/UsageBlockedDispatchTest.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/UsageBlockedDispatchTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/UsageBlockedDispatchTest.java
index 29844cfebd..1b3d84886c 100644
--- a/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/UsageBlockedDispatchTest.java
+++ b/activemq-unit-tests/src/test/java/org/apache/activemq/usecases/UsageBlockedDispatchTest.java
@@ -100,6 +100,7 @@ public class UsageBlockedDispatchTest extends TestSupport {
         ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(connectionUri);
         ActiveMQPrefetchPolicy prefetch = new ActiveMQPrefetchPolicy();
         prefetch.setTopicPrefetch(10);
+        prefetch.setQueuePrefetch(1);
         factory.setPrefetchPolicy(prefetch);
 
         final Connection producerConnection = factory.createConnection();


---------------------------------------------------------------------
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