From 1817fa8581ec380a22eaed1a7ccb3aab39593fbf Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?JB=20Onofr=C3=A9?= <jbonofre@apache.org>
Date: Fri, 13 Mar 2026 13:16:09 +0100
Subject: [PATCH] fix(test): set queue prefetch in UsageBlockedDispatchTest to
 prevent flaky failure

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.
---
 .../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 29844cfebde..1b3d84886ce 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 void testFillMemToBlockConsumer() throws Exception {
         ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(connectionUri);
         ActiveMQPrefetchPolicy prefetch = new ActiveMQPrefetchPolicy();
         prefetch.setTopicPrefetch(10);
+        prefetch.setQueuePrefetch(1);
         factory.setPrefetchPolicy(prefetch);
 
         final Connection producerConnection = factory.createConnection();