You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cl...@apache.org on 2021/07/13 12:29:55 UTC

[activemq-artemis] 02/02: NO-JIRA Small tweaks on AMQPMessage. - adding annotations into toString() - comment typo

This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git

commit 18e9dee490007445ff8ec12899b6c66c678bcc6d
Author: Clebert Suconic <cl...@apache.org>
AuthorDate: Tue Jul 13 08:28:03 2021 -0400

    NO-JIRA Small tweaks on AMQPMessage.
    - adding annotations into toString()
    - comment typo
---
 .../org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java
index 18608d9..3ad1e46 100644
--- a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java
+++ b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java
@@ -1073,7 +1073,7 @@ public abstract class AMQPMessage extends RefCountMessage implements org.apache.
       if (header != null && header .getDurable() != null) {
          return header.getDurable();
       } 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
          return getDataScanningStatus() == MessageDataScanningStatus.RELOAD_PERSISTENCE;
       }
@@ -1706,6 +1706,7 @@ public abstract class AMQPMessage extends RefCountMessage implements org.apache.
          ", address=" + getAddress() +
          ", size=" + getEncodeSize() +
          ", applicationProperties=" + getApplicationPropertiesMap(false) +
+         ", messageAnnotations=" + getMessageAnnotationsMap(false) +
          ", properties=" + properties +
          ", extraProperties = " + getExtraProperties() +
          "]";