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

INT-1659 added 'evaluateAsNode' attribute to XPath router, added tests

Browse Source
This commit is contained in:
Oleg Zhurakousky
2010-12-03 10:25:58 -05:00
parent 616d44a290
commit 317d2cad7f
2 changed files with 47 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
spring-integration-xml/src/main/java/org/springframework/integration/xml/router/XPathRouter.java
View File

@@ -16,6 +16,7 @@
package org.springframework.integration.xml.router;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -45,7 +46,8 @@ public class XPathRouter extends AbstractMessageRouter {
private final XPathExpression xPathExpression;
private volatile XmlPayloadConverter converter = new DefaultXmlPayloadConverter();
private volatile boolean evaluateAsNode = true;
/**
* Create a router that uses an XPath expression. The expression may
@@ -95,6 +97,9 @@ public class XPathRouter extends AbstractMessageRouter {
this.xPathExpression = expression;
}
public void setEvaluateAsNode(boolean evaluateAsNode) {
this.evaluateAsNode = evaluateAsNode;
}
/**
* Specify the Converter to use when converting payloads prior to XPath evaluation.
@@ -110,9 +115,14 @@ public class XPathRouter extends AbstractMessageRouter {
@Override
@SuppressWarnings("unchecked")
public List<Object> getChannelIdentifiers(Message<?> message) {
protected List<Object> getChannelIdentifiers(Message<?> message) {
Node node = this.converter.convertToNode(message.getPayload());
return this.xPathExpression.evaluate(node, this.nodeMapper);
if (this.evaluateAsNode){
return this.xPathExpression.evaluate(node, this.nodeMapper);
}
else {
return Collections.singletonList((Object)this.xPathExpression.evaluateAsString(node));
}
}