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

dinglei 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 dd6922362 [ISSUE #4325] Remove redundant exception to improve 
readability
dd6922362 is described below

commit dd69223624c07f16e0b343546b066c330a19bc04
Author: Oliver <[email protected]>
AuthorDate: Thu May 19 14:29:11 2022 +0800

    [ISSUE #4325] Remove redundant exception to improve readability
---
 .../rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java       | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
 
b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
index 31cd64c01..05ced26c4 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
@@ -959,8 +959,7 @@ public class DefaultMQPushConsumerImpl implements 
MQConsumerInner {
         this.consumeOrderly = consumeOrderly;
     }
 
-    public void resetOffsetByTimeStamp(long timeStamp)
-        throws RemotingException, MQBrokerException, InterruptedException, 
MQClientException {
+    public void resetOffsetByTimeStamp(long timeStamp) throws 
MQClientException {
         for (String topic : rebalanceImpl.getSubscriptionInner().keySet()) {
             Set<MessageQueue> mqs = 
rebalanceImpl.getTopicSubscribeInfoTable().get(topic);
             if (CollectionUtils.isNotEmpty(mqs)) {

Reply via email to