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

DirectChannelFactoryBean should set the bean name and bean factory on created instance

Browse Source
This commit is contained in:
Marius Bogoevici
2015-08-18 16:49:29 -04:00
parent 3dac86a18a
commit 79c13a8ab2
1 changed files with 21 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
spring-cloud-stream/src/main/java/org/springframework/cloud/stream/config/DirectChannelFactoryBean.java
View File

@@ -16,9 +16,12 @@
package org.springframework.cloud.stream.config;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.BeanFactory;
import org.springframework.beans.factory.BeanFactoryAware;
import org.springframework.beans.factory.BeanNameAware;
import org.springframework.beans.factory.FactoryBean;
import org.springframework.integration.channel.DirectChannel;
import org.springframework.messaging.MessageChannel;
/**
* {@link FactoryBean} for creating channels for fields annotated with
@@ -27,15 +30,30 @@ import org.springframework.messaging.MessageChannel;
*
* @author Marius Bogoevici
*/
public class DirectChannelFactoryBean implements FactoryBean<MessageChannel> {
public class DirectChannelFactoryBean implements FactoryBean<DirectChannel>, BeanNameAware, BeanFactoryAware {
private DirectChannel directChannel;
private String beanName;
private BeanFactory beanFactory;
@Override
public synchronized MessageChannel getObject() throws Exception {
public void setBeanName(String beanName) {
this.beanName = beanName;
}
@Override
public void setBeanFactory(BeanFactory beanFactory) throws BeansException {
this.beanFactory = beanFactory;
}
@Override
public synchronized DirectChannel getObject() throws Exception {
if (directChannel == null) {
directChannel = new DirectChannel();
}
directChannel.setBeanName(beanName);
directChannel.setBeanFactory(beanFactory);
return directChannel;
}