Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * Copyright 2002-2010 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.xml.splitter;
 
 import java.io.File;
 import java.util.List;
 import java.util.Map;
 
 
 
Message Splitter that uses an org.springframework.xml.xpath.XPathExpression to split a org.w3c.dom.Document, java.io.File or java.lang.String payload into a org.w3c.dom.NodeList. The return value will be either Strings or org.w3c.dom.Nodes depending on the received payload type. Additionally, node types will be converted to Documents if the 'createDocuments' property is set to true.

Author(s):
Jonas Partner
Mark Fisher
 
 public class XPathMessageSplitter extends AbstractMessageSplitter {
 
 	private final XPathExpression xpathExpression;
 
 	private volatile boolean createDocuments;
 
 
 
 
 	public XPathMessageSplitter(String expression) {
 		this(expressionnew HashMap<StringString>());
 	}
 
 	public XPathMessageSplitter(String expressionMap<StringStringnamespaces) {
 		this(XPathExpressionFactory.createXPathExpression(expressionnamespaces));
 	}
 
 	public XPathMessageSplitter(XPathExpression xpathExpression) {
 		this. = xpathExpression;
 		this. = DocumentBuilderFactory.newInstance();
 	}
 
 
 	public void setCreateDocuments(boolean createDocuments) {
 		this. = createDocuments;
 	}
 
 	public String getComponentType() {
 		return "xml:xpath-splitter";
 	}
 
 	public void setDocumentBuilder(DocumentBuilderFactory documentBuilderFactory) {
 		Assert.notNull(documentBuilderFactory"DocumentBuilderFactory must not be null");
 		this. = documentBuilderFactory;
 	}
 
 	public void setXmlPayloadConverter(XmlPayloadConverter xmlPayloadConverter) {
 		Assert.notNull(xmlPayloadConverter"XmlPayloadConverter must not be null");
 		this. = xmlPayloadConverter;
 	}
 
	protected Object splitMessage(Message<?> message) {
		try {
			Object payload = message.getPayload();
			Object result = null;
			if (payload instanceof Node) {
				result = splitNode((Nodepayload);
			}
			else {
				Document document = this..convertToDocument(payload);
				Assert.notNull(document"unsupported payload type [" + payload.getClass().getName() + "]");
				result = splitDocument(document);
			}
			return result;
		}
			throw new MessagingException(message"failed to create DocumentBuilder"e);
		}
		catch (Exception e) {
			throw new MessagingException(message"failed to split Message payload"e);
		}
	}
	private Object splitDocument(Document documentthrows Exception {
		List<Nodenodes = splitNode(document);
		Transformer transformer = TransformerFactory.newInstance().newTransformer();
		List<StringsplitStrings = new ArrayList<String>(nodes.size());
		for (Node nodeFromList : nodes) {
			StringResult result = new StringResult();
			transformer.transform(new DOMSource(nodeFromList), result);
			splitStrings.add(result.toString());
		}
		return splitStrings;
	}
	private List<NodesplitNode(Node nodethrows ParserConfigurationException {
		List<NodenodeList = this..evaluateAsNodeList(node);
		if (nodeList.size() == 0) {
			throw new IllegalArgumentException("failed to split message with XPath expression: " + this.);
		}
		if (this.) {
			return convertNodesToDocuments(nodeList);
		}
		return nodeList;
	}
		DocumentBuilder documentBuilder = this.getNewDocumentBuilder();
		List<Nodedocuments = new ArrayList<Node>(nodes.size());
		for (Node node : nodes) {
			Document document = documentBuilder.newDocument();
			document.appendChild(document.importNode(nodetrue));
			documents.add(document);
		}
		return documents;
	}
		synchronized (this.) {
		}
	}
New to GrepCode? Check out our FAQ X