[rocketmq] branch develop updated: Add log info for push consumer when execute hook failed (#5468)

[li...@apache.org]

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

lizhanhui 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 9b2375dcf Add log info for push consumer when execute hook failed (#5468)
9b2375dcf is described below

commit 9b2375dcf4c06344b8ecbe339ef7bc99e9b4bb93
Author: Humkum <50...@users.noreply.github.com>
AuthorDate: Mon Nov 7 11:59:55 2022 +0800

    Add log info for push consumer when execute hook failed (#5468)
---
 .../apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java | 2 ++
 1 file changed, 2 insertions(+)

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 207894c49..cd4451fe7 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
@@ -165,6 +165,7 @@ public class DefaultMQPushConsumerImpl implements MQConsumerInner {
                 try {
                     hook.consumeMessageBefore(context);
                 } catch (Throwable e) {
+                    log.warn("consumeMessageHook {} executeHookBefore exception", hook.hookName(), e);
                 }
             }
         }
@@ -176,6 +177,7 @@ public class DefaultMQPushConsumerImpl implements MQConsumerInner {
                 try {
                     hook.consumeMessageAfter(context);
                 } catch (Throwable e) {
+                    log.warn("consumeMessageHook {} executeHookAfter exception", hook.hookName(), e);
                 }
             }
         }