You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by gn...@apache.org on 2006/02/16 13:57:09 UTC
svn commit: r378237 -
/incubator/servicemix/trunk/servicemix-jsr181/src/main/java/org/apache/servicemix/jsr181/xfire/JbiChannel.java
Author: gnodet
Date: Thu Feb 16 04:57:05 2006
New Revision: 378237
URL: http://svn.apache.org/viewcvs?rev=378237&view=rev
Log:
Use SourceTransformer to overcome stax impl limitations
when transforming a DOM source to an XMLStreamReader
Modified:
incubator/servicemix/trunk/servicemix-jsr181/src/main/java/org/apache/servicemix/jsr181/xfire/JbiChannel.java
Modified: incubator/servicemix/trunk/servicemix-jsr181/src/main/java/org/apache/servicemix/jsr181/xfire/JbiChannel.java
URL: http://svn.apache.org/viewcvs/incubator/servicemix/trunk/servicemix-jsr181/src/main/java/org/apache/servicemix/jsr181/xfire/JbiChannel.java?rev=378237&r1=378236&r2=378237&view=diff
==============================================================================
--- incubator/servicemix/trunk/servicemix-jsr181/src/main/java/org/apache/servicemix/jsr181/xfire/JbiChannel.java (original)
+++ incubator/servicemix/trunk/servicemix-jsr181/src/main/java/org/apache/servicemix/jsr181/xfire/JbiChannel.java Thu Feb 16 04:57:05 2006
@@ -33,6 +33,8 @@
import javax.xml.transform.Source;
import javax.xml.transform.stream.StreamSource;
+import org.apache.servicemix.jbi.jaxp.SourceTransformer;
+import org.apache.servicemix.jbi.jaxp.StAXSourceTransformer;
import org.codehaus.xfire.MessageContext;
import org.codehaus.xfire.XFireException;
import org.codehaus.xfire.exchange.InMessage;
@@ -53,9 +55,12 @@
public static final String JBI_SERVICE_NAME = "jbi.service";
public static final String JBI_ENDPOINT = "jbi.endpoint";
+ private StAXSourceTransformer sourceTransformer;
+
public JbiChannel(String uri, JbiTransport transport) {
setTransport(transport);
setUri(uri);
+ this.sourceTransformer = new StAXSourceTransformer();
}
public void open() throws Exception {
@@ -105,7 +110,7 @@
me.setStatus(ExchangeStatus.DONE);
channel.send(me);
- InMessage inMessage = new InMessage(XMLInputFactory.newInstance().createXMLStreamReader(outSrc), getUri());
+ InMessage inMessage = new InMessage(sourceTransformer.toXMLStreamReader(outSrc), getUri());
getEndpoint().onReceive(context, inMessage);
} else {
// TODO