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 index ff03ec5..fd37a53 100644 --- 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{ @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 index 49cd9ee..6e856f4 100644 --- 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 \ No newline at end of file +rocketmq.name-server = 192.168.124.135:9876;192.168.124.136:9876 +rocketmq.consumer.access-key = AK +rocketmq.consumer.secret-key = SK \ No newline at end of file diff --git a/rocketmq/rocketmq-producer/src/main/resources/application.properties b/rocketmq/rocketmq-producer/src/main/resources/application.properties index ade315e..415172c 100644 --- 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 \ No newline at end of file +rocketmq.producer.group = my-group +#rocketmq.producer.access-key = AK +#rocketmq.producer.secret-key = SK \ No newline at end of file