[ISSUE #8921] Add isWakeCommitWhenPutMessage for AIO

zk-drizzle · drizzle.zk · web-flow · commit 60e68dadd919 · 2024-11-14T19:42:25.000+08:00
Co-authored-by: drizzle.zk &lt;drizzle.zk@alibaba-inc.com&gt;
diff --git 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 void handleDiskFlush(AppendMessageResult result, PutMessageResult putMess
                 if (!CommitLog.this.defaultMessageStore.isTransientStorePoolEnable()) {
                     flushCommitLogService.wakeup();
                 } else {
-                    commitRealTimeService.wakeup();
+                    if (defaultMessageStore.getMessageStoreConfig().isWakeCommitWhenPutMessage()) {
+                        commitRealTimeService.wakeup();
+                    }
                 }
             }
         }

Original file line number	Diff line number	Diff line change
`@@ -2181,7 +2181,9 @@ public void handleDiskFlush(AppendMessageResult result, PutMessageResult putMess`
`2181`	`2181`	`if (!CommitLog.this.defaultMessageStore.isTransientStorePoolEnable()) {`
`2182`	`2182`	`flushCommitLogService.wakeup();`
`2183`	`2183`	`} else {`
`2184`		`- commitRealTimeService.wakeup();`
	`2184`	`+ if (defaultMessageStore.getMessageStoreConfig().isWakeCommitWhenPutMessage()) {`
	`2185`	`+ commitRealTimeService.wakeup();`
	`2186`	`+ }`
`2185`	`2187`	`}`
`2186`	`2188`	`}`
`2187`	`2189`	`}`