in samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java [200:229]
public boolean equals(Object obj) {
if (this == obj)
return true;
if (obj == null)
return false;
if (getClass() != obj.getClass())
return false;
IncomingMessageEnvelope other = (IncomingMessageEnvelope) obj;
if (key == null) {
if (other.key != null)
return false;
} else if (!key.equals(other.key))
return false;
if (message == null) {
if (other.message != null)
return false;
} else if (!message.equals(other.message))
return false;
if (offset == null) {
if (other.offset != null)
return false;
} else if (!offset.equals(other.offset))
return false;
if (systemStreamPartition == null) {
if (other.systemStreamPartition != null)
return false;
} else if (!systemStreamPartition.equals(other.systemStreamPartition))
return false;
return true;
}