File tree Expand file tree Collapse file tree
store/src/main/java/org/apache/rocketmq/store/queue Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -86,14 +86,14 @@ public CombineConsumeQueueStore(DefaultMessageStore messageStore) {
8686
8787 if (loadingConsumeQueueTypeSet .contains (StoreType .DEFAULT )) {
8888 this .consumeQueueStore = new ConsumeQueueStore (messageStore );
89- this .innerConsumeQueueStoreList .addFirst (consumeQueueStore );
89+ this .innerConsumeQueueStoreList .add (consumeQueueStore );
9090 } else {
9191 this .consumeQueueStore = null ;
9292 }
9393
9494 if (loadingConsumeQueueTypeSet .contains (StoreType .DEFAULT_ROCKSDB )) {
9595 this .rocksDBConsumeQueueStore = new RocksDBConsumeQueueStore (messageStore );
96- this .innerConsumeQueueStoreList .addFirst (rocksDBConsumeQueueStore );
96+ this .innerConsumeQueueStoreList .add (rocksDBConsumeQueueStore );
9797 } else {
9898 this .rocksDBConsumeQueueStore = null ;
9999 }
You can’t perform that action at this time.
0 commit comments