Author: clebert.suconic(a)jboss.com
Date: 2011-01-01 19:48:23 -0500 (Sat, 01 Jan 2011)
New Revision: 10100
Modified:
trunk/src/main/org/hornetq/core/client/impl/ClientMessageImpl.java
Log:
HORNETQ-604 - flush
Modified: trunk/src/main/org/hornetq/core/client/impl/ClientMessageImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/client/impl/ClientMessageImpl.java 2011-01-02 00:38:16
UTC (rev 10099)
+++ trunk/src/main/org/hornetq/core/client/impl/ClientMessageImpl.java 2011-01-02 00:48:23
UTC (rev 10100)
@@ -147,6 +147,7 @@
byte readBuffer[] = new byte[getBodySize()];
getBodyBuffer().readBytes(readBuffer);
out.write(readBuffer);
+ out.flush();
}
catch (IOException e)
{
Show replies by date