freedom0123 commented on issue #747:
URL: 
https://github.com/apache/rocketmq-spring/issues/747#issuecomment-3602257844

   RocketMQProperties 里面没有 Push-consumer 的配置了,代码里面,实际上在 构建 
DefaultListenerContainer 时
   
   <img width="885" height="602" alt="Image" 
src="https://github.com/user-attachments/assets/11232296-b235-42bb-a94a-c5826da05c05";
 />
   
   ```java
   private DefaultListenerContainer createRocketMQListenerContainer(String 
name, Object bean, RocketMQMessageListener annotation) {
           DefaultListenerContainer container = new DefaultListenerContainer();
           container.setName(name);
           container.setRocketMQMessageListener(annotation);
           container.setMessageListener((RocketMQListener) bean);
           
container.setAccessKey(environment.resolvePlaceholders(annotation.accessKey()));
           
container.setSecretKey(environment.resolvePlaceholders(annotation.secretKey()));
           
container.setConsumerGroup(environment.resolvePlaceholders(annotation.consumerGroup()));
           container.setTag(environment.resolvePlaceholders(annotation.tag()));
           // 这里 
           
container.setEndpoints(environment.resolvePlaceholders(annotation.endpoints()));
           
container.setTopic(environment.resolvePlaceholders(annotation.topic()));
           
container.setNamespace(environment.resolvePlaceholders(annotation.namespace()));
           
container.setRequestTimeout(Duration.ofSeconds(annotation.requestTimeout()));
           
container.setMaxCachedMessageCount(annotation.maxCachedMessageCount());
           
container.setConsumptionThreadCount(annotation.consumptionThreadCount());
           
container.setMaxCacheMessageSizeInBytes(annotation.maxCacheMessageSizeInBytes());
           container.setType(annotation.filterExpressionType());
           return container;
       }
   ```
   通过这种方式,从配置文件之中获取的
   ```java
   String ENDPOINTS_PLACEHOLDER = "${rocketmq.push-consumer.endpoints:}"; 
   ```
   我理解是没有取消吧? 但是为什么不直接放在 RocketMQProperties 之中呢?


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to