[rocketmq] branch 5.0.0-alpha updated: add hook to execute after consume for pop (#3780)

[duhengforever]

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

duhengforever pushed a commit to branch 5.0.0-alpha
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/5.0.0-alpha by this push:
     new de76e06  add hook to execute after consume for pop (#3780)
de76e06 is described below

commit de76e06d6da8e8646d2ac59ea061e8dc2653aae8
Author: cserwen <cser...@163.com>
AuthorDate: Mon Feb 14 15:11:06 2022 +0800

    add hook to execute after consume for pop (#3780)
---
 .../client/impl/consumer/ConsumeMessagePopConcurrentlyService.java     | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessagePopConcurrentlyService.java
 
b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessagePopConcurrentlyService.java
index 910f592..f3e661b 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessagePopConcurrentlyService.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessagePopConcurrentlyService.java
@@ -455,6 +455,9 @@ public class ConsumeMessagePopConcurrentlyService 
implements ConsumeMessageServi
 
             if 
(ConsumeMessagePopConcurrentlyService.this.defaultMQPushConsumerImpl.hasHook()) 
{
                 
consumeMessageContext.getProps().put(MixAll.CONSUME_CONTEXT_TYPE, 
returnType.name());
+                consumeMessageContext.setStatus(status.toString());
+                
consumeMessageContext.setSuccess(ConsumeConcurrentlyStatus.CONSUME_SUCCESS == 
status);
+                
ConsumeMessagePopConcurrentlyService.this.defaultMQPushConsumerImpl.executeHookAfter(consumeMessageContext);
             }
 
             ConsumeMessagePopConcurrentlyService.this.getConsumerStatsManager()