From 2e1fe6ae91eeb5b92ffbdeab9a5ddc57172f3ab9 Mon Sep 17 00:00:00 2001 From: qianye Date: Tue, 5 Aug 2025 11:20:35 +0800 Subject: [PATCH] fix --- .../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 0454f002948..b63379cb21f 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 CombineConsumeQueueStore(DefaultMessageStore messageStore) { 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; }