From 14710c9a00401d671ed27de9a1cc047b100358cb Mon Sep 17 00:00:00 2001 From: wangfan Date: Thu, 10 Mar 2022 20:29:29 +0800 Subject: [PATCH] [ISSUE #3955] delete useless check --- .../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 c8ea4d3b5a9..0c1dec339a1 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 @@ private CompletableFuture 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; }