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();