[rocketmq-spring] branch master updated: Set the correct transaction id identification key for subsequent operations. (#82)

[dinglei]

This is an automated email from the ASF dual-hosted git repository.

dinglei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-spring.git


The following commit(s) were added to refs/heads/master by this push:
     new 813f0d8  Set the correct transaction id identification key for 
subsequent operations. (#82)
813f0d8 is described below

commit 813f0d8100f9da98e12b947d7ff43062afe4e3eb
Author: lookcoder <19659120+lookco...@users.noreply.github.com>
AuthorDate: Tue Jun 4 04:32:49 2019 -0500

    Set the correct transaction id identification key for subsequent 
operations. (#82)
    
    * Set the correct transaction id identification key for subsequent 
operations.
---
 .../org/apache/rocketmq/samples/springboot/ProducerACLApplication.java  | 2 +-
 .../org/apache/rocketmq/samples/springboot/ProducerApplication.java     | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/rocketmq-spring-boot-samples/rocketmq-produce-acl-demo/src/main/java/org/apache/rocketmq/samples/springboot/ProducerACLApplication.java
 
b/rocketmq-spring-boot-samples/rocketmq-produce-acl-demo/src/main/java/org/apache/rocketmq/samples/springboot/ProducerACLApplication.java
index 1c40354..498c2e1 100644
--- 
a/rocketmq-spring-boot-samples/rocketmq-produce-acl-demo/src/main/java/org/apache/rocketmq/samples/springboot/ProducerACLApplication.java
+++ 
b/rocketmq-spring-boot-samples/rocketmq-produce-acl-demo/src/main/java/org/apache/rocketmq/samples/springboot/ProducerACLApplication.java
@@ -74,7 +74,7 @@ public class ProducerACLApplication implements 
CommandLineRunner {
             try {
 
                 Message msg = MessageBuilder.withPayload("Hello RocketMQ " + 
i).
-                    setHeader(RocketMQHeaders.KEYS, "KEY_" + i).build();
+                    setHeader(RocketMQHeaders.TRANSACTION_ID, "KEY_" + 
i).build();
                 SendResult sendResult = 
rocketMQTemplate.sendMessageInTransaction(TX_PGROUP_NAME,
                     springTransTopic + ":" + tags[i % tags.length], msg, null);
                 System.out.printf("------ send Transactional msg body = %s , 
sendResult=%s %n",
diff --git 
a/rocketmq-spring-boot-samples/rocketmq-produce-demo/src/main/java/org/apache/rocketmq/samples/springboot/ProducerApplication.java
 
b/rocketmq-spring-boot-samples/rocketmq-produce-demo/src/main/java/org/apache/rocketmq/samples/springboot/ProducerApplication.java
index 9e49170..8ab42e1 100644
--- 
a/rocketmq-spring-boot-samples/rocketmq-produce-demo/src/main/java/org/apache/rocketmq/samples/springboot/ProducerApplication.java
+++ 
b/rocketmq-spring-boot-samples/rocketmq-produce-demo/src/main/java/org/apache/rocketmq/samples/springboot/ProducerApplication.java
@@ -122,7 +122,7 @@ public class ProducerApplication implements 
CommandLineRunner {
             try {
 
                 Message msg = MessageBuilder.withPayload("Hello RocketMQ " + 
i).
-                    setHeader(RocketMQHeaders.KEYS, "KEY_" + i).build();
+                    setHeader(RocketMQHeaders.TRANSACTION_ID, "KEY_" + 
i).build();
                 SendResult sendResult = 
rocketMQTemplate.sendMessageInTransaction(TX_PGROUP_NAME,
                     springTransTopic + ":" + tags[i % tags.length], msg, null);
                 System.out.printf("------ send Transactional msg body = %s , 
sendResult=%s %n",