(rocketmq) branch develop updated: [ISSUE #8921] Add isWakeCommitWhenPutMessage for AIO

[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 60e68dadd9 [ISSUE #8921] Add isWakeCommitWhenPutMessage for AIO
60e68dadd9 is described below

commit 60e68dadd9197730642ce55b1237e6f6f0401aa5
Author: Drizzle <464473...@qq.com>
AuthorDate: Thu Nov 14 19:42:25 2024 +0800

    [ISSUE #8921] Add isWakeCommitWhenPutMessage for AIO
    
    Co-authored-by: drizzle.zk <drizzle...@alibaba-inc.com>
---
 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 63022520e2..378518d249 100644
--- a/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
+++ b/store/src/main/java/org/apache/rocketmq/store/CommitLog.java
@@ -2181,7 +2181,9 @@ public class CommitLog implements Swappable {
                 if 
(!CommitLog.this.defaultMessageStore.isTransientStorePoolEnable()) {
                     flushCommitLogService.wakeup();
                 } else {
-                    commitRealTimeService.wakeup();
+                    if 
(defaultMessageStore.getMessageStoreConfig().isWakeCommitWhenPutMessage()) {
+                        commitRealTimeService.wakeup();
+                    }
                 }
             }
         }