File tree Expand file tree Collapse file tree 2 files changed +2
-2
lines changed
store/src/main/java/org/apache/rocketmq/store/timer Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -181,7 +181,7 @@ public void setMasterTimerQueueOffset(final long masterTimerQueueOffset) {
181181 this .masterTimerQueueOffset = masterTimerQueueOffset ;
182182 }
183183
184- public void updateDateVersion (long stateVersion ) {
184+ public void updateDataVersion (long stateVersion ) {
185185 dataVersion .nextVersion (stateVersion );
186186 }
187187
Original file line number Diff line number Diff line change @@ -1900,7 +1900,7 @@ public void prepareTimerCheckPoint() {
19001900 if (shouldRunningDequeue ) {
19011901 timerCheckpoint .setMasterTimerQueueOffset (commitQueueOffset );
19021902 if (commitReadTimeMs != lastCommitReadTimeMs || commitQueueOffset != lastCommitQueueOffset ) {
1903- timerCheckpoint .updateDateVersion (messageStore .getStateMachineVersion ());
1903+ timerCheckpoint .updateDataVersion (messageStore .getStateMachineVersion ());
19041904 lastCommitReadTimeMs = commitReadTimeMs ;
19051905 lastCommitQueueOffset = commitQueueOffset ;
19061906 }
You can’t perform that action at this time.
0 commit comments