From 74aa3e005689e2d46c1a7d6ebb9041930132b141 Mon Sep 17 00:00:00 2001
From: Heng Du <duheng0522@gmail.com>
Date: Wed, 21 Jul 2021 15:55:33 +0800
Subject: [PATCH] Update SendMessageProcessor.java

---
 .../apache/rocketmq/broker/processor/SendMessageProcessor.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
index 1b836ebf..11407c97 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
@@ -179,7 +179,7 @@ public class SendMessageProcessor extends AbstractSendMessageProcessor implement
         int maxReconsumeTimes = subscriptionGroupConfig.getRetryMaxTimes();
         if (request.getVersion() >= MQVersion.Version.V3_4_9.ordinal()) {
             Integer times = requestHeader.getMaxReconsumeTimes();
-            if (times != null){
+            if (times != null) {
                 maxReconsumeTimes = times;
             }
         }
-- 
GitLab