Apache/activemq-artemis
1
0
Fork 0
mirror of https://github.com/apache/activemq-artemis.git synced 2025-02-21 17:46:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

This closes #1068

Browse Source
This commit is contained in:
Clebert Suconic 2017-03-06 22:12:25 -05:00
commit 5316a80484
4 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -514,7 +514,7 @@ public class CoreMessage extends RefCountMessage implements ICoreMessage {
// so we always need to take the BUFFER_HEADER_SPACE from packet impl into consideration
endOfBodyPosition = writableBuffer.writerIndex() + BUFFER_HEADER_SPACE - 4;
} else if (endOfBodyPosition <= 0) {
endOfBodyPosition = BUFFER_HEADER_SPACE;
endOfBodyPosition = BUFFER_HEADER_SPACE + DataConstants.SIZE_INT;
}
buffer.setIndex(0, 0);

2
artemis-core-client/src/test/java/org/apache/activemq/artemis/message/CoreMessageTest.java
View File

@ -197,7 +197,7 @@ public class CoreMessageTest {
empty2.receiveBuffer(buffer);
try {
empty2.getBodyBuffer().readByte();
empty2.getBodyBuffer().readLong();
Assert.fail("should throw exception");
} catch (Exception expected) {

3
examples/features/standard/divert/src/main/java/org/apache/activemq/artemis/jms/example/AddForwardingTimeTransformer.java
View File

@ -17,12 +17,15 @@
package org.apache.activemq.artemis.jms.example;
import org.apache.activemq.artemis.api.core.Message;
import org.apache.activemq.artemis.api.core.SimpleString;
import org.apache.activemq.artemis.core.server.cluster.Transformer;
public class AddForwardingTimeTransformer implements Transformer {
@Override
public Message transform(final Message message) {
message.putLongProperty(new SimpleString("time_of_forward"), System.currentTimeMillis());
return message;
}

2
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/client/ConsumerTest.java
View File

@ -190,6 +190,8 @@ public class ConsumerTest extends ActiveMQTestBase {
Assert.assertEquals("hi", message2.getReadOnlyBodyBuffer().readString());
Assert.assertNull(consumer.receiveImmediate());
session.close();
}