Author: ataylor Date: 2009-12-15 10:09:02 -0500 (Tue, 15 Dec 2009) New Revision: 8694 Modified: trunk/src/main/org/hornetq/core/message/impl/MessageImpl.java Log: buffer fix Modified: trunk/src/main/org/hornetq/core/message/impl/MessageImpl.java =================================================================== --- trunk/src/main/org/hornetq/core/message/impl/MessageImpl.java 2009-12-14 19:31:42 UTC (rev 8693) +++ trunk/src/main/org/hornetq/core/message/impl/MessageImpl.java 2009-12-15 15:09:02 UTC (rev 8694) @@ -838,8 +838,17 @@ // write it buffer.setInt(PacketImpl.PACKET_HEADERS_SIZE, endOfBodyPosition); - // Position at end of body and skip past the message end position int - buffer.setIndex(0, endOfBodyPosition + DataConstants.SIZE_INT); + // Position at end of body and skip past the message end position int. + // check for enough room in the buffer even tho it is dynamic + if((endOfBodyPosition + 4) > buffer.capacity()) + { + buffer.setIndex(0, endOfBodyPosition); + buffer.writeInt(0); + } + else + { + buffer.setIndex(0, endOfBodyPosition + DataConstants.SIZE_INT); + } encodeHeadersAndProperties(buffer);