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

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

Author: david.lloyd at jboss.com
Date: 2010-03-03 23:57:00 -0500 (Wed, 03 Mar 2010)
New Revision: 5796

Modified:
   remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/OutboundReplyBufferWriter.java
   remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/OutboundRequestBufferWriter.java
Log:
Flush the last message immediately

Modified: remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/OutboundReplyBufferWriter.java
===================================================================
--- remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/OutboundReplyBufferWriter.java	2010-03-04 04:39:35 UTC (rev 5795)
+++ remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/OutboundReplyBufferWriter.java	2010-03-04 04:57:00 UTC (rev 5796)
@@ -73,7 +73,7 @@
                 buffer.put(7, (byte) (buffer.get(3) | RemoteProtocol.MSG_FLAG_LAST));
             }
             RemoteConnectionHandler.log.trace("Sending buffer %s for %s", buffer, this);
-            connectionHandler.getRemoteConnection().sendBlocking(buffer, false);
+            connectionHandler.getRemoteConnection().sendBlocking(buffer, eof);
         } finally {
             connectionHandler.getBufferPool().free(buffer);
         }

Modified: remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/OutboundRequestBufferWriter.java
===================================================================
--- remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/OutboundRequestBufferWriter.java	2010-03-04 04:39:35 UTC (rev 5795)
+++ remoting3/trunk/jboss-remoting/src/main/java/org/jboss/remoting3/remote/OutboundRequestBufferWriter.java	2010-03-04 04:57:00 UTC (rev 5796)
@@ -73,7 +73,7 @@
                 }
             }
             RemoteConnectionHandler.log.trace("Sending buffer %s for %s", buffer, this);
-            remoteConnectionHandler.getRemoteConnection().sendBlocking(buffer, false);
+            remoteConnectionHandler.getRemoteConnection().sendBlocking(buffer, eof);
         } finally {
             remoteConnectionHandler.getBufferPool().free(buffer);
         }