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