opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-21 05:44:03 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #3949] change toString to toStringHelper

Browse Source
This commit is contained in:
kaiyi.lk
2022-07-13 11:30:49 +08:00
committed by zhouxiang
parent 3685fdaaeb
commit 74b8084268
24 changed files with 229 additions and 188 deletions
Download Patch File Download Diff File Expand all files Collapse all files
common/src/main/java/org/apache/rocketmq/common/protocol/header/AckMessageRequestHeader.java
+8 -7
View File
@@ -16,6 +16,7 @@
*/
package org.apache.rocketmq.common.protocol.header;
import com.google.common.base.MoreObjects;
import org.apache.rocketmq.remoting.CommandCustomHeader;
import org.apache.rocketmq.remoting.annotation.CFNotNull;
import org.apache.rocketmq.remoting.exception.RemotingCommandException;
@@ -80,12 +81,12 @@ public class AckMessageRequestHeader implements CommandCustomHeader {
@Override
public String toString() {
return "AckMessageRequestHeader{" +
"consumerGroup='" + consumerGroup + '\'' +
", topic='" + topic + '\'' +
", queueId=" + queueId +
", extraInfo='" + extraInfo + '\'' +
", offset=" + offset +
'}';
return MoreObjects.toStringHelper(this)
.add("consumerGroup", consumerGroup)
.add("topic", topic)
.add("queueId", queueId)
.add("extraInfo", extraInfo)
.add("offset", offset)
.toString();
}
}
common/src/main/java/org/apache/rocketmq/common/protocol/header/ChangeInvisibleTimeRequestHeader.java
+10 -10
View File
@@ -16,6 +16,7 @@
*/
package org.apache.rocketmq.common.protocol.header;
import com.google.common.base.MoreObjects;
import org.apache.rocketmq.remoting.CommandCustomHeader;
import org.apache.rocketmq.remoting.annotation.CFNotNull;
import org.apache.rocketmq.remoting.exception.RemotingCommandException;
@@ -94,15 +95,14 @@ public class ChangeInvisibleTimeRequestHeader implements CommandCustomHeader {
this.queueId = queueId;
}
@Override
public String toString() {
return "ChangeInvisibleTimeRequestHeader{" +
"consumerGroup='" + consumerGroup + '\'' +
", topic='" + topic + '\'' +
", queueId=" + queueId +
", extraInfo='" + extraInfo + '\'' +
", offset=" + offset +
", invisibleTime=" + invisibleTime +
'}';
@Override public String toString() {
return MoreObjects.toStringHelper(this)
.add("consumerGroup", consumerGroup)
.add("topic", topic)
.add("queueId", queueId)
.add("extraInfo", extraInfo)
.add("offset", offset)
.add("invisibleTime", invisibleTime)
.toString();
}
}
common/src/main/java/org/apache/rocketmq/common/protocol/header/CheckTransactionStateRequestHeader.java
+9 -8
View File
@@ -20,6 +20,7 @@
*/
package org.apache.rocketmq.common.protocol.header;
import com.google.common.base.MoreObjects;
import org.apache.rocketmq.remoting.CommandCustomHeader;
import org.apache.rocketmq.remoting.annotation.CFNotNull;
import org.apache.rocketmq.remoting.exception.RemotingCommandException;
@@ -88,13 +89,13 @@ public class CheckTransactionStateRequestHeader implements CommandCustomHeader {
@Override
public String toString() {
return "CheckTransactionStateRequestHeader{" +
"brokerName='" + brokerName + '\'' +
", tranStateTableOffset=" + tranStateTableOffset +
", commitLogOffset=" + commitLogOffset +
", msgId='" + msgId + '\'' +
", transactionId='" + transactionId + '\'' +
", offsetMsgId='" + offsetMsgId + '\'' +
'}';
return MoreObjects.toStringHelper(this)
.add("brokerName", brokerName)
.add("tranStateTableOffset", tranStateTableOffset)
.add("commitLogOffset", commitLogOffset)
.add("msgId", msgId)
.add("transactionId", transactionId)
.add("offsetMsgId", offsetMsgId)
.toString();
}
}
common/src/main/java/org/apache/rocketmq/common/protocol/header/CloneGroupOffsetRequestHeader.java
+7 -6
View File
@@ -20,6 +20,7 @@
*/
package org.apache.rocketmq.common.protocol.header;
import com.google.common.base.MoreObjects;
import org.apache.rocketmq.remoting.CommandCustomHeader;
import org.apache.rocketmq.remoting.annotation.CFNotNull;
import org.apache.rocketmq.remoting.exception.RemotingCommandException;
@@ -71,11 +72,11 @@ public class CloneGroupOffsetRequestHeader implements CommandCustomHeader {
@Override
public String toString() {
return "CloneGroupOffsetRequestHeader{" +
"srcGroup='" + srcGroup + '\'' +
", destGroup='" + destGroup + '\'' +
", topic='" + topic + '\'' +
", offline=" + offline +
'}';
return MoreObjects.toStringHelper(this)
.add("srcGroup", srcGroup)
.add("destGroup", destGroup)
.add("topic", topic)
.add("offline", offline)
.toString();
}
}
common/src/main/java/org/apache/rocketmq/common/protocol/header/ConsumeMessageDirectlyResultRequestHeader.java
+10 -9
View File
@@ -17,6 +17,7 @@
package org.apache.rocketmq.common.protocol.header;
import com.google.common.base.MoreObjects;
import org.apache.rocketmq.remoting.CommandCustomHeader;
import org.apache.rocketmq.remoting.annotation.CFNotNull;
import org.apache.rocketmq.remoting.annotation.CFNullable;
@@ -100,14 +101,14 @@ public class ConsumeMessageDirectlyResultRequestHeader implements CommandCustomH
@Override
public String toString() {
return "ConsumeMessageDirectlyResultRequestHeader{" +
"consumerGroup='" + consumerGroup + '\'' +
", clientId='" + clientId + '\'' +
", msgId='" + msgId + '\'' +
", brokerName='" + brokerName + '\'' +
", topic='" + topic + '\'' +
", topicSysFlag=" + topicSysFlag +
", groupSysFlag=" + groupSysFlag +
'}';
return MoreObjects.toStringHelper(this)
.add("consumerGroup", consumerGroup)
.add("clientId", clientId)
.add("msgId", msgId)
.add("brokerName", brokerName)
.add("topic", topic)
.add("topicSysFlag", topicSysFlag)
.add("groupSysFlag", groupSysFlag)
.toString();
}
}
common/src/main/java/org/apache/rocketmq/common/protocol/header/ConsumerSendMsgBackRequestHeader.java
+10 -9
View File
@@ -17,6 +17,7 @@
package org.apache.rocketmq.common.protocol.header;
import com.google.common.base.MoreObjects;
import org.apache.rocketmq.remoting.CommandCustomHeader;
import org.apache.rocketmq.remoting.annotation.CFNotNull;
import org.apache.rocketmq.remoting.annotation.CFNullable;
@@ -98,14 +99,14 @@ public class ConsumerSendMsgBackRequestHeader implements CommandCustomHeader {
@Override
public String toString() {
return "ConsumerSendMsgBackRequestHeader{" +
"offset=" + offset +
", group='" + group + '\'' +
", delayLevel=" + delayLevel +
", originMsgId='" + originMsgId + '\'' +
", originTopic='" + originTopic + '\'' +
", unitMode=" + unitMode +
", maxReconsumeTimes=" + maxReconsumeTimes +
'}';
return MoreObjects.toStringHelper(this)
.add("offset", offset)
.add("group", group)
.add("delayLevel", delayLevel)
.add("originMsgId", originMsgId)
.add("originTopic", originTopic)
.add("unitMode", unitMode)
.add("maxReconsumeTimes", maxReconsumeTimes)
.toString();
}
}
common/src/main/java/org/apache/rocketmq/common/protocol/header/CreateAccessConfigRequestHeader.java
+11 -10
View File
@@ -17,6 +17,7 @@
package org.apache.rocketmq.common.protocol.header;
import com.google.common.base.MoreObjects;
import org.apache.rocketmq.remoting.CommandCustomHeader;
import org.apache.rocketmq.remoting.annotation.CFNotNull;
import org.apache.rocketmq.remoting.exception.RemotingCommandException;
@@ -113,15 +114,15 @@ public class CreateAccessConfigRequestHeader implements CommandCustomHeader {
@Override
public String toString() {
return "CreateAccessConfigRequestHeader{" +
"accessKey='" + accessKey + '\'' +
", secretKey='" + secretKey + '\'' +
", whiteRemoteAddress='" + whiteRemoteAddress + '\'' +
", admin=" + admin +
", defaultTopicPerm='" + defaultTopicPerm + '\'' +
", defaultGroupPerm='" + defaultGroupPerm + '\'' +
", topicPerms='" + topicPerms + '\'' +
", groupPerms='" + groupPerms + '\'' +
'}';
return MoreObjects.toStringHelper(this)
.add("accessKey", accessKey)
.add("secretKey", secretKey)
.add("whiteRemoteAddress", whiteRemoteAddress)
.add("admin", admin)
.add("defaultTopicPerm", defaultTopicPerm)
.add("defaultGroupPerm", defaultGroupPerm)
.add("topicPerms", topicPerms)
.add("groupPerms", groupPerms)
.toString();
}
}
common/src/main/java/org/apache/rocketmq/common/protocol/header/CreateTopicRequestHeader.java
+13 -12
View File
@@ -20,6 +20,7 @@
*/
package org.apache.rocketmq.common.protocol.header;
import com.google.common.base.MoreObjects;
import org.apache.rocketmq.common.TopicFilterType;
import org.apache.rocketmq.remoting.CommandCustomHeader;
import org.apache.rocketmq.remoting.annotation.CFNotNull;
@@ -142,17 +143,17 @@ public class CreateTopicRequestHeader implements CommandCustomHeader {
@Override
public String toString() {
return "CreateTopicRequestHeader{" +
"topic='" + topic + '\'' +
", defaultTopic='" + defaultTopic + '\'' +
", readQueueNums=" + readQueueNums +
", writeQueueNums=" + writeQueueNums +
", perm=" + perm +
", topicFilterType='" + topicFilterType + '\'' +
", topicSysFlag=" + topicSysFlag +
", order=" + order +
", attributes='" + attributes + '\'' +
", force=" + force +
'}';
return MoreObjects.toStringHelper(this)
.add("topic", topic)
.add("defaultTopic", defaultTopic)
.add("readQueueNums", readQueueNums)
.add("writeQueueNums", writeQueueNums)
.add("perm", perm)
.add("topicFilterType", topicFilterType)
.add("topicSysFlag", topicSysFlag)
.add("order", order)
.add("attributes", attributes)
.add("force", force)
.toString();
}
}
common/src/main/java/org/apache/rocketmq/common/protocol/header/EndTransactionRequestHeader.java
+10 -9
View File
@@ -17,6 +17,7 @@
package org.apache.rocketmq.common.protocol.header;
import com.google.common.base.MoreObjects;
import org.apache.rocketmq.common.sysflag.MessageSysFlag;
import org.apache.rocketmq.remoting.CommandCustomHeader;
import org.apache.rocketmq.remoting.annotation.CFNotNull;
@@ -118,14 +119,14 @@ public class EndTransactionRequestHeader implements CommandCustomHeader {
@Override
public String toString() {
return "EndTransactionRequestHeader{" +
"producerGroup='" + producerGroup + '\'' +
", tranStateTableOffset=" + tranStateTableOffset +
", commitLogOffset=" + commitLogOffset +
", commitOrRollback=" + commitOrRollback +
", fromTransactionCheck=" + fromTransactionCheck +
", msgId='" + msgId + '\'' +
", transactionId='" + transactionId + '\'' +
'}';
return MoreObjects.toStringHelper(this)
.add("producerGroup", producerGroup)
.add("tranStateTableOffset", tranStateTableOffset)
.add("commitLogOffset", commitLogOffset)
.add("commitOrRollback", commitOrRollback)
.add("fromTransactionCheck", fromTransactionCheck)
.add("msgId", msgId)
.add("transactionId", transactionId)
.toString();
}
}
common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumeStatsRequestHeader.java
+5 -4
View File
@@ -16,6 +16,7 @@
*/
package org.apache.rocketmq.common.protocol.header;
import com.google.common.base.MoreObjects;
import org.apache.rocketmq.remoting.CommandCustomHeader;
import org.apache.rocketmq.remoting.annotation.CFNotNull;
import org.apache.rocketmq.remoting.exception.RemotingCommandException;
@@ -47,9 +48,9 @@ public class GetConsumeStatsRequestHeader implements CommandCustomHeader {
@Override
public String toString() {
return "GetConsumeStatsRequestHeader{" +
"consumerGroup='" + consumerGroup + '\'' +
", topic='" + topic + '\'' +
'}';
return MoreObjects.toStringHelper(this)
.add("consumerGroup", consumerGroup)
.add("topic", topic)
.toString();
}
}
common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerListByGroupRequestHeader.java
+4 -3
View File
@@ -17,6 +17,7 @@
package org.apache.rocketmq.common.protocol.header;
import com.google.common.base.MoreObjects;
import org.apache.rocketmq.remoting.CommandCustomHeader;
import org.apache.rocketmq.remoting.annotation.CFNotNull;
import org.apache.rocketmq.remoting.exception.RemotingCommandException;
@@ -39,8 +40,8 @@ public class GetConsumerListByGroupRequestHeader implements CommandCustomHeader
@Override
public String toString() {
return "GetConsumerListByGroupRequestHeader [" +
"consumerGroup='" + consumerGroup + '\'' +
']';
return MoreObjects.toStringHelper(this)
.add("consumerGroup", consumerGroup)
.toString();
}
}
common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerRunningInfoRequestHeader.java
+6 -5
View File
@@ -17,6 +17,7 @@
package org.apache.rocketmq.common.protocol.header;
import com.google.common.base.MoreObjects;
import org.apache.rocketmq.remoting.CommandCustomHeader;
import org.apache.rocketmq.remoting.annotation.CFNotNull;
import org.apache.rocketmq.remoting.annotation.CFNullable;
@@ -60,10 +61,10 @@ public class GetConsumerRunningInfoRequestHeader implements CommandCustomHeader
@Override
public String toString() {
return "GetConsumerRunningInfoRequestHeader{" +
"consumerGroup='" + consumerGroup + '\'' +
", clientId='" + clientId + '\'' +
", jstackEnable=" + jstackEnable +
'}';
return MoreObjects.toStringHelper(this)
.add("consumerGroup", consumerGroup)
.add("clientId", clientId)
.add("jstackEnable", jstackEnable)
.toString();
}
}
common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerStatusRequestHeader.java
+6 -5
View File
@@ -17,6 +17,7 @@
package org.apache.rocketmq.common.protocol.header;
import com.google.common.base.MoreObjects;
import org.apache.rocketmq.remoting.CommandCustomHeader;
import org.apache.rocketmq.remoting.annotation.CFNotNull;
import org.apache.rocketmq.remoting.annotation.CFNullable;
@@ -60,10 +61,10 @@ public class GetConsumerStatusRequestHeader implements CommandCustomHeader {
@Override
public String toString() {
return "GetConsumerStatusRequestHeader{" +
"topic='" + topic + '\'' +
", group='" + group + '\'' +
", clientAddr='" + clientAddr + '\'' +
'}';
return MoreObjects.toStringHelper(this)
.add("topic", topic)
.add("group", group)
.add("clientAddr", clientAddr)
.toString();
}
}
common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMaxOffsetRequestHeader.java
+6 -5
View File
@@ -20,6 +20,7 @@
*/
package org.apache.rocketmq.common.protocol.header;
import com.google.common.base.MoreObjects;
import org.apache.rocketmq.common.rpc.TopicQueueRequestHeader;
import org.apache.rocketmq.remoting.annotation.CFNotNull;
import org.apache.rocketmq.remoting.annotation.CFNullable;
@@ -74,10 +75,10 @@ public class GetMaxOffsetRequestHeader extends TopicQueueRequestHeader {
@Override
public String toString() {
return "GetMaxOffsetRequestHeader [" +
"topic='" + topic + '\'' +
", queueId=" + queueId +
", committed=" + committed +
']';
return MoreObjects.toStringHelper(this)
.add("topic", topic)
.add("queueId", queueId)
.add("committed", committed)
.toString();
}
}
common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMinOffsetRequestHeader.java
+5 -4
View File
@@ -20,6 +20,7 @@
*/
package org.apache.rocketmq.common.protocol.header;
import com.google.common.base.MoreObjects;
import org.apache.rocketmq.common.rpc.TopicQueueRequestHeader;
import org.apache.rocketmq.remoting.annotation.CFNotNull;
import org.apache.rocketmq.remoting.exception.RemotingCommandException;
@@ -56,9 +57,9 @@ public class GetMinOffsetRequestHeader extends TopicQueueRequestHeader {
@Override
public String toString() {
return "GetMinOffsetRequestHeader [" +
"topic='" + topic + '\'' +
", queueId=" + queueId +
']';
return MoreObjects.toStringHelper(this)
.add("topic", topic)
.add("queueId", queueId)
.toString();
}
}
common/src/main/java/org/apache/rocketmq/common/protocol/header/PopMessageRequestHeader.java
+14 -13
View File
@@ -16,6 +16,7 @@
*/
package org.apache.rocketmq.common.protocol.header;
import com.google.common.base.MoreObjects;
import org.apache.rocketmq.remoting.CommandCustomHeader;
import org.apache.rocketmq.remoting.annotation.CFNotNull;
import org.apache.rocketmq.remoting.exception.RemotingCommandException;
@@ -155,18 +156,18 @@ public class PopMessageRequestHeader implements CommandCustomHeader {
@Override
public String toString() {
return "PopMessageRequestHeader [" +
"consumerGroup='" + consumerGroup + '\'' +
", topic='" + topic + '\'' +
", queueId=" + queueId +
", maxMsgNums=" + maxMsgNums +
", invisibleTime=" + invisibleTime +
", pollTime=" + pollTime +
", bornTime=" + bornTime +
", initMode=" + initMode +
", expType='" + expType + '\'' +
", exp='" + exp + '\'' +
", order=" + order +
']';
return MoreObjects.toStringHelper(this)
.add("consumerGroup", consumerGroup)
.add("topic", topic)
.add("queueId", queueId)
.add("maxMsgNums", maxMsgNums)
.add("invisibleTime", invisibleTime)
.add("pollTime", pollTime)
.add("bornTime", bornTime)
.add("initMode", initMode)
.add("expType", expType)
.add("exp", exp)
.add("order", order)
.toString();
}
}
common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java
+15 -14
View File
@@ -20,6 +20,7 @@
*/
package org.apache.rocketmq.common.protocol.header;
import com.google.common.base.MoreObjects;
import org.apache.rocketmq.common.rpc.TopicQueueRequestHeader;
import org.apache.rocketmq.remoting.annotation.CFNotNull;
import org.apache.rocketmq.remoting.annotation.CFNullable;
@@ -157,19 +158,19 @@ public class PullMessageRequestHeader extends TopicQueueRequestHeader {
@Override
public String toString() {
return "PullMessageRequestHeader [" +
"consumerGroup='" + consumerGroup + '\'' +
", topic='" + topic + '\'' +
", queueId=" + queueId +
", queueOffset=" + queueOffset +
", maxMsgBytes=" + maxMsgBytes +
", maxMsgNums=" + maxMsgNums +
", sysFlag=" + sysFlag +
", commitOffset=" + commitOffset +
", suspendTimeoutMillis=" + suspendTimeoutMillis +
", subscription='" + subscription + '\'' +
", subVersion=" + subVersion +
", expressionType='" + expressionType + '\'' +
']';
return MoreObjects.toStringHelper(this)
.add("consumerGroup", consumerGroup)
.add("topic", topic)
.add("queueId", queueId)
.add("queueOffset", queueOffset)
.add("maxMsgBytes", maxMsgBytes)
.add("maxMsgNums", maxMsgNums)
.add("sysFlag", sysFlag)
.add("commitOffset", commitOffset)
.add("suspendTimeoutMillis", suspendTimeoutMillis)
.add("subscription", subscription)
.add("subVersion", subVersion)
.add("expressionType", expressionType)
.toString();
}
}
common/src/main/java/org/apache/rocketmq/common/protocol/header/SearchOffsetRequestHeader.java
+6 -5
View File
@@ -20,6 +20,7 @@
*/
package org.apache.rocketmq.common.protocol.header;
import com.google.common.base.MoreObjects;
import org.apache.rocketmq.common.rpc.TopicQueueRequestHeader;
import org.apache.rocketmq.remoting.annotation.CFNotNull;
import org.apache.rocketmq.remoting.exception.RemotingCommandException;
@@ -67,10 +68,10 @@ public class SearchOffsetRequestHeader extends TopicQueueRequestHeader {
@Override
public String toString() {
return "SearchOffsetRequestHeader [" +
"topic='" + topic + '\'' +
", queueId=" + queueId +
", timestamp=" + timestamp +
']';
return MoreObjects.toStringHelper(this)
.add("topic", topic)
.add("queueId", queueId)
.add("timestamp", timestamp)
.toString();
}
}
common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageRequestHeader.java
+16 -15
View File
@@ -20,6 +20,7 @@
*/
package org.apache.rocketmq.common.protocol.header;
import com.google.common.base.MoreObjects;
import org.apache.rocketmq.common.rpc.TopicQueueRequestHeader;
import org.apache.rocketmq.remoting.annotation.CFNotNull;
import org.apache.rocketmq.remoting.annotation.CFNullable;
@@ -166,20 +167,20 @@ public class SendMessageRequestHeader extends TopicQueueRequestHeader {
@Override
public String toString() {
return "SendMessageRequestHeader [" +
"producerGroup='" + producerGroup + '\'' +
", topic='" + topic + '\'' +
", defaultTopic='" + defaultTopic + '\'' +
", defaultTopicQueueNums=" + defaultTopicQueueNums +
", queueId=" + queueId +
", sysFlag=" + sysFlag +
", bornTimestamp=" + bornTimestamp +
", flag=" + flag +
", properties='" + properties + '\'' +
", reconsumeTimes=" + reconsumeTimes +
", unitMode=" + unitMode +
", batch=" + batch +
", maxReconsumeTimes=" + maxReconsumeTimes +
']';
return MoreObjects.toStringHelper(this)
.add("producerGroup", producerGroup)
.add("topic", topic)
.add("defaultTopic", defaultTopic)
.add("defaultTopicQueueNums", defaultTopicQueueNums)
.add("queueId", queueId)
.add("sysFlag", sysFlag)
.add("bornTimestamp", bornTimestamp)
.add("flag", flag)
.add("properties", properties)
.add("reconsumeTimes", reconsumeTimes)
.add("unitMode", unitMode)
.add("batch", batch)
.add("maxReconsumeTimes", maxReconsumeTimes)
.toString();
}
}
common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageRequestHeaderV2.java
+20
View File
@@ -17,6 +17,7 @@
package org.apache.rocketmq.common.protocol.header;
import com.google.common.base.MoreObjects;
import org.apache.rocketmq.remoting.CommandCustomHeader;
import org.apache.rocketmq.remoting.annotation.CFNotNull;
import org.apache.rocketmq.remoting.annotation.CFNullable;
@@ -197,4 +198,23 @@ public class SendMessageRequestHeaderV2 implements CommandCustomHeader {
public void setM(boolean m) {
this.m = m;
}
@Override
public String toString() {
return MoreObjects.toStringHelper(this)
.add("a", a)
.add("b", b)
.add("c", c)
.add("d", d)
.add("e", e)
.add("f", f)
.add("g", g)
.add("h", h)
.add("i", i)
.add("j", j)
.add("k", k)
.add("l", l)
.add("m", m)
.toString();
}
}
common/src/main/java/org/apache/rocketmq/common/protocol/header/UpdateConsumerOffsetRequestHeader.java
+7 -6
View File
@@ -20,6 +20,7 @@
*/
package org.apache.rocketmq.common.protocol.header;
import com.google.common.base.MoreObjects;
import org.apache.rocketmq.common.rpc.TopicQueueRequestHeader;
import org.apache.rocketmq.remoting.annotation.CFNotNull;
import org.apache.rocketmq.remoting.exception.RemotingCommandException;
@@ -76,11 +77,11 @@ public class UpdateConsumerOffsetRequestHeader extends TopicQueueRequestHeader {
@Override
public String toString() {
return "UpdateConsumerOffsetRequestHeader [" +
"consumerGroup='" + consumerGroup + '\'' +
", topic='" + topic + '\'' +
", queueId=" + queueId +
", commitOffset=" + commitOffset +
']';
return MoreObjects.toStringHelper(this)
.add("consumerGroup", consumerGroup)
.add("topic", topic)
.add("queueId", queueId)
.add("commitOffset", commitOffset)
.toString();
}
}
proxy/src/main/java/org/apache/rocketmq/proxy/service/route/MessageQueueSelector.java
+9 -7
View File
@@ -16,6 +16,7 @@
*/
package org.apache.rocketmq.proxy.service.route;
import com.google.common.base.MoreObjects;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashSet;
@@ -192,12 +193,13 @@ public class MessageQueueSelector {
return Objects.hash(queues, brokerActingQueues);
}
@Override
public String toString() {
return "SelectableMessageQueue{" + "queues=" + queues +
", brokers=" + brokerActingQueues +
", queueIndex=" + queueIndex +
", brokerIndex=" + brokerIndex +
'}';
@Override public String toString() {
return MoreObjects.toStringHelper(this)
.add("queues", queues)
.add("brokerActingQueues", brokerActingQueues)
.add("brokerNameQueueMap", brokerNameQueueMap)
.add("queueIndex", queueIndex)
.add("brokerIndex", brokerIndex)
.toString();
}
}
proxy/src/main/java/org/apache/rocketmq/proxy/service/route/SelectableMessageQueue.java
+5 -4
View File
@@ -16,6 +16,7 @@
*/
package org.apache.rocketmq.proxy.service.route;
import com.google.common.base.MoreObjects;
import java.util.Objects;
import org.apache.rocketmq.common.message.MessageQueue;
@@ -72,9 +73,9 @@ public class SelectableMessageQueue implements Comparable<SelectableMessageQueue
}
@Override public String toString() {
return "SelectableMessageQueue{" +
"messageQueue=" + messageQueue +
", brokerAddr='" + brokerAddr + '\'' +
'}';
return MoreObjects.toStringHelper(this)
.add("messageQueue", messageQueue)
.add("brokerAddr", brokerAddr)
.toString();
}
}
proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/TransactionId.java
+17 -18
View File
@@ -16,6 +16,7 @@
*/
package org.apache.rocketmq.proxy.service.transaction;
import com.google.common.base.MoreObjects;
import java.net.UnknownHostException;
import java.nio.ByteBuffer;
import java.nio.charset.StandardCharsets;
@@ -180,15 +181,14 @@ public class TransactionId {
this.proxyTransactionId = proxyTransactionId;
}
@Override
public String toString() {
return "TransactionId{" +
"brokerName=" + brokerName +
", brokerTransactionId='" + brokerTransactionId + '\'' +
", commitLogOffset=" + commitLogOffset +
", tranStateTableOffset=" + tranStateTableOffset +
", gatewayTransactionId='" + proxyTransactionId + '\'' +
'}';
@Override public String toString() {
return MoreObjects.toStringHelper(this)
.add("brokerName", brokerName)
.add("brokerTransactionId", brokerTransactionId)
.add("commitLogOffset", commitLogOffset)
.add("tranStateTableOffset", tranStateTableOffset)
.add("proxyTransactionId", proxyTransactionId)
.toString();
}
public static class TransactionIdBuilder {
@@ -230,15 +230,14 @@ public class TransactionId {
return new TransactionId(brokerName, brokerTransactionId, commitLogOffset, tranStateTableOffset, proxyTransactionId);
}
@Override
public String toString() {
return "TransactionId.TransactionIdBuilder{" +
"brokerName=" + brokerName +
", brokerTransactionId='" + brokerTransactionId + '\'' +
", commitLogOffset=" + commitLogOffset +
", tranStateTableOffset=" + tranStateTableOffset +
", gatewayTransactionId='" + proxyTransactionId + '\'' +
'}';
@Override public String toString() {
return MoreObjects.toStringHelper(this)
.add("brokerName", brokerName)
.add("brokerTransactionId", brokerTransactionId)
.add("commitLogOffset", commitLogOffset)
.add("tranStateTableOffset", tranStateTableOffset)
.add("proxyTransactionId", proxyTransactionId)
.toString();
}
}
}