You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2009/02/13 03:35:51 UTC
svn commit: r743960 -
/camel/trunk/components/camel-saxon/src/main/java/org/apache/camel/component/xquery/XQueryBuilder.java
Author: ningjiang
Date: Fri Feb 13 02:35:51 2009
New Revision: 743960
URL: http://svn.apache.org/viewvc?rev=743960&view=rev
Log:
CAMEL-1337 The expression evaluations should rest the cached stream
Modified:
camel/trunk/components/camel-saxon/src/main/java/org/apache/camel/component/xquery/XQueryBuilder.java
Modified: camel/trunk/components/camel-saxon/src/main/java/org/apache/camel/component/xquery/XQueryBuilder.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-saxon/src/main/java/org/apache/camel/component/xquery/XQueryBuilder.java?rev=743960&r1=743959&r2=743960&view=diff
==============================================================================
--- camel/trunk/components/camel-saxon/src/main/java/org/apache/camel/component/xquery/XQueryBuilder.java (original)
+++ camel/trunk/components/camel-saxon/src/main/java/org/apache/camel/component/xquery/XQueryBuilder.java Fri Feb 13 02:35:51 2009
@@ -60,6 +60,7 @@
import org.apache.camel.converter.jaxp.StringSource;
import org.apache.camel.converter.jaxp.XmlConverter;
import org.apache.camel.spi.NamespaceAware;
+import org.apache.camel.util.MessageHelper;
import org.apache.camel.util.ObjectHelper;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
@@ -424,8 +425,10 @@
DocumentInfo doc = getStaticQueryContext().buildDocument(source);
dynamicQueryContext.setContextItem(doc);
}
-
+
configureQuery(dynamicQueryContext, exchange);
+ // call the reset if the in message body is StreamCache
+ MessageHelper.resetStreamCache(exchange.getIn());
return dynamicQueryContext;
}