From 159d28d5f8b0d917934a56cda2cb72dbd3cdcc9b Mon Sep 17 00:00:00 2001
From: zhenghu <huzheng_huang@163.com>
Date: Tue, 5 Nov 2019 01:22:37 +0800
Subject: [PATCH] =?UTF-8?q?[#1568]=20rocketmq=20need=20enhance=20stability?=
 =?UTF-8?q?=20when=20commitlog=20broken=20=20=E5=A2=9E=E5=8A=A0=E9=9D=9E?=
 =?UTF-8?q?=E7=A9=BA=E5=88=A4=E6=96=AD=EF=BC=8C=E9=98=B2=E6=AD=A2=E7=A9=BA?=
 =?UTF-8?q?=E6=8C=87=E9=92=88=E5=BC=82=E5=B8=B8,=E5=AF=BC=E8=87=B4?=
 =?UTF-8?q?=E5=BE=AA=E7=8E=AF=E4=BA=8B=E5=8A=A1=20check,=E5=A2=9E=E5=8A=A0?=
 =?UTF-8?q?test=E8=A6=86=E7=9B=96=EF=BC=8C=E4=BF=AE=E5=A4=8D=E7=BC=96?=
 =?UTF-8?q?=E7=A0=81=E6=A0=BC=E5=BC=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../broker/transaction/queue/TransactionalMessageBridge.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageBridge.java b/broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageBridge.java
index 8e283758..e14ed05a 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageBridge.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageBridge.java
@@ -131,7 +131,7 @@ public class TransactionalMessageBridge {
                     this.brokerController.getBrokerStatsManager().incGroupGetSize(group, topic,
                         getMessageResult.getBufferTotalSize());
                     this.brokerController.getBrokerStatsManager().incBrokerGetNums(getMessageResult.getMessageCount());
-                    if ( foundList == null || foundList.size() == 0 ) {
+                    if (foundList == null || foundList.size() == 0) {
                         break;
                     }
                     this.brokerController.getBrokerStatsManager().recordDiskFallBehindTime(group, topic, queueId,
-- 
GitLab