@SuppressWarnings({ "unchecked", "rawtypes" })
@Bean(destroyMethod = "stop")
@Scope(BeanDefinition.SCOPE_PROTOTYPE)
public KafkaMessageConsumer kafkaMessageConsumer(final String topic) {
return new KafkaMessageConsumer<>(this.kafkaConsumerConfig(), topic, this.senderProvider(), this.messagePublisherProvider());
}
java类org.springframework.beans.factory.config.BeanDefinition的实例源码
ContextConfiguration.java 文件源码
项目:kalinka
阅读 35
收藏 0
点赞 0
评论 0
PropertyPlaceholderConfig.java 文件源码
项目:jaffa-framework
阅读 25
收藏 0
点赞 0
评论 0
/**
* Load the properties files used in application contexts here
*
* @return the initialized instance of the PropertyPlaceholderConfigurer class
*/
@Bean(name="properties")
@Scope(BeanDefinition.SCOPE_SINGLETON)
public PropertyPlaceholderConfigurer conversionService() {
PropertyPlaceholderConfigurer configurer = new PropertyPlaceholderConfigurer();
Resource resource1 = new ClassPathResource("application_file_1.properties");
Resource resource2 = new ClassPathResource("application_file_2.properties");
configurer.setLocations(resource1, resource2);
return configurer;
}
OverrideInternalBeanParser.java 文件源码
项目:bdf2
阅读 20
收藏 0
点赞 0
评论 0
public BeanDefinition parse(Element element, ParserContext parserContext) {
String nodeName=parserContext.getDelegate().getLocalName(element);
String refBeanId=element.getAttribute("ref");
RuntimeBeanReference runtimeBean=new RuntimeBeanReference(refBeanId);
RootBeanDefinition beanDefinition=new RootBeanDefinition(OverrideInternalBeanFactoryBean.class);
beanDefinition.getPropertyValues().addPropertyValue("referenceBean", runtimeBean);
beanDefinition.getPropertyValues().addPropertyValue("targetBeanClass", classMap.get(nodeName));
beanDefinition.getPropertyValues().addPropertyValue("referenceBeanId", refBeanId);
String id=beanIdMap.get(nodeName);
parserContext.registerBeanComponent(new BeanComponentDefinition(beanDefinition,id));
return beanDefinition;
}
SpringBlueprintContainer.java 文件源码
项目:gemini.blueprint
阅读 22
收藏 0
点赞 0
评论 0
public ComponentMetadata getComponentMetadata(String name) throws NoSuchComponentException {
if (getBeanFactory().containsBeanDefinition(name)) {
BeanDefinition beanDefinition = getBeanFactory().getBeanDefinition(name);
return MetadataFactory.buildComponentMetadataFor(name, beanDefinition);
} else {
throw new NoSuchComponentException(name);
}
}
AopNamespaceUtils.java 文件源码
项目:lams
阅读 24
收藏 0
点赞 0
评论 0
public static void registerAspectJAnnotationAutoProxyCreatorIfNecessary(
ParserContext parserContext, Element sourceElement) {
BeanDefinition beanDefinition = AopConfigUtils.registerAspectJAnnotationAutoProxyCreatorIfNecessary(
parserContext.getRegistry(), parserContext.extractSource(sourceElement));
useClassProxyingIfNecessary(parserContext.getRegistry(), sourceElement);
registerComponentIfNecessary(beanDefinition, parserContext);
}
BeanTypeRegistry.java 文件源码
项目:spring-boot-autoconfigure
阅读 21
收藏 0
点赞 0
评论 0
private Method getFactoryMethod(ConfigurableListableBeanFactory beanFactory,
BeanDefinition definition) throws Exception {
if (definition instanceof AnnotatedBeanDefinition) {
MethodMetadata factoryMethodMetadata = ((AnnotatedBeanDefinition) definition).getFactoryMethodMetadata();
if (factoryMethodMetadata instanceof StandardMethodMetadata) {
return ((StandardMethodMetadata) factoryMethodMetadata).getIntrospectedMethod();
}
}
BeanDefinition factoryDefinition = beanFactory.getBeanDefinition(definition.getFactoryBeanName());
Class<?> factoryClass = ClassUtils.forName(factoryDefinition.getBeanClassName(), beanFactory.getBeanClassLoader());
return getFactoryMethod(definition, factoryClass);
}
BeanDefinitionParserDelegate.java 文件源码
项目:lams
阅读 32
收藏 0
点赞 0
评论 0
/**
* Parse a set element.
*/
public Set<Object> parseSetElement(Element collectionEle, BeanDefinition bd) {
String defaultElementType = collectionEle.getAttribute(VALUE_TYPE_ATTRIBUTE);
NodeList nl = collectionEle.getChildNodes();
ManagedSet<Object> target = new ManagedSet<Object>(nl.getLength());
target.setSource(extractSource(collectionEle));
target.setElementTypeName(defaultElementType);
target.setMergeEnabled(parseMergeAttribute(collectionEle));
parseCollectionElements(nl, target, bd, defaultElementType);
return target;
}
NoAutoStartClassPathXmlApplicationContext.java 文件源码
项目:alfresco-data-model
阅读 24
收藏 0
点赞 0
评论 0
@Override
public void parsePropertyElement(Element ele, BeanDefinition bd) {
String propertyName = ele.getAttribute("name");
if("autoStart".equals(propertyName)) {
if("abstractPropertyBackedBean".equals(bd.getParentName())) {
String id = ele.getParentNode().getAttributes().getNamedItem("id").getTextContent();
System.out.println("Preventing the autostart of Subsystem " + id);
return;
}
}
super.parsePropertyElement(ele, bd);
}
TestController.java 文件源码
项目:saluki
阅读 28
收藏 0
点赞 0
评论 0
private Collection<Object> getTypedBeansWithAnnotation(Class<? extends Annotation> annotationType)
throws Exception {
return Stream.of(applicationContext.getBeanNamesForAnnotation(annotationType)).filter(name -> {
BeanDefinition beanDefinition = applicationContext.getBeanFactory().getBeanDefinition(name);
if (beanDefinition.getSource() instanceof StandardMethodMetadata) {
StandardMethodMetadata metadata = (StandardMethodMetadata) beanDefinition.getSource();
return metadata.isAnnotated(annotationType.getName());
}
return null != applicationContext.getBeanFactory().findAnnotationOnBean(name, annotationType);
}).map(name -> applicationContext.getBeanFactory().getBean(name)).collect(Collectors.toList());
}
BogusHandler.java 文件源码
项目:gemini.blueprint
阅读 26
收藏 0
点赞 0
评论 0
public BeanDefinition parse(Element element, ParserContext parserContext) {
BeanDefinitionRegistry registry = parserContext.getRegistry();
registry.registerBeanDefinition("nsDate", BeanDefinitionBuilder.genericBeanDefinition("java.util.Date").getBeanDefinition());
registry.registerBeanDefinition("nsBean", BeanDefinitionBuilder.genericBeanDefinition("java.awt.Rectangle").getBeanDefinition());
return null;
}