in rocketmq-spark/src/main/java/org/apache/rocketmq/spark/TopicQueueId.java [53:77]
public boolean equals(Object obj) {
if (this == obj) {
return true;
}
if (obj == null) {
return false;
}
if (getClass() != obj.getClass()) {
return false;
}
TopicQueueId other = (TopicQueueId) obj;
if (queueId != other.queueId) {
return false;
}
if (topic == null) {
if (other.topic != null) {
return false;
}
} else {
if (!topic.equals(other.topic)) {
return false;
}
}
return true;
}