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

NO-JIRA Small tweaks on AMQPMessage. 

- adding annotations into toString()
- comment typo
This commit is contained in:
Clebert Suconic 2021-07-13 08:28:03 -04:00
parent fb5f6a3f82
commit 18e9dee490
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1073,7 +1073,7 @@ public abstract class AMQPMessage extends RefCountMessage implements org.apache.
if (header != null && header .getDurable() != null) { if (header != null && header .getDurable() != null) {
return header.getDurable(); return header.getDurable();
} else { } else {
// if header == null and scanninStatus=RELOAD_PERSISTENCE, it means the message can only be durable // if header == null and scanningStatus=RELOAD_PERSISTENCE, it means the message can only be durable
// even though the parsing hasn't happened yet // even though the parsing hasn't happened yet
return getDataScanningStatus() == MessageDataScanningStatus.RELOAD_PERSISTENCE; return getDataScanningStatus() == MessageDataScanningStatus.RELOAD_PERSISTENCE;
} }
@ -1706,6 +1706,7 @@ public abstract class AMQPMessage extends RefCountMessage implements org.apache.
", address=" + getAddress() + ", address=" + getAddress() +
", size=" + getEncodeSize() + ", size=" + getEncodeSize() +
", applicationProperties=" + getApplicationPropertiesMap(false) + ", applicationProperties=" + getApplicationPropertiesMap(false) +
", messageAnnotations=" + getMessageAnnotationsMap(false) +
", properties=" + properties + ", properties=" + properties +
", extraProperties = " + getExtraProperties() + ", extraProperties = " + getExtraProperties() +
"]"; "]";