[ISSUE #727] add RocketMQConsumerLifecycleListener

Author: panzhi33

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

@@ -23,13 +23,17 @@
 import org.apache.rocketmq.client.apis.message.MessageView;
 import org.apache.rocketmq.client.core.RocketMQListener;
 import org.apache.rocketmq.client.core.RocketMQPushConsumerLifecycleListener;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
 @Service
-@RocketMQMessageListener(accessKey = "${demo.acl.rocketmq.access-key:}", secretKey = "${demo.acl.rocketmq.secret-key:}",
+@RocketMQMessageListener(
         tag = "${demo.acl.rocketmq.tag:}", topic = "${demo.acl.rocketmq.topic:}",
         endpoints = "${demo.acl.rocketmq.endpoints:}", consumerGroup = "${demo.acl.rocketmq.consumer-group:}")
 public class ACLConsumer implements RocketMQListener, RocketMQPushConsumerLifecycleListener {
+
+    @Value("${demo.acl.rocketmq.consumptionThreadCount}")
+    private Integer consumptionThreadCount;
     @Override
     public ConsumeResult consume(MessageView messageView) {
         System.out.println("handle my acl message:" + messageView);
@@ -38,7 +42,7 @@ public ConsumeResult consume(MessageView messageView) {
 
     @Override
     public void prepareStart(PushConsumerBuilder consumerBuilder) {
-        consumerBuilder.setConsumptionThreadCount(16);
+        consumerBuilder.setConsumptionThreadCount(consumptionThreadCount);
     }
 }
 

rocketmq-v5-client-spring-boot-samples/rocketmq-v5-client-consume-acl-demo/src/main/resources/application.properties

@@ -4,4 +4,4 @@ demo.acl.rocketmq.consumer-group=normalGroup
 demo.acl.rocketmq.access-key=RocketMQ
 demo.acl.rocketmq.secret-key=12345678
 demo.acl.rocketmq.tag=*
-
+demo.acl.rocketmq.consumptionThreadCount=32