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