mirror of
https://github.com/apache/rocketmq.git
synced 2026-08-30 18:10:44 +08:00
+9
@@ -88,4 +88,13 @@ public class BrokerMemberGroup extends RemotingSerializable {
|
||||
public int hashCode() {
|
||||
return Objects.hashCode(cluster, brokerName, brokerAddrs);
|
||||
}
|
||||
|
||||
@Override
|
||||
public String toString() {
|
||||
return "BrokerMemberGroup{" +
|
||||
"cluster='" + cluster + '\'' +
|
||||
", brokerName='" + brokerName + '\'' +
|
||||
", brokerAddrs=" + brokerAddrs +
|
||||
'}';
|
||||
}
|
||||
}
|
||||
|
||||
+3
-3
@@ -91,9 +91,9 @@ public class CleanControllerBrokerDataRequestHeader implements CommandCustomHead
|
||||
public String toString() {
|
||||
return "CleanControllerBrokerDataRequestHeader{" +
|
||||
"clusterName='" + clusterName + '\'' +
|
||||
"brokerName='" + brokerName + '\'' +
|
||||
"brokerAddress='" + brokerAddress + '\'' +
|
||||
"isCleanLivingBroker='" + isCleanLivingBroker + '\'' +
|
||||
", brokerName='" + brokerName + '\'' +
|
||||
", brokerAddress='" + brokerAddress + '\'' +
|
||||
", isCleanLivingBroker=" + isCleanLivingBroker +
|
||||
'}';
|
||||
}
|
||||
}
|
||||
|
||||
+2
-2
@@ -72,8 +72,8 @@ public class ElectMasterRequestHeader implements CommandCustomHeader {
|
||||
public String toString() {
|
||||
return "ElectMasterRequestHeader{" +
|
||||
"clusterName='" + clusterName + '\'' +
|
||||
"brokerName='" + brokerName + '\'' +
|
||||
"brokerAddress='" + brokerAddress + '\'' +
|
||||
", brokerName='" + brokerName + '\'' +
|
||||
", brokerAddress='" + brokerAddress + '\'' +
|
||||
'}';
|
||||
}
|
||||
|
||||
|
||||
+1
-1
@@ -67,7 +67,7 @@ public class ElectMasterResponseHeader implements CommandCustomHeader {
|
||||
"newMasterAddress='" + newMasterAddress + '\'' +
|
||||
", masterEpoch=" + masterEpoch +
|
||||
", syncStateSetEpoch=" + syncStateSetEpoch +
|
||||
", brokerMember=" + brokerMemberGroup +
|
||||
", brokerMemberGroup=" + brokerMemberGroup +
|
||||
'}';
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user