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 <[email protected]>
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);

Reply via email to