修复pr中提出的问题

apache · Sep 20, 2024 · e48d68d · e48d68d
1 parent c09c74a
commit e48d68d
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/store/src/main/java/org/apache/rocketmq/store/RocksDBMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/RocksDBMessageStore.java
@@ -25,6 +25,7 @@
 import org.apache.rocketmq.common.BrokerConfig;
 import org.apache.rocketmq.common.TopicConfig;
 import org.apache.rocketmq.common.UtilAll;
+import org.apache.rocketmq.common.sysflag.MessageSysFlag;
 import org.apache.rocketmq.store.config.MessageStoreConfig;
 import org.apache.rocketmq.store.config.StorePathConfigHelper;
 import org.apache.rocketmq.store.metrics.DefaultStoreMetricsManager;
@@ -187,7 +188,16 @@ public CommitLogDispatcherBuildRocksdbConsumeQueue getDispatcherBuildRocksdbCons
     class CommitLogDispatcherBuildRocksdbConsumeQueue implements CommitLogDispatcher {
         @Override
         public void dispatch(DispatchRequest request) throws RocksDBException {
-            putMessagePositionInfo(request);
+            final int tranType = MessageSysFlag.getTransactionValue(request.getSysFlag());
+            switch (tranType) {
+                case MessageSysFlag.TRANSACTION_NOT_TYPE:
+                case MessageSysFlag.TRANSACTION_COMMIT_TYPE:
+                    putMessagePositionInfo(request);
+                    break;
+                case MessageSysFlag.TRANSACTION_PREPARED_TYPE:
+                case MessageSysFlag.TRANSACTION_ROLLBACK_TYPE:
+                    break;
+            }
         }
     }