From 9db2acdb850db07cf2f357d97ef533fcd877339c Mon Sep 17 00:00:00 2001 From: duhengforever Date: Thu, 9 Aug 2018 10:00:37 +0800 Subject: [PATCH] Rename variable name --- .../rocketmq/example/transaction/TransactionProducer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 6d80b225..a4c3f351 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); -- GitLab