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
}