svn commit: r669515 - /cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIConduitOutputStream.java

[gnodet]

Author: gnodet
Date: Thu Jun 19 08:53:15 2008
New Revision: 669515

URL: http://svn.apache.org/viewvc?rev=669515&view=rev
Log:
Send the DONE status from the jbi proxy, which should also fix the systests 
hanging

Modified:
    
cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIConduitOutputStream.java

Modified: 
cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIConduitOutputStream.java
URL: 
http://svn.apache.org/viewvc/cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIConduitOutputStream.java?rev=669515&r1=669514&r2=669515&view=diff
==============================================================================
--- 
cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIConduitOutputStream.java
 (original)
+++ 
cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIConduitOutputStream.java
 Thu Jun 19 08:53:15 2008
@@ -26,6 +26,7 @@
 import java.util.logging.Logger;
 
 import javax.jbi.messaging.DeliveryChannel;
+import javax.jbi.messaging.ExchangeStatus;
 import javax.jbi.messaging.InOut;
 import javax.jbi.messaging.MessageExchange;
 import javax.jbi.messaging.MessageExchangeFactory;
@@ -147,9 +148,9 @@
                     
                     
                     conduit.getMessageObserver().onMessage(inMessage);
-                    
-                    
-                    
+
+                    xchng.setStatus(ExchangeStatus.DONE);
+                    channel.send(xchng);                    
                 } else {
                     channel.send(xchng);
                 }