Reuse TopicMessageId.Impl

Author: BewareMyPower

pulsar-client/src/main/java/org/apache/pulsar/client/impl/TopicMessageIdImpl.java

@@ -18,21 +18,15 @@
  */
 package org.apache.pulsar.client.impl;
 
-import java.util.BitSet;
 import org.apache.pulsar.client.api.MessageId;
-import org.apache.pulsar.client.api.MessageIdAdv;
 import org.apache.pulsar.client.api.TopicMessageId;
 
-public class TopicMessageIdImpl implements MessageIdAdv, TopicMessageId {
+public class TopicMessageIdImpl extends TopicMessageId.Impl {
 
-    /** This topicPartitionName is get from ConsumerImpl, it contains partition part. */
-    private final String topicPartitionName;
     private final String topicName;
-    private final MessageIdAdv messageId;
 
     public TopicMessageIdImpl(String topicPartitionName, String topicName, MessageId messageId) {
-        this.messageId = (MessageIdAdv) messageId;
-        this.topicPartitionName = topicPartitionName;
+        super(topicPartitionName, messageId);
         this.topicName = topicName;
     }
 
@@ -51,71 +45,6 @@ public String getTopicName() {
      */
     @Deprecated
     public String getTopicPartitionName() {
-        return this.topicPartitionName;
-    }
-
-    @Override
-    public String toString() {
-        return messageId.toString();
-    }
-
-    @Override
-    public byte[] toByteArray() {
-        return messageId.toByteArray();
-    }
-
-    @Override
-    public int hashCode() {
-        return messageId.hashCode();
-    }
-
-    @Override
-    public boolean equals(Object obj) {
-        return messageId.equals(obj);
-    }
-
-    @Override
-    public int compareTo(MessageId o) {
-        return messageId.compareTo(o);
-    }
-
-    @Override
-    public long getLedgerId() {
-        return messageId.getLedgerId();
-    }
-
-    @Override
-    public long getEntryId() {
-        return messageId.getEntryId();
-    }
-
-    @Override
-    public int getPartitionIndex() {
-        return messageId.getPartitionIndex();
-    }
-
-    @Override
-    public int getBatchIndex() {
-        return messageId.getBatchIndex();
-    }
-
-    @Override
-    public int getBatchSize() {
-        return messageId.getBatchSize();
-    }
-
-    @Override
-    public BitSet getAckSet() {
-        return messageId.getAckSet();
-    }
-
-    @Override
-    public MessageIdAdv getFirstChunkMessageId() {
-        return messageId.getFirstChunkMessageId();
-    }
-
-    @Override
-    public String getOwnerTopic() {
-        return topicPartitionName;
+        return getOwnerTopic();
     }
 }