opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-11-01 03:22:45 +08:00
Code Issues Packages Projects Releases Wiki Activity

Rename variable name

Browse Source
This commit is contained in:
duhengforever
2018-08-09 10:00:37 +08:00
parent da9d5c3f43
commit 9db2acdb85
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
example/src/main/java/org/apache/rocketmq/example/transaction/TransactionProducer.java
+2 -2
View File
@@ -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);