Author: ron.sigal(a)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.
Show replies by date