add ProducerBase interface

Author: dbl-x

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

@@ -41,7 +41,7 @@
  * @version OMS 1.2.0
  * @since OMS 1.2.0
  */
-public interface Producer extends Admin {
+public interface Producer extends ProducerBase, Admin {
 
     /**
      * Sends a message to the specified destination synchronously, the destination should be preset to {@link
@@ -84,12 +84,4 @@ public interface Producer extends Admin {
      * @param callbackExecutor
      */
     void setCallbackExecutor(final ExecutorService callbackExecutor);
-
-    /**
-     * Create message builder, used for build message in a fluent way.
-     *
-     * @param <T>
-     * @return
-     */
-    <T> MessageBuilder<T> messageBuilder();
 }

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

@@ -0,0 +1,18 @@
+package io.openmessaging.api;
+
+/**
+ * {@code ProducerBase} is the basic of other {@code Producer} interfaces
+ * and is used to define some common methods.
+ *
+ * @author chengyi (mark.lx@antfin.com) 2020-05-22 11:12
+ */
+public interface ProducerBase {
+
+    /**
+     * Create message builder, used for build message in a fluent way.
+     *
+     * @param <T> the class of message's payload
+     * @return MessageBuilder
+     */
+    <T> MessageBuilder<T> messageBuilder();
+}

openmessaging-api/src/main/java/io/openmessaging/api/order/OrderProducer.java

@@ -17,18 +17,15 @@
 
 package io.openmessaging.api.order;
 
-import io.openmessaging.api.Admin;
-import io.openmessaging.api.Message;
-import io.openmessaging.api.MessageBuilder;
-import io.openmessaging.api.SendResult;
+import io.openmessaging.api.*;
 
 /**
  * Sequential message producer interface  
  *
  * @version OMS 1.2.0
  * @since OMS 1.2.0
  */
-public interface OrderProducer extends Admin {
+public interface OrderProducer extends ProducerBase, Admin {
 
     /**
      * Send message in order
@@ -39,13 +36,4 @@ public interface OrderProducer extends Admin {
      * @return {@link SendResult} Message delivery result, including message Id.
      */
     SendResult send(final Message message, final String shardingKey);
-
-
-    /**
-     * Create message builder, used for build message in a fluent way.
-     *
-     * @param <T>
-     * @return
-     */
-    <T> MessageBuilder<T> messageBuilder();
 }

openmessaging-api/src/main/java/io/openmessaging/api/transaction/TransactionProducer.java

@@ -17,19 +17,15 @@
 
 package io.openmessaging.api.transaction;
 
-import io.openmessaging.api.Admin;
-import io.openmessaging.api.Message;
-import io.openmessaging.api.MessageBuilder;
-import io.openmessaging.api.SendResult;
-import io.openmessaging.api.TransactionalResult;
+import io.openmessaging.api.*;
 
 /**
  * Send transactional message.
  *
  * @version OMS 1.2.0
  * @since OMS 1.2.0
  */
-public interface TransactionProducer extends Admin {
+public interface TransactionProducer extends ProducerBase, Admin {
 
     /**
      * This method is used to send a transactional message. A transactional message is sent in three steps:
@@ -49,15 +45,6 @@ SendResult send(final Message message,
         final LocalTransactionExecuter localTransactionExecutor,
         final Object arg);
 
-
-    /**
-     * Create message builder, used for build message in a fluent way.
-     *
-     * @param <T>
-     * @return
-     */
-    <T> MessageBuilder<T> messageBuilder();
-
     /**
      * Sends a transactional message
      * <p>