[rocketmq-clients] branch master updated: fix bug in changeInvisibleDuration (#155)

[aaronai]

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

aaronai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git


The following commit(s) were added to refs/heads/master by this push:
     new 7e6dc0b  fix bug in changeInvisibleDuration (#155)
7e6dc0b is described below

commit 7e6dc0ba4ac6c10338b7a675c67d3261d77b7886
Author: guyinyou <36399867+guyin...@users.noreply.github.com>
AuthorDate: Wed Aug 17 13:44:42 2022 +0800

    fix bug in changeInvisibleDuration (#155)
    
    * fix bug in changeInvisibleDuration
    
    * fix log
    
    * fix codestyle
    
    Co-authored-by: guyinyou <guyinyou@B-QD2CYVVG-0407.local>
---
 .../org/apache/rocketmq/client/java/impl/consumer/ConsumerImpl.java  | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ConsumerImpl.java
 
b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ConsumerImpl.java
index 30464df..aaef423 100644
--- 
a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ConsumerImpl.java
+++ 
b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ConsumerImpl.java
@@ -211,8 +211,9 @@ abstract class ConsumerImpl extends ClientImpl {
             @Override
             public void onFailure(Throwable t) {
                 final Duration duration = stopwatch.elapsed();
-                doAfter(MessageHookPoints.ACK, messageCommons, duration, 
MessageHookPointsStatus.ERROR);
-                LOGGER.error("Exception raised during message acknowledgement, 
messageId={}, endpoints={}, clientId={}",
+                doAfter(MessageHookPoints.CHANGE_INVISIBLE_DURATION, 
messageCommons, duration,
+                        MessageHookPointsStatus.ERROR);
+                LOGGER.error("Failed to change message invisible duration, 
messageId={}, endpoints={}, clientId={}",
                     messageId, endpoints, clientId, t);
 
             }