You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2025/09/04 02:03:53 UTC

(rocketmq-clients) branch master updated: [ISSUE #1057] [Java] Enhance MessageImpl to allow subclasses to access properties (#1058)

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

lizhimin 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 7389a303 [ISSUE #1057] [Java] Enhance MessageImpl to allow subclasses to access properties (#1058)
7389a303 is described below

commit 7389a3031c8a0ae87fe9e3925b8887512dd56a46
Author: bcaw-ofeer <65...@users.noreply.github.com>
AuthorDate: Thu Sep 4 10:03:42 2025 +0800

    [ISSUE #1057] [Java] Enhance MessageImpl to allow subclasses to access properties (#1058)
    
    Co-authored-by: xiaoying.ly <xi...@alibaba-inc.com>
---
 .../java/org/apache/rocketmq/client/java/message/MessageImpl.java    | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageImpl.java b/java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageImpl.java
index 2d6ece72..581880d7 100644
--- a/java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageImpl.java
+++ b/java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageImpl.java
@@ -33,8 +33,11 @@ import org.apache.rocketmq.client.apis.message.Message;
  * @see Message
  */
 public class MessageImpl implements Message {
+
     protected final Collection<String> keys;
 
+    protected final Map<String, String> properties;
+
     final byte[] body;
     private final String topic;
 
@@ -45,8 +48,6 @@ public class MessageImpl implements Message {
     @Nullable
     private final Long deliveryTimestamp;
 
-    private final Map<String, String> properties;
-
     /**
      * The caller is supposed to have validated the arguments and handled throwing exception or
      * logging warnings already, so we avoid repeating args check here.