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 1b836ebf4312b418ebc7043a9071f51d5208c16d..11407c97c3df670ac931d7c5438dd419f55026a6 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;
             }
         }