[ISSUE #3955] delete useless check

apache · Mar 10, 2022 · 14710c9 · 14710c9
1 parent 7a5d937
commit 14710c9
Showing 1 changed file with 0 additions and 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
@@ -625,8 +625,6 @@ private CompletableFuture<RemotingCommand> asyncSendBatchMessage(ChannelHandlerC
         return handlePutMessageResultFuture(putMessageResult, response, request, messageExtBatch, responseHeader, mqtraceContext, ctx, queueIdInt);
     }
 
-
-
     public boolean hasConsumeMessageHook() {
         return consumeMessageHookList != null && !this.consumeMessageHookList.isEmpty();
     }
@@ -715,9 +713,6 @@ private RemotingCommand preSend(ChannelHandlerContext ctx, RemotingCommand reque
 
         response.setCode(-1);
         super.msgCheck(ctx, requestHeader, response);
-        if (response.getCode() != -1) {
-            return response;
-        }
 
         return response;
     }