[rocketmq] branch develop updated: [ISSUE #6339] set message's flag in popRevive (#6340)

[di...@apache.org]

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 ba00ff8b79 [ISSUE #6339] set message's flag in popRevive (#6340)
ba00ff8b79 is described below

commit ba00ff8b795a70f19a0fea635b30d66fae892a0e
Author: lk <xd...@outlook.com>
AuthorDate: Tue Mar 14 13:58:02 2023 +0800

    [ISSUE #6339] set message's flag in popRevive (#6340)
---
 .../main/java/org/apache/rocketmq/broker/processor/PopReviveService.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java
index 116cb0f82d..d6ce39c290 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java
@@ -114,6 +114,7 @@ public class PopReviveService extends ServiceThread {
             MessageAccessor.setProperties(msgInner, new HashMap<>());
         }
         msgInner.setBornTimestamp(messageExt.getBornTimestamp());
+        msgInner.setFlag(messageExt.getFlag());
         msgInner.setSysFlag(messageExt.getSysFlag());
         msgInner.setBornHost(brokerController.getStoreHost());
         msgInner.setStoreHost(brokerController.getStoreHost());