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

duhengforever 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 818ef21  RemotingCommandException is not thrown in a method (#4030)
818ef21 is described below

commit 818ef2152f8e835cc907557d1e1d3da6705696ac
Author: 李晓双 Li Xiao Shuang <[email protected]>
AuthorDate: Mon Mar 28 15:01:06 2022 +0800

    RemotingCommandException is not thrown in a method (#4030)
---
 .../rocketmq/namesrv/processor/DefaultRequestProcessor.java      | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

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 8068c72..209e918 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
@@ -488,7 +488,7 @@ public class DefaultRequestProcessor extends 
AsyncNettyRequestProcessor implemen
     }
 
     private RemotingCommand getSystemTopicListFromNs(ChannelHandlerContext ctx,
-        RemotingCommand request) throws RemotingCommandException {
+        RemotingCommand request) {
         final RemotingCommand response = 
RemotingCommand.createResponseCommand(null);
 
         TopicList systemTopicList = 
this.namesrvController.getRouteInfoManager().getSystemTopicList();
@@ -501,7 +501,7 @@ public class DefaultRequestProcessor extends 
AsyncNettyRequestProcessor implemen
     }
 
     private RemotingCommand getUnitTopicList(ChannelHandlerContext ctx,
-        RemotingCommand request) throws RemotingCommandException {
+        RemotingCommand request) {
         final RemotingCommand response = 
RemotingCommand.createResponseCommand(null);
 
         TopicList unitTopics = 
this.namesrvController.getRouteInfoManager().getUnitTopics();
@@ -514,7 +514,7 @@ public class DefaultRequestProcessor extends 
AsyncNettyRequestProcessor implemen
     }
 
     private RemotingCommand getHasUnitSubTopicList(ChannelHandlerContext ctx,
-        RemotingCommand request) throws RemotingCommandException {
+        RemotingCommand request) {
         final RemotingCommand response = 
RemotingCommand.createResponseCommand(null);
 
         TopicList hasUnitSubTopicList = 
this.namesrvController.getRouteInfoManager().getHasUnitSubTopicList();
@@ -526,8 +526,7 @@ public class DefaultRequestProcessor extends 
AsyncNettyRequestProcessor implemen
         return response;
     }
 
-    private RemotingCommand getHasUnitSubUnUnitTopicList(ChannelHandlerContext 
ctx, RemotingCommand request)
-        throws RemotingCommandException {
+    private RemotingCommand getHasUnitSubUnUnitTopicList(ChannelHandlerContext 
ctx, RemotingCommand request) {
         final RemotingCommand response = 
RemotingCommand.createResponseCommand(null);
 
         TopicList hasUnitSubUnUnitTopicList = 
this.namesrvController.getRouteInfoManager().getHasUnitSubUnUnitTopicList();

Reply via email to