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]
