diff --git a/example/src/main/java/org/apache/rocketmq/example/transaction/TransactionProducer.java b/example/src/main/java/org/apache/rocketmq/example/transaction/TransactionProducer.java
index 6d80b225d463b90a97ec8d3fd0ce2d3baf26e547..a4c3f351f5a453d5294d5207afe097362698003c 100644
--- a/example/src/main/java/org/apache/rocketmq/example/transaction/TransactionProducer.java
+++ b/example/src/main/java/org/apache/rocketmq/example/transaction/TransactionProducer.java
@@ -43,7 +43,7 @@ public class TransactionProducer {
                 return thread;
             }
         });
-        LocalTransactionExecuter executor = new LocalTransactionExecuterImpl();
+        LocalTransactionExecuter localTransactionExecuter = new LocalTransactionExecuterImpl();
         producer.setExecutorService(executorService);
         producer.setTransactionCheckListener(transactionListener);
         producer.start();
@@ -54,7 +54,7 @@ public class TransactionProducer {
                 Message msg =
                     new Message("TopicTest1234", tags[i % tags.length], "KEY" + i,
                         ("Hello RocketMQ " + i).getBytes(RemotingHelper.DEFAULT_CHARSET));
-                SendResult sendResult = producer.sendMessageInTransaction(msg, executor,null);
+                SendResult sendResult = producer.sendMessageInTransaction(msg, localTransactionExecuter,null);
                 System.out.printf("%s%n", sendResult);
 
                 Thread.sleep(10);