in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Queue.java [79:96]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
Queue queue = (Queue) o;
if (queueId != queue.queueId) {
return false;
}
if (queueName != null ? !queueName.equals(queue.queueName) : queue.queueName != null) {
return false;
}
return brokerName != null ? brokerName.equals(queue.brokerName) : queue.brokerName == null;
}