This closes #583

This commit is contained in:
Clebert Suconic 2016-06-17 15:04:32 -04:00
commit 824b316719
1 changed files with 1 additions and 0 deletions

View File

@ -259,6 +259,7 @@ public class ProtonHandlerImpl extends ProtonInitializable implements ProtonHand
ByteBuf buffer = PooledByteBufAllocator.DEFAULT.buffer(size);
ByteBuffer head = transport.head();
head.position(offset);
head.limit(offset + size);
buffer.writeBytes(head);
offset += size; // incrementing offset for future calls
return buffer;