[jboss-remoting-commits] JBoss Remoting SVN: r6135 - 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:18:56 -0500 (Fri, 12 Nov 2010)
New Revision: 6135

Modified:
   remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/OutboundStream.java
Log:
JBREM-1251: Added getFlushBuffer(), which creates a buffer initialized with RemoteProtocol.STREAM_FLUSH.

Modified: remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/OutboundStream.java
===================================================================
--- remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/OutboundStream.java	2010-11-12 17:13:20 UTC (rev 6134)
+++ remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/OutboundStream.java	2010-11-12 17:18:56 UTC (rev 6135)
@@ -64,6 +64,19 @@
         buffer.putInt(id);
         return buffer;
     }
+    
+    /**
+     * Get a buffer for sendng a FLUSH message.
+     *
+     * @return the next buffer
+     */
+    ByteBuffer getFlushBuffer() {
+        final ByteBuffer buffer = remoteConnection.allocate();
+        buffer.putShort(RemoteConnectionHandler.LENGTH_PLACEHOLDER);
+        buffer.put(RemoteProtocol.STREAM_FLUSH);
+        buffer.putInt(id);
+        return buffer;
+    }
 
     /**
      * Send a buffer acquired above.