Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Introduced AbstractRouterParser.

Browse Source
This commit is contained in:
Mark Fisher
2009-06-19 18:31:34 +00:00
parent 36343efda8
commit 0f8f07a47f
6 changed files with 53 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

44
org.springframework.integration/src/main/java/org/springframework/integration/config/xml/AbstractRouterParser.java Normal file
View File

@@ -0,0 +1,44 @@
/*
* Copyright 2002-2009 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.springframework.integration.config.xml;
import org.w3c.dom.Element;
import org.springframework.beans.factory.support.BeanDefinitionBuilder;
import org.springframework.beans.factory.xml.ParserContext;
/**
* Base parser for routers.
*
* @author Mark Fisher
*/
public abstract class AbstractRouterParser extends AbstractConsumerEndpointParser {
@Override
protected final BeanDefinitionBuilder parseHandler(Element element, ParserContext parserContext) {
BeanDefinitionBuilder builder = BeanDefinitionBuilder.genericBeanDefinition(
IntegrationNamespaceUtils.BASE_PACKAGE + ".config.RouterFactoryBean");
IntegrationNamespaceUtils.setReferenceIfAttributeDefined(builder, element, "default-output-channel");
IntegrationNamespaceUtils.setValueIfAttributeDefined(builder, element, "resolution-required");
IntegrationNamespaceUtils.setValueIfAttributeDefined(builder, element, "ignore-channel-name-resolution-failures");
this.parseRouter(element, builder, parserContext);
return builder;
}
protected abstract void parseRouter(Element element, BeanDefinitionBuilder rootBuilder, ParserContext parserContext);
}

18
org.springframework.integration/src/main/java/org/springframework/integration/config/xml/RouterParser.java → org.springframework.integration/src/main/java/org/springframework/integration/config/xml/DefaultRouterParser.java
View File

@@ -29,20 +29,15 @@ import org.springframework.util.StringUtils;
* @author Mark Fisher
* @author Oleg Zhurakousky
*/
public class RouterParser extends AbstractConsumerEndpointParser {
public class DefaultRouterParser extends AbstractRouterParser {
@Override
protected BeanDefinitionBuilder parseHandler(Element element, ParserContext parserContext) {
protected void parseRouter(Element element, BeanDefinitionBuilder builder, ParserContext parserContext) {
String ref = element.getAttribute(REF_ATTRIBUTE);
if (!StringUtils.hasText(ref)) {
parserContext.getReaderContext().error("The '" + REF_ATTRIBUTE + "' attribute is required.", element);
}
BeanDefinitionBuilder builder = this.createBuilder();
builder.addPropertyReference("targetObject", ref);
return doParse(element, parserContext, builder);
}
protected BeanDefinitionBuilder doParse(Element element, ParserContext parserContext, BeanDefinitionBuilder builder) {
if (StringUtils.hasText(element.getAttribute(METHOD_ATTRIBUTE))) {
String method = element.getAttribute(METHOD_ATTRIBUTE);
builder.addPropertyValue("targetMethodName", method);
@@ -52,15 +47,6 @@ public class RouterParser extends AbstractConsumerEndpointParser {
String resolverBeanName = BeanDefinitionReaderUtils.registerWithGeneratedName(
resolverBuilder.getBeanDefinition(), parserContext.getRegistry());
builder.addPropertyReference("channelResolver", resolverBeanName);
IntegrationNamespaceUtils.setReferenceIfAttributeDefined(builder, element, "default-output-channel");
IntegrationNamespaceUtils.setValueIfAttributeDefined(builder, element, "resolution-required");
IntegrationNamespaceUtils.setValueIfAttributeDefined(builder, element, "ignore-channel-name-resolution-failures");
return builder;
}
BeanDefinitionBuilder createBuilder() {
return BeanDefinitionBuilder.genericBeanDefinition(
IntegrationNamespaceUtils.BASE_PACKAGE + ".config.RouterFactoryBean");
}
}

6
org.springframework.integration/src/main/java/org/springframework/integration/config/xml/HeaderValueRouterParser.java
View File

@@ -34,11 +34,11 @@ import org.springframework.util.xml.DomUtils;
* @author Mark Fisher
* @since 1.0.3
*/
public class HeaderValueRouterParser extends RouterParser {
public class HeaderValueRouterParser extends AbstractRouterParser {
@Override
@SuppressWarnings("unchecked")
protected BeanDefinitionBuilder parseHandler(Element element, ParserContext parserContext) {
protected void parseRouter(Element element, BeanDefinitionBuilder rootBuilder, ParserContext parserContext) {
BeanDefinitionBuilder headerValueRouterBuilder = BeanDefinitionBuilder.genericBeanDefinition(
IntegrationNamespaceUtils.BASE_PACKAGE + ".router.HeaderValueRouter");
headerValueRouterBuilder.addConstructorArgValue(element.getAttribute("header-name"));
@@ -57,9 +57,7 @@ public class HeaderValueRouterParser extends RouterParser {
mapBasedChannelResolverBuilder.getBeanDefinition(), parserContext.getRegistry());
headerValueRouterBuilder.addPropertyReference("channelResolver", resolverBeanName);
}
BeanDefinitionBuilder rootBuilder = this.createBuilder();
rootBuilder.addPropertyValue("targetObject", headerValueRouterBuilder.getBeanDefinition());
return this.doParse(element, parserContext, rootBuilder);
}
}

2
org.springframework.integration/src/main/java/org/springframework/integration/config/xml/IntegrationNamespaceHandler.java
View File

@@ -79,7 +79,7 @@ public class IntegrationNamespaceHandler implements NamespaceHandler {
registerBeanDefinitionParser("service-activator", new ServiceActivatorParser());
registerBeanDefinitionParser("transformer", new TransformerParser());
registerBeanDefinitionParser("filter", new FilterParser());
registerBeanDefinitionParser("router", new RouterParser());
registerBeanDefinitionParser("router", new DefaultRouterParser());
registerBeanDefinitionParser("header-value-router", new HeaderValueRouterParser());
registerBeanDefinitionParser("payload-type-router", new PayloadTypeRouterParser());
registerBeanDefinitionParser("splitter", new SplitterParser());

8
org.springframework.integration/src/main/java/org/springframework/integration/config/xml/PayloadTypeRouterParser.java
View File

@@ -35,11 +35,11 @@ import org.springframework.util.xml.DomUtils;
* @author Mark Fisher
* @since 1.0.3
*/
public class PayloadTypeRouterParser extends RouterParser {
public class PayloadTypeRouterParser extends AbstractRouterParser {
@Override
@SuppressWarnings("unchecked")
protected BeanDefinitionBuilder parseHandler(Element element, ParserContext parserContext) {
protected void parseRouter(Element element, BeanDefinitionBuilder rootBuilder, ParserContext parserContext) {
BeanDefinitionBuilder payloadTypeRouterBuilder = BeanDefinitionBuilder.genericBeanDefinition(
IntegrationNamespaceUtils.BASE_PACKAGE + ".router.PayloadTypeRouter");
List<Element> childElements = DomUtils.getChildElementsByTagName(element, "mapping");
@@ -56,9 +56,7 @@ public class PayloadTypeRouterParser extends RouterParser {
channelMap.put(typeName, new RuntimeBeanReference(childElement.getAttribute("channel")));
}
payloadTypeRouterBuilder.addPropertyValue("payloadTypeChannelMap", channelMap);
BeanDefinitionBuilder rootBuilder = this.createBuilder();
rootBuilder.addPropertyValue("targetObject", payloadTypeRouterBuilder.getBeanDefinition());
return this.doParse(element, parserContext, rootBuilder);
}
}

1
org.springframework.integration/src/main/java/org/springframework/integration/config/xml/spring-integration-1.0.xsd
View File

@@ -924,6 +924,7 @@
</xsd:appinfo>
</xsd:annotation>
</xsd:attribute>
<xsd:attribute name="timeout" type="xsd:string"/>
<xsd:attribute name="resolution-required" type="xsd:string"/>
<xsd:attribute name="ignore-channel-name-resolution-failures" type="xsd:string"/>
</xsd:extension>