Author: david.lloyd(a)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);
}