[rocketmq] branch develop updated: fix(log) add log for interruptedException (#3854)

[duhengforever]

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 fc01404  fix(log) add log for interruptedException (#3854)
fc01404 is described below

commit fc014049a2fbec2e1b87b09bfe16ec7b3e15029b
Author: Ni Ze <uncleran...@gmail.com>
AuthorDate: Thu Feb 17 13:27:09 2022 +0800

    fix(log) add log for interruptedException (#3854)
---
 .../rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java      | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java
 
b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java
index bb3536b..d515750 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java
@@ -849,6 +849,8 @@ public class DefaultLitePullConsumerImpl implements 
MQConsumerInner {
                             break;
                     }
                     updatePullOffset(messageQueue, 
pullResult.getNextBeginOffset(), processQueue);
+                } catch (InterruptedException interruptedException) {
+                    log.warn("Polling thread was interrupted.", 
interruptedException);
                 } catch (Throwable e) {
                     pullDelayTimeMills = pullTimeDelayMillsWhenException;
                     log.error("An error occurred in pull message process.", e);