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 0110055 [ISSUE #74]Add acl examples compile in the project (#75)
0110055 is described below
commit 011005560ad24b742ed318557c13e28f1d0c8a14
Author: dinglei <[email protected]>
AuthorDate: Sat May 25 09:08:44 2019 +0800
[ISSUE #74]Add acl examples compile in the project (#75)
* Fix checkstyle error in the acl examples
* Add acl example compile
---
rocketmq-spring-boot-samples/pom.xml | 2 ++
.../java/org/apache/rocketmq/samples/springboot/ACLStringConsumer.java | 2 +-
.../rocketmq/samples/springboot/ACLStringTransactionalConsumer.java | 2 +-
.../org/apache/rocketmq/samples/springboot/ProducerACLApplication.java | 2 +-
4 files changed, 5 insertions(+), 3 deletions(-)
diff --git a/rocketmq-spring-boot-samples/pom.xml
b/rocketmq-spring-boot-samples/pom.xml
index ca50687..e348e15 100644
--- a/rocketmq-spring-boot-samples/pom.xml
+++ b/rocketmq-spring-boot-samples/pom.xml
@@ -33,6 +33,8 @@
<modules>
<module>rocketmq-produce-demo</module>
<module>rocketmq-consume-demo</module>
+ <module>rocketmq-produce-acl-demo</module>
+ <module>rocketmq-consume-acl-demo</module>
</modules>
<properties>
diff --git
a/rocketmq-spring-boot-samples/rocketmq-consume-acl-demo/src/main/java/org/apache/rocketmq/samples/springboot/ACLStringConsumer.java
b/rocketmq-spring-boot-samples/rocketmq-consume-acl-demo/src/main/java/org/apache/rocketmq/samples/springboot/ACLStringConsumer.java
index fdddffd..fe99d38 100644
---
a/rocketmq-spring-boot-samples/rocketmq-consume-acl-demo/src/main/java/org/apache/rocketmq/samples/springboot/ACLStringConsumer.java
+++
b/rocketmq-spring-boot-samples/rocketmq-consume-acl-demo/src/main/java/org/apache/rocketmq/samples/springboot/ACLStringConsumer.java
@@ -30,7 +30,7 @@ import org.springframework.stereotype.Service;
consumerGroup = "group_define_in_Aliware_MQ"
//accessKey = "AK" // It will read by `rocketmq.consumer.access-key` key
//secretKey = "SK" // It will read by `rocketmq.consumer.access-key` key
-)
+ )
public class ACLStringConsumer implements RocketMQListener<String> {
@Override
public void onMessage(String message) {
diff --git
a/rocketmq-spring-boot-samples/rocketmq-consume-acl-demo/src/main/java/org/apache/rocketmq/samples/springboot/ACLStringTransactionalConsumer.java
b/rocketmq-spring-boot-samples/rocketmq-consume-acl-demo/src/main/java/org/apache/rocketmq/samples/springboot/ACLStringTransactionalConsumer.java
index d815e8c..342f44b 100644
---
a/rocketmq-spring-boot-samples/rocketmq-consume-acl-demo/src/main/java/org/apache/rocketmq/samples/springboot/ACLStringTransactionalConsumer.java
+++
b/rocketmq-spring-boot-samples/rocketmq-consume-acl-demo/src/main/java/org/apache/rocketmq/samples/springboot/ACLStringTransactionalConsumer.java
@@ -30,7 +30,7 @@ import org.springframework.stereotype.Service;
consumerGroup = "group_define_in_Aliware_MQ",
accessKey = "AK", // if accessKey is empty, it will read by
`rocketmq.consumer.access-key` key
secretKey = "SK" // if accessKey is empty, it will read by
`rocketmq.consumer.secret-key` key
-)
+ )
public class ACLStringTransactionalConsumer implements
RocketMQListener<String> {
@Override
public void onMessage(String message) {
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 0796c5e..1c40354 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
@@ -91,7 +91,7 @@ public class ProducerACLApplication implements
CommandLineRunner {
txProducerGroup = TX_PGROUP_NAME,
accessKey = "AK", // if not setting, it will read by
`rocketmq.producer.access-key` key
secretKey = "SK" // if not setting, it will read by
`rocketmq.producer.secret-key` key
- )
+ )
class TransactionListenerImpl implements RocketMQLocalTransactionListener {
private AtomicInteger transactionIndex = new AtomicInteger(0);