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

Generate proper qualifiers for channel beans

Browse Source
This commit is contained in:
Marius Bogoevici
2015-07-21 21:21:46 -04:00
committed by Mark Fisher
parent bb25e6b46e
commit dca40fec59
1 changed files with 24 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
spring-cloud-stream/src/main/java/org/springframework/cloud/stream/utils/MessageChannelBeanDefinitionRegistryUtils.java
View File

@@ -48,22 +48,40 @@ import org.springframework.util.StringUtils;
*/
public abstract class MessageChannelBeanDefinitionRegistryUtils {
public static final String DEFAULT_INPUT_QUALIFIER_VALUE;
public static final String DEFAULT_OUTPUT_QUALIFIER_VALUE;
static {
DEFAULT_INPUT_QUALIFIER_VALUE = (String) ReflectionUtils.findMethod(Input.class, "value").getDefaultValue();
DEFAULT_OUTPUT_QUALIFIER_VALUE = (String) ReflectionUtils.findMethod(Output.class, "value").getDefaultValue();
}
public static void registerInputChannelBeanDefinition(String name,
BeanDefinitionRegistry registry) {
registerChannelBeanDefinition(Input.class, name, registry);
registerInputChannelBeanDefinition(DEFAULT_INPUT_QUALIFIER_VALUE, name, registry);
}
public static void registerInputChannelBeanDefinition(String qualifierValue, String name,
BeanDefinitionRegistry registry) {
registerChannelBeanDefinition(Input.class, qualifierValue, name, registry);
}
public static void registerOutputChannelBeanDefinition(String name,
BeanDefinitionRegistry registry) {
registerChannelBeanDefinition(Output.class, name, registry);
registerOutputChannelBeanDefinition(DEFAULT_OUTPUT_QUALIFIER_VALUE, name, registry);
}
public static void registerOutputChannelBeanDefinition(String qualifierValue, String name,BeanDefinitionRegistry registry) {
registerChannelBeanDefinition(Output.class, qualifierValue, name, registry);
}
private static void registerChannelBeanDefinition(
Class<? extends Annotation> qualifier, String name,
Class<? extends Annotation> qualifier, String qualifierValue, String name,
BeanDefinitionRegistry registry) {
RootBeanDefinition rootBeanDefinition = new RootBeanDefinition(
DirectChannelFactoryBean.class);
rootBeanDefinition.addQualifier(new AutowireCandidateQualifier(qualifier));
rootBeanDefinition.addQualifier(new AutowireCandidateQualifier(qualifier, qualifierValue));
registry.registerBeanDefinition(name, rootBeanDefinition);
}
@@ -76,12 +94,12 @@ public abstract class MessageChannelBeanDefinitionRegistryUtils {
Input input = AnnotationUtils.findAnnotation(method, Input.class);
if (input != null) {
String name = getName(input, method);
registerInputChannelBeanDefinition(name, registry);
registerInputChannelBeanDefinition(name, input.value(), registry);
}
Output output = AnnotationUtils.findAnnotation(method, Output.class);
if (output != null) {
String name = getName(output, method);
registerOutputChannelBeanDefinition(name, registry);
registerOutputChannelBeanDefinition(name, output.value(), registry);
}
}