Author: gnodet
Date: Tue Nov 28 05:54:51 2006
New Revision: 480042

URL: http://svn.apache.org/viewvc?view=rev&rev=480042
Log:
SM-759: Error "Attempted read on closed stream" thrown from jsr181 proxies when 
dealing with streams

Modified:
    
incubator/servicemix/trunk/deployables/serviceengines/servicemix-jsr181/src/main/java/org/apache/servicemix/jsr181/xfire/JbiChannel.java

Modified: 
incubator/servicemix/trunk/deployables/serviceengines/servicemix-jsr181/src/main/java/org/apache/servicemix/jsr181/xfire/JbiChannel.java
URL: 
http://svn.apache.org/viewvc/incubator/servicemix/trunk/deployables/serviceengines/servicemix-jsr181/src/main/java/org/apache/servicemix/jsr181/xfire/JbiChannel.java?view=diff&rev=480042&r1=480041&r2=480042
==============================================================================
--- 
incubator/servicemix/trunk/deployables/serviceengines/servicemix-jsr181/src/main/java/org/apache/servicemix/jsr181/xfire/JbiChannel.java
 (original)
+++ 
incubator/servicemix/trunk/deployables/serviceengines/servicemix-jsr181/src/main/java/org/apache/servicemix/jsr181/xfire/JbiChannel.java
 Tue Nov 28 05:54:51 2006
@@ -107,11 +107,12 @@
                         throw new 
XFireFault(sourceTransformer.contentToString(me.getFault()), 
XFireFault.RECEIVER);
                     }
                     Source outSrc = me.getOutMessage().getContent();
-                    me.setStatus(ExchangeStatus.DONE);
-                    channel.send(me);
 
                     InMessage inMessage = new 
InMessage(sourceTransformer.toXMLStreamReader(outSrc), getUri());
                     getEndpoint().onReceive(context, inMessage);
+
+                    me.setStatus(ExchangeStatus.DONE);
+                    channel.send(me);
                 } else {
                     // TODO
                 }


Reply via email to