From 64029756f42a230c8a836242b02454422363401b Mon Sep 17 00:00:00 2001
From: Senrian <senagent@github.com>
Date: Mon, 2 Mar 2026 12:42:21 +0000
Subject: [PATCH] [refactor] Use isEmpty() in PopBufferMergeService

Signed-off-by: Senrian <senrian@github.com>
---
 .../rocketmq/broker/processor/PopBufferMergeService.java    | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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 8a85dd8fec8..629d19f57a1 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) {
@@ -126,7 +126,7 @@ public void run() {
         if (!isShouldRunning()) {
             return;
         }
-        while (this.buffer.size() > 0 || getOffsetTotalSize() > 0) {
+        while (!this.buffer.isEmpty() || getOffsetTotalSize() > 0) {
             scan();
         }
     }
@@ -282,7 +282,7 @@ private void scan() {
                                 indexList.add(i);
                             }
                         }
-                        if (indexList.size() > 0) {
+                        if (!indexList.isEmpty()) {
                             if (putBatchAckToStore(pointWrapper, indexList)) {
                                 count += indexList.size();
                                 for (Byte i : indexList) {