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

GH-1621 Ensured BF is injected in MessageSource if applicable

Browse Source 
Resolves #1621
This commit is contained in:
Oleg Zhurakousky
2019-02-28 16:35:27 +01:00
parent 53268ed631
commit 2e4c2370c8
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/AbstractMessageChannelBinder.java
View File

@@ -26,6 +26,7 @@ import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.commons.logging.Log;
import org.reactivestreams.Publisher;
import org.springframework.beans.factory.BeanFactoryAware;
import org.springframework.beans.factory.DisposableBean;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.annotation.Autowired;
@@ -460,7 +461,12 @@ public abstract class AbstractMessageChannelBinder<C extends ConsumerProperties,
}
final PolledConsumerResources resources = createPolledConsumerResources(name,
group, destination, properties);
bindingTarget.setSource(resources.getSource());
MessageSource<?> messageSource = resources.getSource();
if (messageSource instanceof BeanFactoryAware) {
// ((BeanFactoryAware)messageSource).setBeanFactory(getApplicationContext().getBeanFactory());
}
bindingTarget.setSource(messageSource);
if (resources.getErrorInfrastructure() != null) {
if (resources.getErrorInfrastructure().getErrorChannel() != null) {
bindingTarget.setErrorChannel(