Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Improving bodyBuffer encode / decode

This commit is contained in:
Clebert Suconic 2016-01-27 21:31:01 -05:00
parent a5aa44670d
commit f149e76b3f
1 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
artemis-core-client/src/main/java/org/apache/activemq/artemis/core/message/impl/MessageImpl.java
View File

@ -279,8 +279,8 @@ public abstract class MessageImpl implements MessageInternal {
ByteBuf byteBuf = ChannelBufferWrapper.unwrap(getBodyBuffer().byteBuf()); ByteBuf byteBuf = ChannelBufferWrapper.unwrap(getBodyBuffer().byteBuf());
byteBuf = byteBuf.duplicate(); byteBuf = byteBuf.duplicate();
byteBuf.writerIndex(getBodyBuffer().writerIndex());
byteBuf.readerIndex(getBodyBuffer().readerIndex()); byteBuf.readerIndex(getBodyBuffer().readerIndex());
byteBuf.writerIndex(getBodyBuffer().writerIndex());
return new ResetLimitWrappedActiveMQBuffer(BODY_OFFSET, byteBuf, null); return new ResetLimitWrappedActiveMQBuffer(BODY_OFFSET, byteBuf, null);
} }
@ -439,6 +439,17 @@ public abstract class MessageImpl implements MessageInternal {
this.buffer = buffer; this.buffer = buffer;
decode(); decode();
// Setting up the BodyBuffer based on endOfBodyPosition set from decode
ResetLimitWrappedActiveMQBuffer tmpbodyBuffer = new ResetLimitWrappedActiveMQBuffer(BODY_OFFSET, buffer, null);
tmpbodyBuffer.readerIndex(BODY_OFFSET);
tmpbodyBuffer.writerIndex(endOfBodyPosition);
// only set this after the writer and reader is set,
// otherwise the buffer would be reset through the listener
tmpbodyBuffer.setMessage(this);
this.bodyBuffer = tmpbodyBuffer;
} }
@Override @Override