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