opt

apache · Feb 2, 2023 · 6a85838 · 6a85838
1 parent c22aea7
commit 6a85838
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/tcc/src/main/java/io/seata/rm/tcc/rocketmq/RocketMQUtils.java b/tcc/src/main/java/io/seata/rm/tcc/rocketmq/RocketMQUtils.java
@@ -41,15 +41,13 @@ public static SendResult halfSend(DefaultMQProducer defaultMQProducer,
 
         MessageAccessor.putProperty(msg, MessageConst.PROPERTY_TRANSACTION_PREPARED, "true");
         MessageAccessor.putProperty(msg, MessageConst.PROPERTY_PRODUCER_GROUP, defaultMQProducer.getProducerGroup());
-        DefaultMQProducerImpl defaultMQProducerImpl = defaultMQProducer.getDefaultMQProducerImpl();
-        SendResult sendResult = null;
+        SendResult sendResult;
         try {
-            sendResult = defaultMQProducerImpl.send(msg);
+            sendResult = defaultMQProducer.send(msg);
         } catch (Exception e) {
             throw new MQClientException("send message Exception", e);
         }
 
-        LocalTransactionState localTransactionState = LocalTransactionState.UNKNOW;
         switch (sendResult.getSendStatus()) {
             case SEND_OK: {
                 if (sendResult.getTransactionId() != null) {