in inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/config/TubeClientConfig.java [475:570]
public boolean equals(Object o) {
// #lizard forgives
if (this == o) {
return true;
}
if (!(o instanceof TubeClientConfig)) {
return false;
}
TubeClientConfig that = (TubeClientConfig) o;
if (rpcReadTimeoutMs != that.rpcReadTimeoutMs) {
return false;
}
if (rpcConnProcessorCnt != that.rpcConnProcessorCnt) {
return false;
}
if (rpcNettyWorkMemorySize != that.rpcNettyWorkMemorySize) {
return false;
}
if (rpcRspCallBackThreadCnt != that.rpcRspCallBackThreadCnt) {
return false;
}
if (nettyWriteBufferHighWaterMark != that.nettyWriteBufferHighWaterMark) {
return false;
}
if (nettyWriteBufferLowWaterMark != that.nettyWriteBufferLowWaterMark) {
return false;
}
if (maxRegisterRetryTimes != that.maxRegisterRetryTimes) {
return false;
}
if (regFailWaitPeriodMs != that.regFailWaitPeriodMs) {
return false;
}
if (maxHeartBeatRetryTimes != that.maxHeartBeatRetryTimes) {
return false;
}
if (heartbeatPeriodMs != that.heartbeatPeriodMs) {
return false;
}
if (heartbeatPeriodAfterFail != that.heartbeatPeriodAfterFail) {
return false;
}
if (linkStatsDurationMs != that.linkStatsDurationMs) {
return false;
}
if (linkStatsForbiddenDurationMs != that.linkStatsForbiddenDurationMs) {
return false;
}
if (unAvailableFbdDurationMs != that.unAvailableFbdDurationMs) {
return false;
}
if (linkStatsMaxAllowedFailTimes != that.linkStatsMaxAllowedFailTimes) {
return false;
}
if (Double.compare(that.linkStatsMaxForbiddenRate, linkStatsMaxForbiddenRate) != 0) {
return false;
}
if (Double.compare(that.maxSentForbiddenRate, maxSentForbiddenRate) != 0) {
return false;
}
if (maxForbiddenCheckDuration != that.maxForbiddenCheckDuration) {
return false;
}
if (sessionStatisticCheckDuration != that.sessionStatisticCheckDuration) {
return false;
}
if (Double.compare(that.sessionWarnForbiddenRate, sessionWarnForbiddenRate) != 0) {
return false;
}
if (sessionWarnDelayedMsgCount != that.sessionWarnDelayedMsgCount) {
return false;
}
if (linkMaxAllowedDelayedMsgCount != that.linkMaxAllowedDelayedMsgCount) {
return false;
}
if (sessionMaxAllowedDelayedMsgCount != that.sessionMaxAllowedDelayedMsgCount) {
return false;
}
if (enableUserAuthentic != that.enableUserAuthentic) {
return false;
}
if (!usrName.equals(that.usrName)) {
return false;
}
if (!usrPassWord.equals(that.usrPassWord)) {
return false;
}
if (!this.tlsConfig.equals(that.tlsConfig)) {
return false;
}
if (!this.statsConfig.equals(that.statsConfig)) {
return false;
}
return masterInfo.equals(that.masterInfo);
}