optimize MessaageBuilder API

Author: dbl-x

openmessaging-api-samples/src/main/java/io/openmessaging/samples/consumer/GenericPullConsumerApp.java

@@ -28,55 +28,55 @@ public interface MessageBuilder<T> {
     /**
      * Used for set topic.
      * @param topic message topic
-     * @return
+     * @return {@link MessageBuilder}
      */
-    MessageBuilder withTopic(String topic);
+    MessageBuilder<T> withTopic(String topic);
 
     /**
      * Used for message key.
      *
      * @param key message key
-     * @return
+     * @return {@link MessageBuilder}
      */
-    MessageBuilder withKey(String key);
+    MessageBuilder<T> withKey(String key);
 
     /**
      * Used for set message tags.
      *
-     * @param tags
-     * @return
+     * @param tags message tags
+     * @return {@link MessageBuilder}
      */
-    MessageBuilder withTags(String tags);
+    MessageBuilder<T> withTags(String tags);
 
     /**
      * Used for set message sharding key.
      *
-     * @param shardingKey
-     * @return
+     * @param shardingKey message shardingKey
+     * @return {@link MessageBuilder}
      */
-    MessageBuilder withShardingKey(String shardingKey);
+    MessageBuilder<T> withShardingKey(String shardingKey);
 
     /**
      * Used for set user properties.
      *
-     * @param key
-     * @param value
-     * @return
+     * @param key the key of user property
+     * @param value the value of user property
+     * @return {@link MessageBuilder}
      */
-    MessageBuilder withProperty(final String key, final String value);
+    MessageBuilder<T> withProperty(final String key, final String value);
 
     /**
      * Used for set message body.
      *
      * @param t object need to be serialized.
-     * @return
+     * @return {@link MessageBuilder}
      */
-    MessageBuilder withValue(T t);
+    MessageBuilder<T> withValue(T t);
 
     /**
      * Get the topic which this {@code MessageBuilder} belongs to.
      *
-     * @return
+     * @return message topic
      */
     String getTopic();
 

openmessaging-api/src/main/java/io/openmessaging/api/MessageBuilder.java

@@ -69,16 +69,6 @@ interface TopicPartitionChangeListener {
      */
     List<Message> poll(long timeout);
 
-    /**
-     * Fetch Objects for the topics or partitions specified using assign API. It is an error to not have subscribed to
-     * any topics or partitions before polling for data.
-     *
-     * @param timeout in millisecond
-     * @param tClass class of message body
-     * @return
-     */
-    <T> List<GenericMessage<T>> pollGenericMessages(long timeout, Class<T> tClass);
-
     /**
      * Overrides the fetch offsets that the consumer will use on the next {@link #poll(long)} }. If this API is invoked
      * for the same message queue more than once, the latest offset will be used on the next poll(). Note that you may