From b620b9c8d272737bf6aefa30547e54b472daef7c Mon Sep 17 00:00:00 2001
From: joewee <371499220@qq.com>
Date: Tue, 4 Sep 2018 13:34:40 +0800
Subject: [PATCH] Fix the problem when method executeLocalTransaction return
 LocalTransactionState.COMMIT_MESSAGE but still executing
 checkLocalTransaction method

---
 .../rocketmq/client/impl/producer/DefaultMQProducerImpl.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
index d095254a..7ace9d5b 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
@@ -1153,7 +1153,7 @@ public class DefaultMQProducerImpl implements MQProducerInner {
                         localTransactionState = localTransactionExecuter.executeLocalTransactionBranch(msg, arg);
                     } else if (transactionListener != null) {
                         log.debug("Used new transaction API");
-                        transactionListener.executeLocalTransaction(msg, arg);
+                        localTransactionState = transactionListener.executeLocalTransaction(msg, arg);
                     }
                     if (null == localTransactionState) {
                         localTransactionState = LocalTransactionState.UNKNOW;
-- 
GitLab