rocketmq模块: acl

guolanren · Apr 13, 2020 · 5638634 · 5638634
1 parent 5f46f53
commit 5638634
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 3 deletions.
diff --git a/rocketmq/rocketmq-consumer/src/main/java/name/guolanren/service/OrderPaidService.java b/rocketmq/rocketmq-consumer/src/main/java/name/guolanren/service/OrderPaidService.java
@@ -16,7 +16,7 @@ public class OrderPaidService {
     private static final Logger logger = LoggerFactory.getLogger(OrderPaidService.class);
 
     @Service
-    @RocketMQMessageListener(topic = "my-topic", consumerGroup = "my-topic-group")
+    @RocketMQMessageListener(topic = "my-topic", consumerGroup = "my-topic-group" /* , accessKey = "AK", secretKey = "SK" */)
     public class StringConsumer implements RocketMQListener<String>{
         @Override
         public void onMessage(String message) {

diff --git a/rocketmq/rocketmq-consumer/src/main/resources/application.properties b/rocketmq/rocketmq-consumer/src/main/resources/application.properties
@@ -1,3 +1,5 @@
 spring.application.name = rocketmq-consumer
 
-rocketmq.name-server = 192.168.124.135:9876;192.168.124.136:9876
+rocketmq.name-server = 192.168.124.135:9876;192.168.124.136:9876
+rocketmq.consumer.access-key = AK
+rocketmq.consumer.secret-key = SK
diff --git a/rocketmq/rocketmq-producer/src/main/resources/application.properties b/rocketmq/rocketmq-producer/src/main/resources/application.properties
@@ -1,4 +1,6 @@
 spring.application.name = rocketmq-producer
 
 rocketmq.name-server = 192.168.124.135:9876;192.168.124.136:9876
-rocketmq.producer.group = my-group
+rocketmq.producer.group = my-group
+#rocketmq.producer.access-key = AK
+#rocketmq.producer.secret-key = SK