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

GH-1799 Defer channel initialization until it is configured

Browse Source 
Resolves #1799
This commit is contained in:
Oleg Zhurakousky
2019-09-11 14:33:29 +02:00
parent 043bf8e8c6
commit 284d37fa2b
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/BinderAwareChannelResolver.java
View File

@@ -102,9 +102,6 @@ public class BinderAwareChannelResolver
}
else {
channel = this.bindingTargetFactory.createOutput(channelName);
this.beanFactory.registerSingleton(channelName, channel);
channel = (MessageChannel) this.beanFactory.initializeBean(channel,
channelName);
if (this.newBindingCallback != null) {
ProducerProperties producerProperties = bindingServiceProperties
.getProducerProperties(channelName);
@@ -115,6 +112,9 @@ public class BinderAwareChannelResolver
bindingServiceProperties.updateProducerProperties(channelName,
producerProperties);
}
this.beanFactory.registerSingleton(channelName, channel);
channel = (MessageChannel) this.beanFactory.initializeBean(channel,
channelName);
Binding<MessageChannel> binding = this.bindingService
.bindProducer(channel, channelName);
this.dynamicDestinationsBindable.addOutputBinding(channelName, binding);