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

ARTEMIS-357 fixing issue with Messages Growing after JMS sends (after my last change on ARTEMIS-357)

This commit is contained in:
Clebert Suconic 2016-01-26 22:30:24 -05:00
parent ff95b216ef
commit 4d239ac803
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
artemis-core-client/src/main/java/org/apache/activemq/artemis/core/buffers/impl/ResetLimitWrappedActiveMQBuffer.java
View File

@ -45,7 +45,7 @@ public final class ResetLimitWrappedActiveMQBuffer extends ChannelBufferWrapper
public ResetLimitWrappedActiveMQBuffer(final int limit, final ActiveMQBuffer buffer, final MessageInternal message) { public ResetLimitWrappedActiveMQBuffer(final int limit, final ActiveMQBuffer buffer, final MessageInternal message) {
// a wrapped inside a wrapper will increase the stack size. // a wrapped inside a wrapper will increase the stack size.
// we fixed this here due to some profiling testing // we fixed this here due to some profiling testing
super(unwrap(buffer.byteBuf())); super(unwrap(buffer.byteBuf()).duplicate());
this.limit = limit; this.limit = limit;
@ -53,7 +53,7 @@ public final class ResetLimitWrappedActiveMQBuffer extends ChannelBufferWrapper
writerIndex(limit); writerIndex(limit);
} }
buffer.readerIndex(limit); readerIndex(limit);
this.message = message; this.message = message;
} }

2
artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientMessageImpl.java
View File

@ -136,7 +136,7 @@ public class ClientMessageImpl extends MessageImpl implements ClientMessageInter
@Override @Override
public int getBodySize() { public int getBodySize() {
return buffer.writerIndex() - buffer.readerIndex(); return getBodyBuffer().writerIndex() - getBodyBuffer().readerIndex();
} }
@Override @Override

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

@ -448,7 +448,7 @@ public abstract class MessageImpl implements MessageInternal {
@Override @Override
public int getEndOfBodyPosition() { public int getEndOfBodyPosition() {
if (endOfBodyPosition < 0) { if (endOfBodyPosition < 0) {
endOfBodyPosition = buffer.writerIndex(); endOfBodyPosition = getBodyBuffer().writerIndex();
} }
return endOfBodyPosition; return endOfBodyPosition;
} }