This is an automated email from the ASF dual-hosted git repository.
jinrongtong 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 dc62d7f2e1 [ISSUE #7451] Override toString for
TopicConfigAndQueueMapping
dc62d7f2e1 is described below
commit dc62d7f2e1ce4f99364599f8e23d65fd88eb1cd4
Author: LetLetMe <[email protected]>
AuthorDate: Fri Oct 13 13:45:48 2023 +0800
[ISSUE #7451] Override toString for TopicConfigAndQueueMapping
---
.../protocol/statictopic/TopicConfigAndQueueMapping.java | 10 ++++++++++
1 file changed, 10 insertions(+)
diff --git
a/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/statictopic/TopicConfigAndQueueMapping.java
b/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/statictopic/TopicConfigAndQueueMapping.java
index c937fec232..d13692735e 100644
---
a/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/statictopic/TopicConfigAndQueueMapping.java
+++
b/remoting/src/main/java/org/apache/rocketmq/remoting/protocol/statictopic/TopicConfigAndQueueMapping.java
@@ -16,6 +16,7 @@
*/
package org.apache.rocketmq.remoting.protocol.statictopic;
+import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.builder.EqualsBuilder;
import org.apache.commons.lang3.builder.HashCodeBuilder;
import org.apache.rocketmq.common.TopicConfig;
@@ -60,4 +61,13 @@ public class TopicConfigAndQueueMapping extends TopicConfig {
.append(mappingDetail)
.toHashCode();
}
+
+ @Override
+ public String toString() {
+ String string = super.toString();
+ if (StringUtils.isNotBlank(string)) {
+ string = string.substring(0, string.length() - 1) + ",
mappingDetail=" + mappingDetail + "]";
+ }
+ return string;
+ }
}