optimize producer

Author: Bughue

rocketmq/src/main/java/org/apache/seata/integration/rocketmq/SeataMQProducer.java

@@ -52,11 +52,11 @@ public class SeataMQProducer extends TransactionMQProducer {
     public static String PROPERTY_SEATA_BRANCHID = "TX_BRANCHID";
     private TransactionListener transactionListener;
 
-    public SeataMQProducer(final String producerGroup) {
+    SeataMQProducer(final String producerGroup) {
         this(null, producerGroup, null);
     }
 
-    public SeataMQProducer(final String namespace, final String producerGroup, RPCHook rpcHook) {
+    SeataMQProducer(final String namespace, final String producerGroup, RPCHook rpcHook) {
         super(namespace, producerGroup, rpcHook);
         this.transactionListener = new TransactionListener() {
             @Override

rocketmq/src/main/java/org/apache/seata/integration/rocketmq/SeataMQProducerFactory.java

@@ -16,7 +16,9 @@
  */
 package org.apache.seata.integration.rocketmq;
 
+import org.apache.rocketmq.remoting.RPCHook;
 import org.apache.seata.common.exception.NotSupportYetException;
+
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
 
@@ -30,12 +32,18 @@ public class SeataMQProducerFactory {
     private static Map<String, SeataMQProducer> PRODUCER_MAP = new ConcurrentHashMap<>();
     private volatile static String SINGLE_PRODUCER_ID;
 
-    public SeataMQProducer create(String groupName, String producerId) {
+    public static SeataMQProducer create(String producerId, String nameServer, String producerGroup) {
+        return create(producerId, nameServer, null, producerGroup, null);
+    }
+
+    public static SeataMQProducer create(String producerId, String nameServer, String namespace,
+                                         String groupName, RPCHook rpcHook) {
         if (SINGLE_PRODUCER_ID == null) {
             synchronized (SeataMQProducerFactory.class) {
                 if (SINGLE_PRODUCER_ID == null) {
                     SINGLE_PRODUCER_ID = producerId;
-                    SeataMQProducer producer = new SeataMQProducer(groupName);
+                    SeataMQProducer producer = new SeataMQProducer(namespace, groupName, rpcHook);
+                    producer.setNamesrvAddr(nameServer);
                     tccRocketMQ.setProducer(producer);
                     PRODUCER_MAP.put(producerId, producer);
                 }
@@ -48,7 +56,7 @@ public SeataMQProducer create(String groupName, String producerId) {
         return getProducer();
     }
 
-    public SeataMQProducer getProducer() {
+    public static SeataMQProducer getProducer() {
         return PRODUCER_MAP.get(SINGLE_PRODUCER_ID);
     }