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