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