(rocketmq) branch develop updated: [ISSUE #9254] Optimize innerConsumeQueueStoreList order in CombineConsumeQueueStore

[lizhimin]

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

lizhimin 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 f798f96df1 [ISSUE #9254] Optimize innerConsumeQueueStoreList order in 
CombineConsumeQueueStore
f798f96df1 is described below

commit f798f96df19c92b192895e26fff0a13aea7c55b3
Author: qianye <wuxingcan....@alibaba-inc.com>
AuthorDate: Wed Aug 6 10:03:31 2025 +0800

    [ISSUE #9254] Optimize innerConsumeQueueStoreList order in 
CombineConsumeQueueStore
---
 .../org/apache/rocketmq/store/queue/CombineConsumeQueueStore.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/store/src/main/java/org/apache/rocketmq/store/queue/CombineConsumeQueueStore.java
 
b/store/src/main/java/org/apache/rocketmq/store/queue/CombineConsumeQueueStore.java
index 0454f00294..b63379cb21 100644
--- 
a/store/src/main/java/org/apache/rocketmq/store/queue/CombineConsumeQueueStore.java
+++ 
b/store/src/main/java/org/apache/rocketmq/store/queue/CombineConsumeQueueStore.java
@@ -86,14 +86,14 @@ public class CombineConsumeQueueStore implements 
ConsumeQueueStoreInterface {
 
         if (loadingConsumeQueueTypeSet.contains(StoreType.DEFAULT)) {
             this.consumeQueueStore = new ConsumeQueueStore(messageStore);
-            this.innerConsumeQueueStoreList.addFirst(consumeQueueStore);
+            this.innerConsumeQueueStoreList.add(consumeQueueStore);
         } else {
             this.consumeQueueStore = null;
         }
 
         if (loadingConsumeQueueTypeSet.contains(StoreType.DEFAULT_ROCKSDB)) {
             this.rocksDBConsumeQueueStore = new 
RocksDBConsumeQueueStore(messageStore);
-            this.innerConsumeQueueStoreList.addFirst(rocksDBConsumeQueueStore);
+            this.innerConsumeQueueStoreList.add(rocksDBConsumeQueueStore);
         } else {
             this.rocksDBConsumeQueueStore = null;
         }