[jboss-remoting-commits] JBoss Remoting SVN: r6136 - remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote.

[jboss-remoting-commits at lists.jboss.org]

Author: ron.sigal at jboss.com
Date: 2010-11-12 12:26:56 -0500 (Fri, 12 Nov 2010)
New Revision: 6136

Modified:
   remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/PrimaryExternalizerFactory.java
Log:
JBREM-1251: Updated flush() in NioByteOutput returned by PrimaryExternalizerFactory.readOutboundStream() to send buffer with RemoteProtocol.STREAM_FLUSH.

Modified: remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/PrimaryExternalizerFactory.java
===================================================================
--- remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/PrimaryExternalizerFactory.java	2010-11-12 17:18:56 UTC (rev 6135)
+++ remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/PrimaryExternalizerFactory.java	2010-11-12 17:26:56 UTC (rev 6136)
@@ -276,6 +276,9 @@
             }
 
             public void flush() throws IOException {
+            	ByteBuffer flushBuffer = outboundStream.getFlushBuffer();
+            	flushBuffer.flip();
+            	outboundStream.send(flushBuffer);
             }
         });
     }