public boolean equals()

in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java [245:267]

• 23 lines of code
• 17 McCabe index (conditional complexity)

  public boolean equals(Object o) {
    if (this == o) {
      return true;
    }
    if (o == null || getClass() != o.getClass()) {
      return false;
    }
    ProcessorMessage that = (ProcessorMessage) o;
    return physicalPartition == that.physicalPartition
        && physicalOffset == that.physicalOffset
        && physicalTimestamp == that.physicalTimestamp
        && logicalPartition == that.logicalPartition
        && logicalOffset == that.logicalOffset
        && logicalTimestamp == that.logicalTimestamp
        && Arrays.equals(key, that.key)
        && Arrays.equals(value, that.value)
        && physicalTopic.equals(that.physicalTopic)
        && logicalGroup.equals(that.logicalGroup)
        && logicalTopic.equals(that.logicalTopic)
        && getRetryCount() == that.getRetryCount()
        && getDispatchAttempt() == that.getDispatchAttempt()
        && getTimeoutCount() == that.getTimeoutCount();
  }