From 150941ea9be28f5df8b5c6cb496d4f3990a70e8c Mon Sep 17 00:00:00 2001 From: Senrian Date: Tue, 3 Mar 2026 01:34:45 +0000 Subject: [PATCH] [refactor] Use isEmpty() instead of size() == 0 in PopBufferMergeService Use isEmpty() method for better readability and performance. Signed-off-by: Senrian --- .../apache/rocketmq/broker/processor/PopBufferMergeService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java index 5373eaea333..c13b1905cea 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java @@ -109,7 +109,7 @@ public void run() { this.waitForRunning(interval); - if (!this.serving && this.buffer.size() == 0 && getOffsetTotalSize() == 0) { + if (!this.serving && this.buffer.isEmpty() && getOffsetTotalSize() == 0) { this.serving = true; } } catch (Throwable e) {