rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ding...@apache.org
Subject [rocketmq-spring] branch master updated: Set the correct transaction id identification key for subsequent operations. (#82)
Date Tue, 04 Jun 2019 09:32:54 GMT
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+lookcoder@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",


Mime
View raw message