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

This closes #2504

This commit is contained in:
Michael Andre Pearce 2019-01-18 01:03:47 +00:00
parent 82ab6ff159 07fa93dfae
commit 7efa6187d8
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java
View File

@ -815,13 +815,13 @@ public class AMQPMessage extends RefCountMessage {
encoder.writeObject(applicationProperties);
// Now raw write the remainder body and footer if present.
if (remainingBodyPosition != VALUE_NOT_PRESENT) {
if (data != null && remainingBodyPosition != VALUE_NOT_PRESENT) {
writable.put(data.position(remainingBodyPosition));
}
} else if (applicationPropertiesPosition != VALUE_NOT_PRESENT) {
} else if (data != null && applicationPropertiesPosition != VALUE_NOT_PRESENT) {
// Writes out ApplicationProperties, Body and Footer in one go if present.
writable.put(data.position(applicationPropertiesPosition));
} else if (remainingBodyPosition != VALUE_NOT_PRESENT) {
} else if (data != null && remainingBodyPosition != VALUE_NOT_PRESENT) {
// No Application properties at all so raw write Body and Footer sections
writable.put(data.position(remainingBodyPosition));
}