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
commit 78a4791d1bf55432c5f63f7a08423202adf4c616 Author: Aaron Ai <[email protected]> AuthorDate: Fri Jul 1 11:44:17 2022 +0800 Java: bugfix for MessageIdImpl#toString --- .../java/org/apache/rocketmq/client/java/message/MessageIdImpl.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageIdImpl.java b/java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageIdImpl.java index bc66919..0235786 100644 --- a/java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageIdImpl.java +++ b/java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageIdImpl.java @@ -42,6 +42,10 @@ public class MessageIdImpl implements MessageId { */ @Override public String toString() { + // Use suffix directly for V0 + if (MessageIdCodec.MESSAGE_ID_VERSION_V0.equals(version)) { + return suffix; + } return version + suffix; }
