You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by aa...@apache.org on 2022/06/28 11:42:29 UTC
[rocketmq-clients] 01/03: Java: polish MessageViewImpl#toString
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 dc8eeda0d5a880e8916d5b6a8208a1db4dece9ca
Author: Aaron Ai <ya...@gmail.com>
AuthorDate: Tue Jun 28 18:59:32 2022 +0800
Java: polish MessageViewImpl#toString
---
.../rocketmq/client/java/message/MessageViewImpl.java | 19 ++++++-------------
1 file changed, 6 insertions(+), 13 deletions(-)
diff --git a/java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageViewImpl.java b/java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageViewImpl.java
index 5b3525d..a4a785d 100644
--- a/java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageViewImpl.java
+++ b/java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageViewImpl.java
@@ -100,7 +100,7 @@ public class MessageViewImpl implements LinkedElement<MessageViewImpl>, MessageV
public MessageCommon getMessageCommon() {
return new MessageCommon(messageId, topic, body, tag, messageGroup, deliveryTimestamp, keys, properties,
- bornHost, traceContext, bornTimestamp, deliveryAttempt, decodeStopwatch, null);
+ bornHost, traceContext, bornTimestamp, deliveryAttempt, decodeStopwatch, deliveryTimestampFromRemote);
}
/**
@@ -324,22 +324,15 @@ public class MessageViewImpl implements LinkedElement<MessageViewImpl>, MessageV
return MoreObjects.toStringHelper(this)
.add("messageId", messageId)
.add("topic", topic)
+ .add("bornHost", bornHost)
+ .add("bornTimestamp", bornTimestamp)
+ .add("endpoints", endpoints)
+ .add("deliveryAttempt", deliveryAttempt)
.add("tag", tag)
+ .add("keys", keys)
.add("messageGroup", messageGroup)
.add("deliveryTimestamp", deliveryTimestamp)
- .add("keys", keys)
.add("properties", properties)
- .add("bornHost", bornHost)
- .add("bornTimestamp", bornTimestamp)
- .add("deliveryAttempt", deliveryAttempt)
- .add("messageQueue", messageQueue)
- .add("endpoints", endpoints)
- .add("receiptHandle", receiptHandle)
- .add("traceContext", traceContext)
- .add("offset", offset)
- .add("corrupted", corrupted)
- .add("decodeStopwatch", decodeStopwatch)
- .add("deliveryTimestampFromRemote", deliveryTimestampFromRemote)
.toString();
}
}