diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/config/AbstractTargetEndpointParser.java b/org.springframework.integration/src/main/java/org/springframework/integration/config/AbstractTargetEndpointParser.java index 8cfed040ca..7c302097e6 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/config/AbstractTargetEndpointParser.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/config/AbstractTargetEndpointParser.java @@ -85,13 +85,14 @@ public abstract class AbstractTargetEndpointParser extends AbstractSingleBeanDef for (int i = 0; i < childNodes.getLength(); i++) { Node child = childNodes.item(i); if (child.getNodeType() == Node.ELEMENT_NODE) { + Element childElement = (Element) child; String localName = child.getLocalName(); if (SCHEDULE_ELEMENT.equals(localName)) { - schedule = this.parseSchedule((Element) child); + schedule = this.parseSchedule(childElement); } else if (INTERCEPTORS_ELEMENT.equals(localName)) { - ManagedList interceptors = IntegrationNamespaceUtils.parseEndpointInterceptors( - (Element) child, parserContext); + EndpointInterceptorParser parser = new EndpointInterceptorParser(); + ManagedList interceptors = parser.parseEndpointInterceptors(childElement, parserContext); builder.addPropertyValue("interceptors", interceptors); } } diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/config/BeanDefinitionRegisteringParser.java b/org.springframework.integration/src/main/java/org/springframework/integration/config/BeanDefinitionRegisteringParser.java new file mode 100644 index 0000000000..22056b46ea --- /dev/null +++ b/org.springframework.integration/src/main/java/org/springframework/integration/config/BeanDefinitionRegisteringParser.java @@ -0,0 +1,35 @@ +/* + * Copyright 2002-2008 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; + +import org.w3c.dom.Element; + +import org.springframework.beans.factory.xml.ParserContext; + +/** + * Simple strategy interface for parsers that are responsible + * for parsing an element, creating a bean definition, and then + * registering the bean. The {@link #parse(Element, ParserContext)} + * method should return the name of the registered bean. + * + * @author Mark Fisher + */ +public interface BeanDefinitionRegisteringParser { + + String parse(Element element, ParserContext parserContext); + +} diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/config/ConcurrencyInterceptorParser.java b/org.springframework.integration/src/main/java/org/springframework/integration/config/ConcurrencyInterceptorParser.java new file mode 100644 index 0000000000..b073d36fe8 --- /dev/null +++ b/org.springframework.integration/src/main/java/org/springframework/integration/config/ConcurrencyInterceptorParser.java @@ -0,0 +1,74 @@ +/* + * Copyright 2002-2008 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; + +import org.w3c.dom.Element; + +import org.springframework.beans.factory.support.BeanDefinitionBuilder; +import org.springframework.beans.factory.support.BeanDefinitionReaderUtils; +import org.springframework.beans.factory.xml.ParserContext; +import org.springframework.integration.endpoint.ConcurrencyPolicy; +import org.springframework.integration.endpoint.interceptor.ConcurrencyInterceptor; +import org.springframework.util.StringUtils; + +/** + * Parser for the concurrency-interceptor. element. + * + * @author Mark Fisher + */ +public class ConcurrencyInterceptorParser implements BeanDefinitionRegisteringParser { + + public String parse(Element element, ParserContext parserContext) { + BeanDefinitionBuilder builder = BeanDefinitionBuilder.genericBeanDefinition(ConcurrencyInterceptor.class); + String taskExecutorRef = element.getAttribute("task-executor"); + if (StringUtils.hasText(taskExecutorRef)) { + if (element.getAttributes().getLength() != 1) { + parserContext.getReaderContext().error("No other attributes are permitted when " + + "specifying a 'task-executor' reference on the element.", + parserContext.extractSource(element)); + } + builder.addConstructorArgReference(taskExecutorRef); + } + else { + ConcurrencyPolicy policy = this.parseConcurrencyPolicy(element); + builder.addConstructorArgValue(policy); + } + return BeanDefinitionReaderUtils.registerWithGeneratedName(builder.getBeanDefinition(), parserContext.getRegistry()); + } + + private ConcurrencyPolicy parseConcurrencyPolicy(Element element) { + ConcurrencyPolicy policy = new ConcurrencyPolicy(); + String coreSize = element.getAttribute("core"); + String maxSize = element.getAttribute("max"); + String queueCapacity = element.getAttribute("queue-capacity"); + String keepAlive = element.getAttribute("keep-alive"); + if (StringUtils.hasText(coreSize)) { + policy.setCoreSize(Integer.parseInt(coreSize)); + } + if (StringUtils.hasText(maxSize)) { + policy.setMaxSize(Integer.parseInt(maxSize)); + } + if (StringUtils.hasText(queueCapacity)) { + policy.setQueueCapacity(Integer.parseInt(queueCapacity)); + } + if (StringUtils.hasText(keepAlive)) { + policy.setKeepAliveSeconds(Integer.parseInt(keepAlive)); + } + return policy; + } + +} diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/config/EndpointInterceptorParser.java b/org.springframework.integration/src/main/java/org/springframework/integration/config/EndpointInterceptorParser.java new file mode 100644 index 0000000000..572e5c91cb --- /dev/null +++ b/org.springframework.integration/src/main/java/org/springframework/integration/config/EndpointInterceptorParser.java @@ -0,0 +1,85 @@ +/* + * Copyright 2002-2008 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; + +import java.util.HashMap; +import java.util.Map; + +import org.w3c.dom.Element; +import org.w3c.dom.Node; +import org.w3c.dom.NodeList; + +import org.springframework.beans.factory.config.BeanDefinitionHolder; +import org.springframework.beans.factory.config.RuntimeBeanReference; +import org.springframework.beans.factory.parsing.BeanComponentDefinition; +import org.springframework.beans.factory.support.ManagedList; +import org.springframework.beans.factory.xml.BeanDefinitionParserDelegate; +import org.springframework.beans.factory.xml.ParserContext; +import org.springframework.integration.ConfigurationException; + +/** + * A helper class for parsing the sub-elements of an endpoint's + * interceptors element. + * + * @author Mark Fisher + */ +public class EndpointInterceptorParser { + + private final Map parsers = new HashMap(); + + + public EndpointInterceptorParser() { + this.parsers.put("transaction-interceptor", new TransactionInterceptorParser()); + this.parsers.put("concurrency-interceptor", new ConcurrencyInterceptorParser()); + } + + + @SuppressWarnings("unchecked") + public ManagedList parseEndpointInterceptors(Element element, ParserContext parserContext) { + ManagedList interceptors = new ManagedList(); + NodeList childNodes = element.getChildNodes(); + for (int i = 0; i < childNodes.getLength(); i++) { + Node child = childNodes.item(i); + if (child.getNodeType() == Node.ELEMENT_NODE) { + Element childElement = (Element) child; + String localName = child.getLocalName(); + if ("bean".equals(localName)) { + BeanDefinitionParserDelegate beanParser = new BeanDefinitionParserDelegate(parserContext.getReaderContext()); + beanParser.initDefaults(childElement.getOwnerDocument().getDocumentElement()); + BeanDefinitionHolder beanDefinitionHolder = beanParser.parseBeanDefinitionElement(childElement); + parserContext.registerBeanComponent(new BeanComponentDefinition(beanDefinitionHolder)); + interceptors.add(new RuntimeBeanReference(beanDefinitionHolder.getBeanName())); + } + else if ("ref".equals(localName)) { + String ref = childElement.getAttribute("bean"); + interceptors.add(new RuntimeBeanReference(ref)); + } + else { + BeanDefinitionRegisteringParser parser = this.parsers.get(localName); + if (parser == null) { + throw new ConfigurationException("No parser available for interceptor element '" + + localName + "'."); + } + String interceptorBeanName = parser.parse(childElement, parserContext); + interceptors.add(new RuntimeBeanReference(interceptorBeanName)); + } + } + } + return interceptors; + } + +} diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/config/IntegrationNamespaceUtils.java b/org.springframework.integration/src/main/java/org/springframework/integration/config/IntegrationNamespaceUtils.java index 14a03a5a7e..41a44568c1 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/config/IntegrationNamespaceUtils.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/config/IntegrationNamespaceUtils.java @@ -16,30 +16,10 @@ package org.springframework.integration.config; -import java.util.LinkedList; -import java.util.List; - import org.w3c.dom.Element; -import org.w3c.dom.Node; -import org.w3c.dom.NodeList; -import org.springframework.beans.factory.config.BeanDefinitionHolder; import org.springframework.beans.factory.config.RuntimeBeanReference; -import org.springframework.beans.factory.parsing.BeanComponentDefinition; -import org.springframework.beans.factory.support.BeanDefinitionBuilder; -import org.springframework.beans.factory.support.BeanDefinitionReaderUtils; -import org.springframework.beans.factory.support.ManagedList; import org.springframework.beans.factory.support.RootBeanDefinition; -import org.springframework.beans.factory.xml.BeanDefinitionParserDelegate; -import org.springframework.beans.factory.xml.ParserContext; -import org.springframework.integration.ConfigurationException; -import org.springframework.integration.endpoint.ConcurrencyPolicy; -import org.springframework.integration.endpoint.interceptor.ConcurrencyInterceptor; -import org.springframework.transaction.interceptor.MatchAlwaysTransactionAttributeSource; -import org.springframework.transaction.interceptor.NoRollbackRuleAttribute; -import org.springframework.transaction.interceptor.RollbackRuleAttribute; -import org.springframework.transaction.interceptor.RuleBasedTransactionAttribute; -import org.springframework.transaction.interceptor.TransactionInterceptor; import org.springframework.util.StringUtils; /** @@ -50,141 +30,6 @@ import org.springframework.util.StringUtils; */ public abstract class IntegrationNamespaceUtils { - private static final String CORE_SIZE_ATTRIBUTE = "core"; - - private static final String MAX_SIZE_ATTRIBUTE = "max"; - - private static final String QUEUE_CAPACITY_ATTRIBUTE = "queue-capacity"; - - private static final String KEEP_ALIVE_ATTRIBUTE = "keep-alive"; - - - public static ConcurrencyPolicy parseConcurrencyPolicy(Element element) { - ConcurrencyPolicy policy = new ConcurrencyPolicy(); - String coreSize = element.getAttribute(CORE_SIZE_ATTRIBUTE); - String maxSize = element.getAttribute(MAX_SIZE_ATTRIBUTE); - String queueCapacity = element.getAttribute(QUEUE_CAPACITY_ATTRIBUTE); - String keepAlive = element.getAttribute(KEEP_ALIVE_ATTRIBUTE); - if (StringUtils.hasText(coreSize)) { - policy.setCoreSize(Integer.parseInt(coreSize)); - } - if (StringUtils.hasText(maxSize)) { - policy.setMaxSize(Integer.parseInt(maxSize)); - } - if (StringUtils.hasText(queueCapacity)) { - policy.setQueueCapacity(Integer.parseInt(queueCapacity)); - } - if (StringUtils.hasText(keepAlive)) { - policy.setKeepAliveSeconds(Integer.parseInt(keepAlive)); - } - return policy; - } - - @SuppressWarnings("unchecked") - public static ManagedList parseEndpointInterceptors(Element element, ParserContext parserContext) { - ManagedList interceptors = new ManagedList(); - NodeList childNodes = element.getChildNodes(); - for (int i = 0; i < childNodes.getLength(); i++) { - Node child = childNodes.item(i); - if (child.getNodeType() == Node.ELEMENT_NODE) { - Element childElement = (Element) child; - String localName = child.getLocalName(); - if ("bean".equals(localName)) { - BeanDefinitionParserDelegate beanParser = new BeanDefinitionParserDelegate(parserContext.getReaderContext()); - beanParser.initDefaults(childElement.getOwnerDocument().getDocumentElement()); - BeanDefinitionHolder beanDefinitionHolder = beanParser.parseBeanDefinitionElement(childElement); - parserContext.registerBeanComponent(new BeanComponentDefinition(beanDefinitionHolder)); - interceptors.add(new RuntimeBeanReference(beanDefinitionHolder.getBeanName())); - } - else if ("ref".equals(localName)) { - String ref = childElement.getAttribute("bean"); - interceptors.add(new RuntimeBeanReference(ref)); - } - else if ("transaction-interceptor".equals(localName)) { - String txInterceptorBeanName = parseTransactionInterceptor(childElement, parserContext); - interceptors.add(new RuntimeBeanReference(txInterceptorBeanName)); - } - else if ("concurrency-interceptor".equals(localName)) { - String concurrencyInterceptorBeanName = parseConcurrencyInterceptor(childElement, parserContext); - interceptors.add(new RuntimeBeanReference(concurrencyInterceptorBeanName)); - } - } - } - return interceptors; - } - - private static String parseTransactionInterceptor(Element element, ParserContext parserContext) { - BeanDefinitionBuilder builder = BeanDefinitionBuilder.genericBeanDefinition(TransactionInterceptor.class); - String txManagerRef = element.getAttribute("transaction-manager"); - if (!StringUtils.hasText(txManagerRef)) { - txManagerRef = "transactionManager"; - } - builder.addPropertyReference("transactionManager", txManagerRef); - RuleBasedTransactionAttribute attribute = new RuleBasedTransactionAttribute(); - String propagation = element.getAttribute("propagation"); - String isolation = element.getAttribute("isolation"); - String timeout = element.getAttribute("timeout"); - String readOnly = element.getAttribute("read-only"); - if (StringUtils.hasText(propagation)) { - attribute.setPropagationBehaviorName(RuleBasedTransactionAttribute.PREFIX_PROPAGATION + propagation); - } - if (StringUtils.hasText(isolation)) { - attribute.setIsolationLevelName(RuleBasedTransactionAttribute.PREFIX_ISOLATION + isolation); - } - if (StringUtils.hasText(timeout)) { - try { - attribute.setTimeout(Integer.parseInt(timeout)); - } - catch (NumberFormatException ex) { - parserContext.getReaderContext().error("Timeout must be an integer value: [" + timeout + "]", element); - } - } - if (StringUtils.hasText(readOnly)) { - attribute.setReadOnly(Boolean.valueOf(readOnly).booleanValue()); - } - List rollbackRules = new LinkedList(); - if (element.hasAttribute("rollback-for")) { - String rollbackForValue = element.getAttribute("rollback-for"); - String[] exceptionTypeNames = StringUtils.commaDelimitedListToStringArray(rollbackForValue); - for (int i = 0; i < exceptionTypeNames.length; i++) { - rollbackRules.add(new RollbackRuleAttribute(StringUtils.trimWhitespace(exceptionTypeNames[i]))); - } - } - if (element.hasAttribute("no-rollback-for")) { - String noRollbackForValue = element.getAttribute("no-rollback-for"); - String[] exceptionTypeNames = StringUtils.commaDelimitedListToStringArray(noRollbackForValue); - for (int i = 0; i < exceptionTypeNames.length; i++) { - rollbackRules.add(new NoRollbackRuleAttribute(StringUtils.trimWhitespace(exceptionTypeNames[i]))); - } - } - attribute.setRollbackRules(rollbackRules); - RootBeanDefinition attributeSourceDefinition = new RootBeanDefinition(MatchAlwaysTransactionAttributeSource.class); - attributeSourceDefinition.setSource(parserContext.extractSource(element)); - attributeSourceDefinition.getPropertyValues().addPropertyValue("transactionAttribute", attribute); - String attributeSourceBeanName = BeanDefinitionReaderUtils.registerWithGeneratedName( - attributeSourceDefinition, parserContext.getRegistry()); - builder.addPropertyReference("transactionAttributeSource", attributeSourceBeanName); - return BeanDefinitionReaderUtils.registerWithGeneratedName(builder.getBeanDefinition(), parserContext.getRegistry()); - } - - private static String parseConcurrencyInterceptor(Element element, ParserContext parserContext) { - BeanDefinitionBuilder builder = BeanDefinitionBuilder.genericBeanDefinition(ConcurrencyInterceptor.class); - String taskExecutorRef = element.getAttribute("task-executor"); - if (StringUtils.hasText(taskExecutorRef)) { - if (element.getAttributes().getLength() != 1) { - parserContext.getReaderContext().error("No other attributes are permitted when " - + "specifying a 'task-executor' reference on the element.", - parserContext.extractSource(element)); - } - builder.addConstructorArgReference(taskExecutorRef); - } - else { - ConcurrencyPolicy policy = IntegrationNamespaceUtils.parseConcurrencyPolicy(element); - builder.addConstructorArgValue(policy); - } - return BeanDefinitionReaderUtils.registerWithGeneratedName(builder.getBeanDefinition(), parserContext.getRegistry()); - } - /** * Populates the property identified by propertyName on the bean definition * to the value of the attribute specified by attributeName, if that diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/config/MessageBusParser.java b/org.springframework.integration/src/main/java/org/springframework/integration/config/MessageBusParser.java index 94ea283907..936d699367 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/config/MessageBusParser.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/config/MessageBusParser.java @@ -51,10 +51,6 @@ public class MessageBusParser extends AbstractSimpleBeanDefinitionParser { private static final String ERROR_CHANNEL_ATTRIBUTE = "error-channel"; - private static final String DEFAULT_CONCURRENCY_ELEMENT = "default-concurrency"; - - private static final String DEFAULT_CONCURRENCY_PROPERTY = "defaultConcurrencyPolicy"; - private static final String CHANNEL_FACTORY_ATTRIBUTE = "channel-factory"; private static final String INTERCEPTOR_ELEMENT = "interceptor"; @@ -109,10 +105,6 @@ public class MessageBusParser extends AbstractSimpleBeanDefinitionParser { Node child = childNodes.item(i); if (child.getNodeType() == Node.ELEMENT_NODE) { String localName = child.getLocalName(); - if (DEFAULT_CONCURRENCY_ELEMENT.equals(localName)) { - beanDefinition.addPropertyValue(DEFAULT_CONCURRENCY_PROPERTY, - IntegrationNamespaceUtils.parseConcurrencyPolicy((Element) child)); - } if (INTERCEPTOR_ELEMENT.equals(localName)) { interceptors.add(new RuntimeBeanReference(((Element)child).getAttribute(REFERENCE_ATTRIBUTE))); } diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/config/SourceEndpointParser.java b/org.springframework.integration/src/main/java/org/springframework/integration/config/SourceEndpointParser.java index 0088b423c0..02b1ce30a9 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/config/SourceEndpointParser.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/config/SourceEndpointParser.java @@ -71,8 +71,8 @@ public class SourceEndpointParser extends AbstractSimpleBeanDefinitionParser { builder.addPropertyValue("schedule", this.parseSchedule(scheduleElement)); Element interceptorsElement = DomUtils.getChildElementByTagName(element, "interceptors"); if (interceptorsElement != null) { - ManagedList interceptors = IntegrationNamespaceUtils.parseEndpointInterceptors( - interceptorsElement, parserContext); + EndpointInterceptorParser parser = new EndpointInterceptorParser(); + ManagedList interceptors = parser.parseEndpointInterceptors(interceptorsElement, parserContext); builder.addPropertyValue("interceptors", interceptors); } } diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/config/TransactionInterceptorParser.java b/org.springframework.integration/src/main/java/org/springframework/integration/config/TransactionInterceptorParser.java new file mode 100644 index 0000000000..78f2269b42 --- /dev/null +++ b/org.springframework.integration/src/main/java/org/springframework/integration/config/TransactionInterceptorParser.java @@ -0,0 +1,97 @@ +/* + * Copyright 2002-2008 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; + +import java.util.LinkedList; +import java.util.List; + +import org.w3c.dom.Element; + +import org.springframework.beans.factory.support.BeanDefinitionBuilder; +import org.springframework.beans.factory.support.BeanDefinitionReaderUtils; +import org.springframework.beans.factory.support.RootBeanDefinition; +import org.springframework.beans.factory.xml.ParserContext; +import org.springframework.transaction.interceptor.MatchAlwaysTransactionAttributeSource; +import org.springframework.transaction.interceptor.NoRollbackRuleAttribute; +import org.springframework.transaction.interceptor.RollbackRuleAttribute; +import org.springframework.transaction.interceptor.RuleBasedTransactionAttribute; +import org.springframework.transaction.interceptor.TransactionInterceptor; +import org.springframework.util.StringUtils; + +/** + * Parser for the transaction-interceptor element. + * + * @author Mark Fisher + */ +public class TransactionInterceptorParser implements BeanDefinitionRegisteringParser { + + @SuppressWarnings("unchecked") + public String parse(Element element, ParserContext parserContext) { + BeanDefinitionBuilder builder = BeanDefinitionBuilder.genericBeanDefinition(TransactionInterceptor.class); + String txManagerRef = element.getAttribute("transaction-manager"); + if (!StringUtils.hasText(txManagerRef)) { + txManagerRef = "transactionManager"; + } + builder.addPropertyReference("transactionManager", txManagerRef); + RuleBasedTransactionAttribute attribute = new RuleBasedTransactionAttribute(); + String propagation = element.getAttribute("propagation"); + String isolation = element.getAttribute("isolation"); + String timeout = element.getAttribute("timeout"); + String readOnly = element.getAttribute("read-only"); + if (StringUtils.hasText(propagation)) { + attribute.setPropagationBehaviorName(RuleBasedTransactionAttribute.PREFIX_PROPAGATION + propagation); + } + if (StringUtils.hasText(isolation)) { + attribute.setIsolationLevelName(RuleBasedTransactionAttribute.PREFIX_ISOLATION + isolation); + } + if (StringUtils.hasText(timeout)) { + try { + attribute.setTimeout(Integer.parseInt(timeout)); + } + catch (NumberFormatException ex) { + parserContext.getReaderContext().error("Timeout must be an integer value: [" + timeout + "]", element); + } + } + if (StringUtils.hasText(readOnly)) { + attribute.setReadOnly(Boolean.valueOf(readOnly).booleanValue()); + } + List rollbackRules = new LinkedList(); + if (element.hasAttribute("rollback-for")) { + String rollbackForValue = element.getAttribute("rollback-for"); + String[] exceptionTypeNames = StringUtils.commaDelimitedListToStringArray(rollbackForValue); + for (int i = 0; i < exceptionTypeNames.length; i++) { + rollbackRules.add(new RollbackRuleAttribute(StringUtils.trimWhitespace(exceptionTypeNames[i]))); + } + } + if (element.hasAttribute("no-rollback-for")) { + String noRollbackForValue = element.getAttribute("no-rollback-for"); + String[] exceptionTypeNames = StringUtils.commaDelimitedListToStringArray(noRollbackForValue); + for (int i = 0; i < exceptionTypeNames.length; i++) { + rollbackRules.add(new NoRollbackRuleAttribute(StringUtils.trimWhitespace(exceptionTypeNames[i]))); + } + } + attribute.setRollbackRules(rollbackRules); + RootBeanDefinition attributeSourceDefinition = new RootBeanDefinition(MatchAlwaysTransactionAttributeSource.class); + attributeSourceDefinition.setSource(parserContext.extractSource(element)); + attributeSourceDefinition.getPropertyValues().addPropertyValue("transactionAttribute", attribute); + String attributeSourceBeanName = BeanDefinitionReaderUtils.registerWithGeneratedName( + attributeSourceDefinition, parserContext.getRegistry()); + builder.addPropertyReference("transactionAttributeSource", attributeSourceBeanName); + return BeanDefinitionReaderUtils.registerWithGeneratedName(builder.getBeanDefinition(), parserContext.getRegistry()); + } + +}