You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2022/03/01 12:23:55 UTC
[rocketmq] branch develop updated: Remove unnecessary Exception thrown by MQClientAPIImpl#createSubscriptionGroup (#3880)
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 11026c2 Remove unnecessary Exception thrown by MQClientAPIImpl#createSubscriptionGroup (#3880)
11026c2 is described below
commit 11026c287e248b632b451589b3c9c66c8d44856a
Author: cnScarb <jj...@163.com>
AuthorDate: Tue Mar 1 20:23:38 2022 +0800
Remove unnecessary Exception thrown by MQClientAPIImpl#createSubscriptionGroup (#3880)
---
.../src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
index 8dc73ad..c926341 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
@@ -248,8 +248,7 @@ public class MQClientAPIImpl {
}
public void createSubscriptionGroup(final String addr, final SubscriptionGroupConfig config,
- final long timeoutMillis)
- throws RemotingException, MQBrokerException, InterruptedException, MQClientException {
+ final long timeoutMillis) throws RemotingException, InterruptedException, MQClientException {
RemotingCommand request = RemotingCommand.createRequestCommand(RequestCode.UPDATE_AND_CREATE_SUBSCRIPTIONGROUP, null);
byte[] body = RemotingSerializable.encode(config);