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

jinrongtong 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 204b251239 Correct method name from updateDateVersion to 
updateDataVersion (#9788)
204b251239 is described below

commit 204b251239572c554a64351730de7bd9c2bc58ab
Author: majialong <[email protected]>
AuthorDate: Thu Oct 30 11:11:32 2025 +0800

    Correct method name from updateDateVersion to updateDataVersion (#9788)
---
 .../src/main/java/org/apache/rocketmq/store/timer/TimerCheckpoint.java  | 2 +-
 .../main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java    | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/store/src/main/java/org/apache/rocketmq/store/timer/TimerCheckpoint.java 
b/store/src/main/java/org/apache/rocketmq/store/timer/TimerCheckpoint.java
index 2cbe7e3bcf..0c67c0d134 100644
--- a/store/src/main/java/org/apache/rocketmq/store/timer/TimerCheckpoint.java
+++ b/store/src/main/java/org/apache/rocketmq/store/timer/TimerCheckpoint.java
@@ -181,7 +181,7 @@ public class TimerCheckpoint {
         this.masterTimerQueueOffset = masterTimerQueueOffset;
     }
 
-    public void updateDateVersion(long stateVersion) {
+    public void updateDataVersion(long stateVersion) {
         dataVersion.nextVersion(stateVersion);
     }
 
diff --git 
a/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java 
b/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java
index 8b995fbd70..9ff2544db1 100644
--- a/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java
+++ b/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java
@@ -1900,7 +1900,7 @@ public class TimerMessageStore {
         if (shouldRunningDequeue) {
             timerCheckpoint.setMasterTimerQueueOffset(commitQueueOffset);
             if (commitReadTimeMs != lastCommitReadTimeMs || commitQueueOffset 
!= lastCommitQueueOffset) {
-                
timerCheckpoint.updateDateVersion(messageStore.getStateMachineVersion());
+                
timerCheckpoint.updateDataVersion(messageStore.getStateMachineVersion());
                 lastCommitReadTimeMs = commitReadTimeMs;
                 lastCommitQueueOffset = commitQueueOffset;
             }

Reply via email to