test

core/src/main/java/org/apache/seata/core/context/RootContext.java

@@ -48,6 +48,8 @@ private RootContext() {
      */
     public static final String KEY_XID = "TX_XID";
 
+    public static final String KEY_BRANCHID = "TX_BRANCHID";
+
     /**
      * The constant HIDDEN_KEY_XID for sofa-rpc integration.
      */

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

@@ -48,7 +48,7 @@ public class SeataMQProducer extends TransactionMQProducer {
     private static final Logger LOGGER = LoggerFactory.getLogger(SeataMQProducer.class);
 
     public static String PROPERTY_SEATA_XID = RootContext.KEY_XID;
-    public static String PROPERTY_SEATA_BRANCHID = "TX_BRANCHID";
+    public static String PROPERTY_SEATA_BRANCHID = RootContext.KEY_BRANCHID;
     private TransactionListener transactionListener;
 
     SeataMQProducer(final String producerGroup) {
@@ -86,7 +86,7 @@ public LocalTransactionState checkLocalTransaction(MessageExt msg) {
         };
     }
 
-
+    @Override
     public SendResult send(Message msg) throws MQClientException, MQBrokerException, RemotingException, InterruptedException {
         return send(msg, this.defaultMQProducerImpl.getDefaultMQProducer().getSendMsgTimeout());
     }