(rocketmq) branch develop updated: [ISSUE #10562] Optimize PopConsumerServiceTest#transferToFsStoreTest to avoid unnecessary background threads (#10563)

[lizhimin]

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

lizhimins pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 8242c1e9d2 [ISSUE #10562] Optimize 
PopConsumerServiceTest#transferToFsStoreTest to avoid unnecessary background 
threads (#10563)
8242c1e9d2 is described below

commit 8242c1e9d223c33b68fe1c66d129e83e86f5eba0
Author: Quan <zsjper...@foxmail.com>
AuthorDate: Wed Jul 1 14:03:54 2026 +0800

    [ISSUE #10562] Optimize PopConsumerServiceTest#transferToFsStoreTest to 
avoid unnecessary background threads (#10563)
    
    - Replace consumerService.start() with 
consumerService.getPopConsumerStore().start()
    - Replace consumerService.shutdown() with 
consumerService.getPopConsumerStore().shutdown()
    - Avoid starting revive/cache background threads that are not needed for 
transferToFsStore verification
    - Reduces test execution time from ~60s to ~1.3s
---
 .../java/org/apache/rocketmq/broker/pop/PopConsumerServiceTest.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/broker/src/test/java/org/apache/rocketmq/broker/pop/PopConsumerServiceTest.java
 
b/broker/src/test/java/org/apache/rocketmq/broker/pop/PopConsumerServiceTest.java
index 089d2c1f22..44189744b4 100644
--- 
a/broker/src/test/java/org/apache/rocketmq/broker/pop/PopConsumerServiceTest.java
+++ 
b/broker/src/test/java/org/apache/rocketmq/broker/pop/PopConsumerServiceTest.java
@@ -464,10 +464,10 @@ public class PopConsumerServiceTest {
             .thenReturn(CompletableFuture.completedFuture(
                 new PutMessageResult(PutMessageStatus.PUT_OK, new 
AppendMessageResult(AppendMessageStatus.PUT_OK))));
 
-        consumerService.start();
+        consumerService.getPopConsumerStore().start();
         consumerService.getPopConsumerStore().writeRecords(consumerRecordList);
         consumerService.transferToFsStore();
-        consumerService.shutdown();
+        consumerService.getPopConsumerStore().shutdown();
     }
 
     @Test