rename FlatFile.addMessage

apache · Jul 3, 2024 · 90a20af · 90a20af
1 parent c9d68d6
commit 90a20af
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/...dstore/src/main/java/org/apache/rocketmq/tieredstore/core/MessageStoreDispatcherImpl.java b/...dstore/src/main/java/org/apache/rocketmq/tieredstore/core/MessageStoreDispatcherImpl.java
@@ -245,7 +245,7 @@ public CompletableFuture<Boolean> doScheduleDispatch(FlatFileInterface flatFile,
                     message.release();
                     break;
                 }
-                flatFile.addMessage(message);
+                flatFile.addMessageToBufferList(message);
             }
 
             // If there are many messages waiting to be uploaded, call the upload logic immediately.

diff --git a/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatFileInterface.java b/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatFileInterface.java
@@ -80,7 +80,7 @@ public interface FlatFileInterface {
 
     long getConsumeQueueCommitOffset();
 
-    void addMessage(SelectMappedBufferResult bufferResult);
+    void addMessageToBufferList(SelectMappedBufferResult bufferResult);
 
     /**
      * Persist commit log file and consume queue file

diff --git a/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatMessageFile.java b/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatMessageFile.java
@@ -144,7 +144,7 @@ public void initOffset(long offset) {
     }
 
     @Override
-    public void addMessage(SelectMappedBufferResult message) {
+    public void addMessageToBufferList(SelectMappedBufferResult message) {
         this.bufferResultList.add(message);
     }