Skip to content

Commit 8517afa

Browse files
committed
[ISSUE #727] add RocketMQConsumerLifecycleListener
1 parent e270f3a commit 8517afa

File tree

1 file changed

+1
-1
lines changed
  • rocketmq-v5-client-spring-boot-samples/rocketmq-v5-client-consume-acl-demo/src/main/java/org/apache/rocketmq/samples/springboot/consumer

1 file changed

+1
-1
lines changed

rocketmq-v5-client-spring-boot-samples/rocketmq-v5-client-consume-acl-demo/src/main/java/org/apache/rocketmq/samples/springboot/consumer/ACLConsumer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@
2727
import org.springframework.stereotype.Service;
2828

2929
@Service
30-
@RocketMQMessageListener(
30+
@RocketMQMessageListener(accessKey = "${demo.acl.rocketmq.access-key:}", secretKey = "${demo.acl.rocketmq.secret-key:}",
3131
tag = "${demo.acl.rocketmq.tag:}", topic = "${demo.acl.rocketmq.topic:}",
3232
endpoints = "${demo.acl.rocketmq.endpoints:}", consumerGroup = "${demo.acl.rocketmq.consumer-group:}")
3333
public class ACLConsumer implements RocketMQListener, RocketMQPushConsumerLifecycleListener {

0 commit comments

Comments
 (0)