(rocketmq) branch develop updated: [ISSUE #8235]Add @Override annotation for handleDiskFlush method (#8236)

[jinrongtong]

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 144b22ba7d [ISSUE #8235]Add @Override annotation for handleDiskFlush 
method (#8236)
144b22ba7d is described below

commit 144b22ba7d557619275a7b4a343c7350836b0b2c
Author: mxsm <ljbm...@gmail.com>
AuthorDate: Sun Jun 2 07:13:15 2024 +0800

    [ISSUE #8235]Add @Override annotation for handleDiskFlush method (#8236)
---
 store/src/main/java/org/apache/rocketmq/store/CommitLog.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java 
b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
index cc29cca5d9..1174eca1ba 100644
--- a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
+++ b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
@@ -2116,7 +2116,8 @@ public class CommitLog implements Swappable {
             this.commitRealTimeService = new CommitLog.CommitRealTimeService();
         }
 
-        @Override public void start() {
+        @Override
+        public void start() {
             this.flushCommitLogService.start();
 
             if (defaultMessageStore.isTransientStorePoolEnable()) {
@@ -2124,6 +2125,7 @@ public class CommitLog implements Swappable {
             }
         }
 
+        @Override
         public void handleDiskFlush(AppendMessageResult result, 
PutMessageResult putMessageResult,
             MessageExt messageExt) {
             // Synchronization flush