This is an automated email from the ASF dual-hosted git repository.
RongtongJin 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 10d498c68a [ISSUE-10546] Add default implementation for
rejectRequest() in NettyRequestProcessor (#10547)
10d498c68a is described below
commit 10d498c68aaea5c15ca844d3b3b2d257847d1875
Author: Quan <[email protected]>
AuthorDate: Thu Jun 25 10:22:35 2026 +0800
[ISSUE-10546] Add default implementation for rejectRequest() in
NettyRequestProcessor (#10547)
---
.../rocketmq/broker/processor/AbstractSendMessageProcessor.java | 4 ----
.../org/apache/rocketmq/broker/processor/AckMessageProcessor.java | 5 -----
.../org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java | 5 -----
.../rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java | 5 -----
.../org/apache/rocketmq/broker/processor/ClientManageProcessor.java | 5 -----
.../apache/rocketmq/broker/processor/ConsumerManageProcessor.java | 5 -----
.../apache/rocketmq/broker/processor/EndTransactionProcessor.java | 5 -----
.../org/apache/rocketmq/broker/processor/LiteManagerProcessor.java | 4 ----
.../rocketmq/broker/processor/LiteSubscriptionCtlProcessor.java | 5 -----
.../org/apache/rocketmq/broker/processor/NotificationProcessor.java | 5 -----
.../org/apache/rocketmq/broker/processor/PeekMessageProcessor.java | 5 -----
.../org/apache/rocketmq/broker/processor/PollingInfoProcessor.java | 5 -----
.../apache/rocketmq/broker/processor/PopLiteMessageProcessor.java | 5 -----
.../org/apache/rocketmq/broker/processor/PopMessageProcessor.java | 5 -----
.../apache/rocketmq/broker/processor/QueryAssignmentProcessor.java | 5 -----
.../org/apache/rocketmq/broker/processor/QueryMessageProcessor.java | 5 -----
.../apache/rocketmq/broker/processor/RecallMessageProcessor.java | 4 ----
.../rocketmq/broker/processor/PopLiteMessageProcessorTest.java | 6 ------
.../org/apache/rocketmq/client/impl/ClientRemotingProcessor.java | 5 -----
.../org/apache/rocketmq/container/BrokerContainerProcessor.java | 5 -----
.../rocketmq/controller/processor/ControllerRequestProcessor.java | 4 ----
.../apache/rocketmq/namesrv/processor/ClientRequestProcessor.java | 4 ----
.../apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java | 5 -----
.../rocketmq/proxy/remoting/activity/AbstractRemotingActivity.java | 5 -----
.../org/apache/rocketmq/remoting/netty/NettyRequestProcessor.java | 4 +++-
.../test/java/org/apache/rocketmq/remoting/RemotingServerTest.java | 4 ----
.../java/org/apache/rocketmq/remoting/SubRemotingServerTest.java | 4 ----
.../rocketmq/test/container/ContainerIntegrationTestBase.java | 4 ----
28 files changed, 3 insertions(+), 129 deletions(-)
diff --git
a/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
b/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
index 67be56e462..0131794cb9 100644
---
a/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
+++
b/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
@@ -589,8 +589,4 @@ public abstract class AbstractSendMessageProcessor
implements NettyRequestProces
}
}
- @Override
- public boolean rejectRequest() {
- return false;
- }
}
diff --git
a/broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java
b/broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java
index 34a790efca..65f5f79aec 100644
---
a/broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java
+++
b/broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java
@@ -116,11 +116,6 @@ public class AckMessageProcessor implements
NettyRequestProcessor {
return this.processRequest(ctx.channel(), request, true);
}
- @Override
- public boolean rejectRequest() {
- return false;
- }
-
private RemotingCommand processRequest(final Channel channel,
RemotingCommand request,
boolean brokerAllowSuspend) throws RemotingCommandException {
AckMessageRequestHeader requestHeader;
diff --git
a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
index c88d4e5ad2..fc0182d733 100644
---
a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
+++
b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
@@ -542,11 +542,6 @@ public class AdminBrokerProcessor implements
NettyRequestProcessor {
return response;
}
- @Override
- public boolean rejectRequest() {
- return false;
- }
-
private synchronized RemotingCommand
updateAndCreateTopic(ChannelHandlerContext ctx,
RemotingCommand request) throws RemotingCommandException {
long startTime = System.currentTimeMillis();
diff --git
a/broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java
b/broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java
index 5ff132ca23..02deeb18a7 100644
---
a/broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java
+++
b/broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java
@@ -68,11 +68,6 @@ public class ChangeInvisibleTimeProcessor implements
NettyRequestProcessor {
return this.processRequest(ctx.channel(), request, true);
}
- @Override
- public boolean rejectRequest() {
- return false;
- }
-
private RemotingCommand processRequest(final Channel channel,
RemotingCommand request,
boolean brokerAllowSuspend) throws RemotingCommandException {
diff --git
a/broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java
b/broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java
index cc1f42e4e3..0e27fb9fb8 100644
---
a/broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java
+++
b/broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java
@@ -70,11 +70,6 @@ public class ClientManageProcessor implements
NettyRequestProcessor {
return null;
}
- @Override
- public boolean rejectRequest() {
- return false;
- }
-
public RemotingCommand heartBeat(ChannelHandlerContext ctx,
RemotingCommand request) {
RemotingCommand response = RemotingCommand.createResponseCommand(null);
HeartbeatData heartbeatData = HeartbeatData.decode(request.getBody(),
HeartbeatData.class);
diff --git
a/broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java
b/broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java
index dfa755d7c4..48ac7e6d87 100644
---
a/broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java
+++
b/broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java
@@ -71,11 +71,6 @@ public class ConsumerManageProcessor implements
NettyRequestProcessor {
return null;
}
- @Override
- public boolean rejectRequest() {
- return false;
- }
-
public RemotingCommand getConsumerListByGroup(ChannelHandlerContext ctx,
RemotingCommand request)
throws RemotingCommandException {
final RemotingCommand response =
diff --git
a/broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java
b/broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java
index f90b534204..2be2e18802 100644
---
a/broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java
+++
b/broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java
@@ -233,11 +233,6 @@ public class EndTransactionProcessor implements
NettyRequestProcessor {
return false;
}
- @Override
- public boolean rejectRequest() {
- return false;
- }
-
private RemotingCommand checkPrepareMessage(MessageExt msgExt,
EndTransactionRequestHeader requestHeader) {
final RemotingCommand response =
RemotingCommand.createResponseCommand(null);
if (msgExt != null) {
diff --git
a/broker/src/main/java/org/apache/rocketmq/broker/processor/LiteManagerProcessor.java
b/broker/src/main/java/org/apache/rocketmq/broker/processor/LiteManagerProcessor.java
index 63037b9fb7..d1b2a35b20 100644
---
a/broker/src/main/java/org/apache/rocketmq/broker/processor/LiteManagerProcessor.java
+++
b/broker/src/main/java/org/apache/rocketmq/broker/processor/LiteManagerProcessor.java
@@ -410,8 +410,4 @@ public class LiteManagerProcessor implements
NettyRequestProcessor {
.collect(Collectors.toSet());
}
- @Override
- public boolean rejectRequest() {
- return false;
- }
}
diff --git
a/broker/src/main/java/org/apache/rocketmq/broker/processor/LiteSubscriptionCtlProcessor.java
b/broker/src/main/java/org/apache/rocketmq/broker/processor/LiteSubscriptionCtlProcessor.java
index 2b3ce6f965..bcf0df4127 100644
---
a/broker/src/main/java/org/apache/rocketmq/broker/processor/LiteSubscriptionCtlProcessor.java
+++
b/broker/src/main/java/org/apache/rocketmq/broker/processor/LiteSubscriptionCtlProcessor.java
@@ -128,9 +128,4 @@ public class LiteSubscriptionCtlProcessor implements
NettyRequestProcessor {
.collect(Collectors.toSet());
}
- @Override
- public boolean rejectRequest() {
- return false;
- }
-
}
diff --git
a/broker/src/main/java/org/apache/rocketmq/broker/processor/NotificationProcessor.java
b/broker/src/main/java/org/apache/rocketmq/broker/processor/NotificationProcessor.java
index 24b587d1c6..5217861565 100644
---
a/broker/src/main/java/org/apache/rocketmq/broker/processor/NotificationProcessor.java
+++
b/broker/src/main/java/org/apache/rocketmq/broker/processor/NotificationProcessor.java
@@ -70,11 +70,6 @@ public class NotificationProcessor implements
NettyRequestProcessor {
this.popLongPollingService.shutdown();
}
- @Override
- public boolean rejectRequest() {
- return false;
- }
-
// When a new message is written to CommitLog, this method would be called.
// Suspended long polling will receive notification and be wakeup.
public void notifyMessageArriving(final String topic, final int queueId,
long offset,
diff --git
a/broker/src/main/java/org/apache/rocketmq/broker/processor/PeekMessageProcessor.java
b/broker/src/main/java/org/apache/rocketmq/broker/processor/PeekMessageProcessor.java
index 22694f5afa..66ac29371f 100644
---
a/broker/src/main/java/org/apache/rocketmq/broker/processor/PeekMessageProcessor.java
+++
b/broker/src/main/java/org/apache/rocketmq/broker/processor/PeekMessageProcessor.java
@@ -75,11 +75,6 @@ public class PeekMessageProcessor implements
NettyRequestProcessor {
return this.processRequest(ctx.channel(), request, true);
}
- @Override
- public boolean rejectRequest() {
- return false;
- }
-
private RemotingCommand processRequest(final Channel channel,
RemotingCommand request, boolean brokerAllowSuspend)
throws RemotingCommandException {
final long beginTimeMills =
this.brokerController.getMessageStore().now();
diff --git
a/broker/src/main/java/org/apache/rocketmq/broker/processor/PollingInfoProcessor.java
b/broker/src/main/java/org/apache/rocketmq/broker/processor/PollingInfoProcessor.java
index c114f4d4c3..32d609b1a2 100644
---
a/broker/src/main/java/org/apache/rocketmq/broker/processor/PollingInfoProcessor.java
+++
b/broker/src/main/java/org/apache/rocketmq/broker/processor/PollingInfoProcessor.java
@@ -51,11 +51,6 @@ public class PollingInfoProcessor implements
NettyRequestProcessor {
return this.processRequest(ctx.channel(), request);
}
- @Override
- public boolean rejectRequest() {
- return false;
- }
-
private RemotingCommand processRequest(final Channel channel,
RemotingCommand request)
throws RemotingCommandException {
RemotingCommand response =
RemotingCommand.createResponseCommand(PollingInfoResponseHeader.class);
diff --git
a/broker/src/main/java/org/apache/rocketmq/broker/processor/PopLiteMessageProcessor.java
b/broker/src/main/java/org/apache/rocketmq/broker/processor/PopLiteMessageProcessor.java
index 7baca87694..a1fa417152 100644
---
a/broker/src/main/java/org/apache/rocketmq/broker/processor/PopLiteMessageProcessor.java
+++
b/broker/src/main/java/org/apache/rocketmq/broker/processor/PopLiteMessageProcessor.java
@@ -96,11 +96,6 @@ public class PopLiteMessageProcessor implements
NettyRequestProcessor {
this.popLiteLockManager = new PopLiteLockManager();
}
- @Override
- public boolean rejectRequest() {
- return false;
- }
-
@Override
public RemotingCommand processRequest(final ChannelHandlerContext ctx,
RemotingCommand request)
throws RemotingCommandException {
diff --git
a/broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java
b/broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java
index c32e1b5ae2..55cabe6f5e 100644
---
a/broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java
+++
b/broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java
@@ -174,11 +174,6 @@ public class PopMessageProcessor implements
NettyRequestProcessor {
+ PopAckConstants.SPLIT + PopAckConstants.CK_TAG;
}
- @Override
- public boolean rejectRequest() {
- return false;
- }
-
public Cache<String, ConcurrentSkipListSet<PopRequest>> getPollingMap() {
return popLongPollingService.getPollingMap();
}
diff --git
a/broker/src/main/java/org/apache/rocketmq/broker/processor/QueryAssignmentProcessor.java
b/broker/src/main/java/org/apache/rocketmq/broker/processor/QueryAssignmentProcessor.java
index d29e3d0e06..586e5ec668 100644
---
a/broker/src/main/java/org/apache/rocketmq/broker/processor/QueryAssignmentProcessor.java
+++
b/broker/src/main/java/org/apache/rocketmq/broker/processor/QueryAssignmentProcessor.java
@@ -89,11 +89,6 @@ public class QueryAssignmentProcessor implements
NettyRequestProcessor {
return null;
}
- @Override
- public boolean rejectRequest() {
- return false;
- }
-
/**
*
*/
diff --git
a/broker/src/main/java/org/apache/rocketmq/broker/processor/QueryMessageProcessor.java
b/broker/src/main/java/org/apache/rocketmq/broker/processor/QueryMessageProcessor.java
index f29cd2b8a1..18197ed22c 100644
---
a/broker/src/main/java/org/apache/rocketmq/broker/processor/QueryMessageProcessor.java
+++
b/broker/src/main/java/org/apache/rocketmq/broker/processor/QueryMessageProcessor.java
@@ -70,11 +70,6 @@ public class QueryMessageProcessor implements
NettyRequestProcessor {
return null;
}
- @Override
- public boolean rejectRequest() {
- return false;
- }
-
public RemotingCommand queryMessage(ChannelHandlerContext ctx,
RemotingCommand request)
throws RemotingCommandException {
final RemotingCommand response =
diff --git
a/broker/src/main/java/org/apache/rocketmq/broker/processor/RecallMessageProcessor.java
b/broker/src/main/java/org/apache/rocketmq/broker/processor/RecallMessageProcessor.java
index fd537c3c9d..26e7d7dde2 100644
---
a/broker/src/main/java/org/apache/rocketmq/broker/processor/RecallMessageProcessor.java
+++
b/broker/src/main/java/org/apache/rocketmq/broker/processor/RecallMessageProcessor.java
@@ -183,8 +183,4 @@ public class RecallMessageProcessor implements
NettyRequestProcessor {
}
}
- @Override
- public boolean rejectRequest() {
- return false;
- }
}
diff --git
a/broker/src/test/java/org/apache/rocketmq/broker/processor/PopLiteMessageProcessorTest.java
b/broker/src/test/java/org/apache/rocketmq/broker/processor/PopLiteMessageProcessorTest.java
index fa9f2dbfaf..9705ab4f5a 100644
---
a/broker/src/test/java/org/apache/rocketmq/broker/processor/PopLiteMessageProcessorTest.java
+++
b/broker/src/test/java/org/apache/rocketmq/broker/processor/PopLiteMessageProcessorTest.java
@@ -56,7 +56,6 @@ import java.util.Iterator;
import static org.assertj.core.api.Assertions.assertThat;
import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertNull;
import static org.junit.Assert.assertTrue;
@@ -122,11 +121,6 @@ public class PopLiteMessageProcessorTest {
popLiteMessageProcessor = Mockito.spy(testObject);
}
- @Test
- public void testRejectRequest() {
- assertFalse(popLiteMessageProcessor.rejectRequest());
- }
-
@Test
public void testTransformOrderCountInfo_empty() {
StringBuilder result =
popLiteMessageProcessor.transformOrderCountInfo(new StringBuilder(), 3);
diff --git
a/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java
b/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java
index e46c651f92..0a187751f2 100644
---
a/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java
+++
b/client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java
@@ -92,11 +92,6 @@ public class ClientRemotingProcessor implements
NettyRequestProcessor {
return null;
}
- @Override
- public boolean rejectRequest() {
- return false;
- }
-
public RemotingCommand checkTransactionState(ChannelHandlerContext ctx,
RemotingCommand request) throws RemotingCommandException {
final CheckTransactionStateRequestHeader requestHeader =
diff --git
a/container/src/main/java/org/apache/rocketmq/container/BrokerContainerProcessor.java
b/container/src/main/java/org/apache/rocketmq/container/BrokerContainerProcessor.java
index 9107d5c05b..cfedb24aee 100644
---
a/container/src/main/java/org/apache/rocketmq/container/BrokerContainerProcessor.java
+++
b/container/src/main/java/org/apache/rocketmq/container/BrokerContainerProcessor.java
@@ -82,11 +82,6 @@ public class BrokerContainerProcessor implements
NettyRequestProcessor {
return null;
}
- @Override
- public boolean rejectRequest() {
- return false;
- }
-
protected synchronized RemotingCommand addBroker(ChannelHandlerContext ctx,
RemotingCommand request) throws Exception {
final RemotingCommand response =
RemotingCommand.createResponseCommand(null);
diff --git
a/controller/src/main/java/org/apache/rocketmq/controller/processor/ControllerRequestProcessor.java
b/controller/src/main/java/org/apache/rocketmq/controller/processor/ControllerRequestProcessor.java
index 4bd33efe2c..41e3d73bbc 100644
---
a/controller/src/main/java/org/apache/rocketmq/controller/processor/ControllerRequestProcessor.java
+++
b/controller/src/main/java/org/apache/rocketmq/controller/processor/ControllerRequestProcessor.java
@@ -326,10 +326,6 @@ public class ControllerRequestProcessor implements
NettyRequestProcessor {
return response;
}
- @Override
- public boolean rejectRequest() {
- return false;
- }
private boolean validateBlackListConfigExist(Properties properties) {
for (String blackConfig : configBlackList) {
if (properties.containsKey(blackConfig)) {
diff --git
a/namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/ClientRequestProcessor.java
b/namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/ClientRequestProcessor.java
index ef653129a7..becfa74b92 100644
---
a/namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/ClientRequestProcessor.java
+++
b/namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/ClientRequestProcessor.java
@@ -100,8 +100,4 @@ public class ClientRequestProcessor implements
NettyRequestProcessor {
return response;
}
- @Override
- public boolean rejectRequest() {
- return false;
- }
}
diff --git
a/namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java
b/namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java
index fa996e9952..b067384ccf 100644
---
a/namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java
+++
b/namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java
@@ -152,11 +152,6 @@ public class DefaultRequestProcessor implements
NettyRequestProcessor {
}
}
- @Override
- public boolean rejectRequest() {
- return false;
- }
-
public RemotingCommand putKVConfig(ChannelHandlerContext ctx,
RemotingCommand request) throws RemotingCommandException {
final RemotingCommand response =
RemotingCommand.createResponseCommand(null);
diff --git
a/proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/AbstractRemotingActivity.java
b/proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/AbstractRemotingActivity.java
index 230a37f4c1..2d09c39429 100644
---
a/proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/AbstractRemotingActivity.java
+++
b/proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/AbstractRemotingActivity.java
@@ -106,11 +106,6 @@ public abstract class AbstractRemotingActivity implements
NettyRequestProcessor
}
}
- @Override
- public boolean rejectRequest() {
- return false;
- }
-
protected abstract RemotingCommand processRequest0(ChannelHandlerContext
ctx, RemotingCommand request,
ProxyContext context) throws Exception;
diff --git
a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRequestProcessor.java
b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRequestProcessor.java
index 040f768488..972cef9152 100644
---
a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRequestProcessor.java
+++
b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRequestProcessor.java
@@ -26,5 +26,7 @@ public interface NettyRequestProcessor {
RemotingCommand processRequest(ChannelHandlerContext ctx, RemotingCommand
request)
throws Exception;
- boolean rejectRequest();
+ default boolean rejectRequest() {
+ return false;
+ }
}
diff --git
a/remoting/src/test/java/org/apache/rocketmq/remoting/RemotingServerTest.java
b/remoting/src/test/java/org/apache/rocketmq/remoting/RemotingServerTest.java
index d0da0eb2ef..cb224221cc 100644
---
a/remoting/src/test/java/org/apache/rocketmq/remoting/RemotingServerTest.java
+++
b/remoting/src/test/java/org/apache/rocketmq/remoting/RemotingServerTest.java
@@ -55,10 +55,6 @@ public class RemotingServerTest {
return request;
}
- @Override
- public boolean rejectRequest() {
- return false;
- }
}, Executors.newCachedThreadPool());
remotingServer.start();
diff --git
a/remoting/src/test/java/org/apache/rocketmq/remoting/SubRemotingServerTest.java
b/remoting/src/test/java/org/apache/rocketmq/remoting/SubRemotingServerTest.java
index 43ff1e9c0f..ac15e7c71e 100644
---
a/remoting/src/test/java/org/apache/rocketmq/remoting/SubRemotingServerTest.java
+++
b/remoting/src/test/java/org/apache/rocketmq/remoting/SubRemotingServerTest.java
@@ -62,10 +62,6 @@ public class SubRemotingServerTest {
return request;
}
- @Override
- public boolean rejectRequest() {
- return false;
- }
}, null);
subServer.start();
return subServer;
diff --git
a/test/src/test/java/org/apache/rocketmq/test/container/ContainerIntegrationTestBase.java
b/test/src/test/java/org/apache/rocketmq/test/container/ContainerIntegrationTestBase.java
index 02fa8487b4..0507f01d38 100644
---
a/test/src/test/java/org/apache/rocketmq/test/container/ContainerIntegrationTestBase.java
+++
b/test/src/test/java/org/apache/rocketmq/test/container/ContainerIntegrationTestBase.java
@@ -286,10 +286,6 @@ public class ContainerIntegrationTestBase {
return
namesrvController.getRemotingServer().getDefaultProcessorPair().getObject1().processRequest(ctx,
request);
}
- @Override
- public boolean rejectRequest() {
- return false;
- }
}, null);
namesrvControllers.add(namesrvController);
