[rocketmq] branch develop updated: [ISSUE #3955] delete useless check

[zh...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

zhangyang pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new adbf3db  [ISSUE #3955] delete useless check
adbf3db is described below

commit adbf3db7176fea568bb96ce9d379d7e151781825
Author: wangfan <wa...@xiaomi.com>
AuthorDate: Thu Mar 10 20:29:29 2022 +0800

    [ISSUE #3955] delete useless check
---
 .../org/apache/rocketmq/broker/processor/SendMessageProcessor.java   | 5 -----
 1 file changed, 5 deletions(-)

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 c8ea4d3..0c1dec3 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
@@ -625,8 +625,6 @@ public class SendMessageProcessor extends AbstractSendMessageProcessor implement
         return handlePutMessageResultFuture(putMessageResult, response, request, messageExtBatch, responseHeader, mqtraceContext, ctx, queueIdInt);
     }
 
-
-
     public boolean hasConsumeMessageHook() {
         return consumeMessageHookList != null && !this.consumeMessageHookList.isEmpty();
     }
@@ -715,9 +713,6 @@ public class SendMessageProcessor extends AbstractSendMessageProcessor implement
 
         response.setCode(-1);
         super.msgCheck(ctx, requestHeader, response);
-        if (response.getCode() != -1) {
-            return response;
-        }
 
         return response;
     }