package com.salesforce.storm.spout.sideline;

import org.apache.kafka.common.TopicPartition;

/**
 * This object is used as the MessageId for Tuples emitted to the Storm topology.
 */
public class TupleMessageId {
    private final String topic;
    private final int partition;
    private final long offset;
    private final String srcConsumerId;

    public TupleMessageId(final String topic, final int partition, final long offset, final String srcConsumerId) {
        this.topic = topic;
        this.partition = partition;
        this.offset = offset;
        this.srcConsumerId = srcConsumerId;
    }

    public TupleMessageId(final KafkaMessage kafkaMessage) {
        this(kafkaMessage.getTopic(), kafkaMessage.getPartition(), kafkaMessage.getOffset(), "DummyForNow");
    }

    public String getTopic() {
        return topic;
    }

    public int getPartition() {
        return partition;
    }

    public long getOffset() {
        return offset;
    }

    public String getSrcConsumerId() {
        return srcConsumerId;
    }

    @Override
    public boolean equals(Object o) {
        if (this == o) {
            return true;
        }
        if (o == null || getClass() != o.getClass()) {
            return false;
        }

        TupleMessageId that = (TupleMessageId) o;

        if (getPartition() != that.getPartition()) {
            return false;
        }
        if (getOffset() != that.getOffset()) {
            return false;
        }
        if (!getTopic().equals(that.getTopic())) {
            return false;
        }
        return getSrcConsumerId().equals(that.getSrcConsumerId());
    }

    @Override
    public int hashCode() {
        int result = getTopic().hashCode();
        result = 31 * result + getPartition();
        result = 31 * result + (int) (getOffset() ^ (getOffset() >>> 32));
        result = 31 * result + getSrcConsumerId().hashCode();
        return result;
    }

    @Override
    public String toString() {
        return "TupleMessageId{"
                + "topic='" + topic + '\''
                + ", partition=" + partition
                + ", offset=" + offset
                + ", srcConsumerId='" + srcConsumerId + '\''
                + '}';
    }

    /**
     * Helper method.
     * @return TopicPartition object for this tuple message.
     */
    public TopicPartition getTopicPartition() {
        return new TopicPartition(getTopic(), getPartition());
    }
}

@@ -608,185 +608,12 @@
   %7D%0A
-%0A
     
-public TupleMessageId(final KafkaMessage kafkaMessage) %7B%0A        this(kafkaMessage.getTopic(), kafkaMessage.getPartition(), kafkaMessage.getOffset(), %22DummyForNow%22);%0A    %7D%0A
 %0A   

Remove dead constructor