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/11/28 14:54:52 UTC

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

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
                 }