SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Polishing KafkaStreamsBinderUtils

Browse Source 
Added registerBean(..) instead of registerSingleton

Resolves #675
This commit is contained in:
Oleg Zhurakousky
2019-06-18 16:21:49 +02:00
parent 12afaf1144
commit c1e58d187a
1 changed files with 9 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsBinderUtils.java
View File

@@ -27,6 +27,7 @@ import org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProv
import org.springframework.cloud.stream.binder.kafka.streams.properties.KafkaStreamsBinderConfigurationProperties;
import org.springframework.cloud.stream.binder.kafka.streams.properties.KafkaStreamsConsumerProperties;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.GenericApplicationContext;
import org.springframework.core.MethodParameter;
import org.springframework.util.StringUtils;
@@ -95,17 +96,15 @@ final class KafkaStreamsBinderUtils {
static BeanFactoryPostProcessor outerContextBeanFactoryPostProcessor() {
return (beanFactory) -> {
// It is safe to call getBean("outerContext") here, because this bean is
// registered as first
// and as independent from the parent context.
ApplicationContext outerContext = (ApplicationContext) beanFactory
// registered first and is independent from the parent context.
GenericApplicationContext outerContext = (GenericApplicationContext) beanFactory
.getBean("outerContext");
beanFactory.registerSingleton(
KafkaStreamsBinderConfigurationProperties.class.getSimpleName(),
outerContext
.getBean(KafkaStreamsBinderConfigurationProperties.class));
beanFactory.registerSingleton(
KafkaStreamsBindingInformationCatalogue.class.getSimpleName(),
outerContext.getBean(KafkaStreamsBindingInformationCatalogue.class));
outerContext.registerBean(KafkaStreamsBinderConfigurationProperties.class,
() -> outerContext.getBean(KafkaStreamsBinderConfigurationProperties.class));
outerContext.registerBean(KafkaStreamsBindingInformationCatalogue.class,
() -> outerContext.getBean(KafkaStreamsBindingInformationCatalogue.class));
};
}