study/Spring-Cloud-Alibaba
1
0
Fork 0
mirror of https://gitee.com/mirrors/Spring-Cloud-Alibaba.git synced 2021-06-26 13:25:11 +08:00
Code Issues Releases Wiki Activity

issue#2040

Browse Source 
移除RocketMQConfigBeanPostProcessor在RocketMQBinderAutoConfiguration类中的注入，改为通过spirng.factories注入，原来是通过spirng.binders经过spring-cloud-stream代理
This commit is contained in:
Spike 2021-04-15 13:32:13 +08:00
parent 3ee8d4bf56
commit 1f9f10ce90
2 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/java/com/alibaba/cloud/stream/binder/rocketmq/autoconfigurate/RocketMQBinderAutoConfiguration.java
View File

@ -50,11 +50,6 @@ public class RocketMQBinderAutoConfiguration {
@Autowired @Autowired
private RocketMQBinderConfigurationProperties rocketBinderConfigurationProperties; private RocketMQBinderConfigurationProperties rocketBinderConfigurationProperties;
@Bean
public RocketMQConfigBeanPostProcessor rocketMQConfigBeanPostProcessor() {
return new RocketMQConfigBeanPostProcessor();
}
@Bean(RocketMQMessageConverter.DEFAULT_NAME) @Bean(RocketMQMessageConverter.DEFAULT_NAME)
@ConditionalOnMissingBean(name = { RocketMQMessageConverter.DEFAULT_NAME }) @ConditionalOnMissingBean(name = { RocketMQMessageConverter.DEFAULT_NAME })
public CompositeMessageConverter rocketMQMessageConverter() { public CompositeMessageConverter rocketMQMessageConverter() {

3
spring-cloud-alibaba-starters/spring-cloud-starter-stream-rocketmq/src/main/resources/META-INF/spring.factories
View File

@ -1,2 +1,3 @@
org.springframework.boot.autoconfigure.EnableAutoConfiguration=\ org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
com.alibaba.cloud.stream.binder.rocketmq.autoconfigurate.ExtendedBindingHandlerMappingsProviderConfiguration com.alibaba.cloud.stream.binder.rocketmq.autoconfigurate.ExtendedBindingHandlerMappingsProviderConfiguration,\
com.alibaba.cloud.stream.binder.rocketmq.custom.RocketMQConfigBeanPostProcessor